timed_call

Documentation

Index

• func TimedDispatch(tc *TimedCallType)
• type TimedCallFunc
• type TimedCallType
  • func NewTimedCall(gcfg *data.BaseConfigType, monitor_prefix string, st int, db map[string]bool, ...) *TimedCallType
  • func (tc *TimedCallType) AddFunc(fx TimedCallFunc, dt interface{})
  • func (tc *TimedCallType) GetCurTick() int
  • func (tc *TimedCallType) SetTime(t int)

Functions

func TimedDispatch

func TimedDispatch(tc *TimedCallType)

Types

type TimedCallFunc

type TimedCallFunc func(cc *TimedCallType, data interface{}) error

type TimedCallType

type TimedCallType struct {

	// Debug flags like prevent send of tc for testing
	DbFlag map[string]bool

	Data []interface{} // Config per-function (or use a closure)
	// contains filtered or unexported fields
}

func NewTimedCall

func NewTimedCall(gcfg *data.BaseConfigType, monitor_prefix string, st int, db map[string]bool, f *os.File, conn *pgxpool.Pool, ctx context.Context, lgr *zap.Logger, xmd *metrics.MetricsData) *TimedCallType

func (*TimedCallType) AddFunc

func (tc *TimedCallType) AddFunc(fx TimedCallFunc, dt interface{})

func (*TimedCallType) GetCurTick

func (tc *TimedCallType) GetCurTick() int

GetCurTics returns the number of times that a timeout has saved the data.

func (*TimedCallType) SetTime

func (tc *TimedCallType) SetTime(t int)