utils

Documentation

Index

• func LoadPostgres(database config.Database, node core.Node) postgres.DB
• func RollbackAndLogFailure(tx *sqlx.Tx, txErr error, fieldName string)
• type Callback
• type CallbackWithArg
• type StandardTimer
  • func (timer StandardTimer) ElapsedTime() time.Duration
  • func (timer *StandardTimer) Start()
  • func (timer StandardTimer) WaitFor(sleepTime time.Duration)
• type Throttler
  • func NewThrottler(timer Timer) Throttler
  • func (throttler Throttler) Throttle(minTime time.Duration, f Callback) error
• type ThrottlerFunc
• type ThrottlerFuncWithArg
• type ThrottlerWithArgs
  • func NewThrottlerWithArgs(timer Timer) ThrottlerWithArgs
  • func (throttler ThrottlerWithArgs) Throttle(minTime time.Duration, f CallbackWithArg, header core.Header) error
• type Timer

Functions

func LoadPostgres

func LoadPostgres(database config.Database, node core.Node) postgres.DB

func RollbackAndLogFailure

func RollbackAndLogFailure(tx *sqlx.Tx, txErr error, fieldName string)

Types

type Callback

type Callback func() error

type CallbackWithArg

type CallbackWithArg func(header core.Header) error

type StandardTimer

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

func (StandardTimer) ElapsedTime

func (timer StandardTimer) ElapsedTime() time.Duration

func (*StandardTimer) Start

func (timer *StandardTimer) Start()

func (StandardTimer) WaitFor

func (timer StandardTimer) WaitFor(sleepTime time.Duration)

type Throttler

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

func NewThrottler

func NewThrottler(timer Timer) Throttler

func (Throttler) Throttle

func (throttler Throttler) Throttle(minTime time.Duration, f Callback) error

type ThrottlerFunc

type ThrottlerFunc func(time.Duration, Callback) error

type ThrottlerFuncWithArg

type ThrottlerFuncWithArg func(time.Duration, CallbackWithArg, core.Header) error

type ThrottlerWithArgs

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

func NewThrottlerWithArgs

func NewThrottlerWithArgs(timer Timer) ThrottlerWithArgs

func (ThrottlerWithArgs) Throttle

func (throttler ThrottlerWithArgs) Throttle(minTime time.Duration, f CallbackWithArg, header core.Header) error

type Timer

type Timer interface {
	WaitFor(sleep time.Duration)
	ElapsedTime() time.Duration
	Start()
}