utils

Documentation

Index

• func CompareSlices(a, b []any) bool
• func CompareStringSlices(a, b []string) bool
• func Ptr[T any](v T) *T
• type DelayedExecutor
  • func NewDelayedExecutor(delay, maxInterval time.Duration) *DelayedExecutor
  • func (d *DelayedExecutor) Cancel(key string)
  • func (d *DelayedExecutor) Do(key string, execFunc func())
• type DelayedState
• type Throttle
  • func NewThrottle(limit time.Duration) *Throttle
  • func (t *Throttle) Do(f func())

Functions

func CompareSlices

func CompareSlices(a, b []any) bool

func CompareStringSlices

func CompareStringSlices(a, b []string) bool

func Ptr

func Ptr[T any](v T) *T

Types

type DelayedExecutor

type DelayedExecutor struct {
	States      sync.Map
	Delay       time.Duration
	MaxInterval time.Duration
}

func NewDelayedExecutor

func NewDelayedExecutor(delay, maxInterval time.Duration) *DelayedExecutor

func (*DelayedExecutor) Cancel

func (d *DelayedExecutor) Cancel(key string)

func (*DelayedExecutor) Do

func (d *DelayedExecutor) Do(key string, execFunc func())

type DelayedState

type DelayedState struct {
	StartTime time.Duration
	Timer     *time.Timer
	ExecFunc  func()
}

type Throttle

type Throttle struct {
	// contains filtered or unexported fields
}

func NewThrottle

func NewThrottle(limit time.Duration) *Throttle

func (*Throttle) Do

func (t *Throttle) Do(f func())