tools

May 4, 2024

Changes in this version

+ func AnyKeyToExit(log Logger, cancel context.CancelFunc)

May 3, 2024

Changes in this version

+ func NewID() string

+ func NewIDFromTimestamp(timestamp time.Time) string

+ type Retry struct

+ func NewRetry(log Logger, max int, delay time.Duration) *Retry

+ func (r *Retry) Do(task func() error) error

type Scheduler

+ func NewSchedulerWRoutineLimiter[I any, O any](rl *RoutineLimiter, task func(I) O) *Scheduler[I, O]

+ func (s *Scheduler[I, O]) QueryLen() int

Apr 7, 2024

Changes in this version

+ type SafeSlice struct

+ func NewSafeSlice[T any]() *SafeSlice[T]

+ func (ss *SafeSlice[T]) Delete(i int)

+ func (ss *SafeSlice[T]) Get(i int) T

+ func (ss *SafeSlice[T]) Len() int

+ func (ss *SafeSlice[T]) Push(v ...T)

Mar 17, 2024

Changes in this version

+ var ErrRateLimited = errors.New("rate limited")

+ func GetGlobalCancel(ctx context.Context) context.CancelCauseFunc

+ func GlobalCancel(ctx context.Context) context.Context

+ type Cache struct

+ func NewCache[T any]() *Cache[T]

+ func (c *Cache[T]) Delete(key string)

+ func (c *Cache[T]) Get(key string) *T

+ func (c *Cache[T]) Set(key string, value *T)

+ type CodeGenerator struct

+ func NewCodeGenerator(ttl int, len int, numbers, letters bool) *CodeGenerator

+ func (cg *CodeGenerator) Generate(input string) string

+ func (cg *CodeGenerator) GenerateForTime(t time.Time, input string) string

+ func (cg *CodeGenerator) Validate(input, code string) bool

+ func (cg *CodeGenerator) ValidateForTime(t time.Time, input string, code string) bool

+ type CycleTask struct

+ func NewCycleTask(task func()) *CycleTask

+ func (r *CycleTask) Once()

+ func (r *CycleTask) Run(d time.Duration)

+ func (r *CycleTask) Stop()

+ type ErrorsMap map[string]error

+ func NewErrorsMap() ErrorsMap

+ func (e ErrorsMap) Error() string

+ func (e ErrorsMap) IsError() error

+ type Fifo struct

+ func NewFifo[T any]() *Fifo[T]

+ func (f *Fifo[T]) Len() int

+ func (f *Fifo[T]) Pop() *T

+ func (f *Fifo[T]) Push(items ...T)

+ type Logger interface

+ Logf func(format string, args ...interface{})

+ func BaseLogger() Logger

+ type Randomizer struct

+ func NewRandomizer() *Randomizer

+ func (r *Randomizer) PseudoString(seed int64, count int, alphabet, numbers, symbols bool) string

+ func (r *Randomizer) String(count int, alphabet, numbers, symbols bool) string

+ type RateLimiter struct

+ func NewRateLimiter(seconds int64) *RateLimiter

+ func (rl *RateLimiter) Check(key string) (err error)

+ func (rl *RateLimiter) Deinit()

+ func (rl *RateLimiter) Set(key string)

+ type RoutineLimiter struct

+ func NewRoutineLimiter(max int) *RoutineLimiter

+ func (r *RoutineLimiter) Run(task func())

+ type SMTP struct

+ func NewConfiguredSMTP(host, port, name, email, login, password string) *SMTP

+ func NewSMTP(config SMTPConfig) *SMTP

+ func (s *SMTP) SendHTMLEmail(name, email, subject string, message []byte) error

+ func (s *SMTP) SendTextEmail(name, email, subject, message string) error

+ type SMTPConfig struct

+ Email string

+ Host string

+ Login string

+ Name string

+ Password string

+ Port string

+ type Scheduler struct

+ func NewScheduler[I any, O any](parallel int, task func(I) O) *Scheduler[I, O]

+ func (s *Scheduler[I, O]) Out() <-chan O

+ func (s *Scheduler[I, O]) Push(items ...I)

+ func (s *Scheduler[I, O]) Wait()

+ type ShutdownFunc func(context.Context)

+ type ShutdownStack struct

+ func NewShutdownStack(logger Logger) *ShutdownStack

+ func (st *ShutdownStack) Add(fn ...ShutdownFunc)

+ func (st *ShutdownStack) Wait(ctx context.Context, timeout time.Duration)