misc

Documentation

Index

• func EnsureDirExist(dirPath string)
• func GetIP() string
• func OnPanic(fn func(msg string))
• func Retry(retryCount int) *retryer
• func Schedule(ctx context.Context, period time.Duration, fn func())
• func ScheduleWithInitialDelay(ctx context.Context, period, initialDelay time.Duration, fn func())
• func UUID() uuid.UUID
• func UUIDString() string
• type ErrorCounter
  • func NewErrorCounter(duration time.Duration, threshold int) *ErrorCounter
  • func (c *ErrorCounter) Err() error
  • func (c *ErrorCounter) IsOverThreshold() bool
  • func (c *ErrorCounter) Put(err error)
• type ExpirableOnce
  • func (o *ExpirableOnce) Do(f func())
  • func (o *ExpirableOnce) Expire()

Functions

func EnsureDirExist

func EnsureDirExist(dirPath string)

func GetIP

func GetIP() string

func OnPanic

func OnPanic(fn func(msg string))

func Retry

func Retry(retryCount int) *retryer

func Schedule

func Schedule(ctx context.Context, period time.Duration, fn func())

func ScheduleWithInitialDelay

func ScheduleWithInitialDelay(ctx context.Context, period, initialDelay time.Duration, fn func())

func UUID

func UUID() uuid.UUID

func UUIDString

func UUIDString() string

Types

type ErrorCounter

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

일정 시간 (duration) 동안 일정 건수 (threshold) 이상의 err 발생 여부 카운팅

func NewErrorCounter

func NewErrorCounter(duration time.Duration, threshold int) *ErrorCounter

func (*ErrorCounter) Err

func (c *ErrorCounter) Err() error

func (*ErrorCounter) IsOverThreshold

func (c *ErrorCounter) IsOverThreshold() bool

func (*ErrorCounter) Put

func (c *ErrorCounter) Put(err error)

type ExpirableOnce

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

func (*ExpirableOnce) Do

func (o *ExpirableOnce) Do(f func())

func (*ExpirableOnce) Expire

func (o *ExpirableOnce) Expire()