engine

Documentation

Index

• type BaseEngineConfig
• type Callback
• type ConstantEngine
  • func (b ConstantEngine) Close()
  • func (b ConstantEngine) Run(callback Callback)
• type Engine
  • func NewEngine(baseEngineConf BaseEngineConfig) (e Engine)

Types

type BaseEngineConfig

type BaseEngineConfig struct {
	// Type engine type.
	Type string `mapstructure:"type"`
	// Rate engine call Callback rate.
	Rate int64 `mapstructure:"rate"`
	// Instant the number of a batch
	Instant int64 `mapstructure:"instant"`
	// Duration engine run duration.
	Duration time.Duration `mapstructure:"duration"`
	// Wg Semaphore of localWorker
	Wg *sync.WaitGroup
}

BaseEngineConfig base engine config.

type Callback

type Callback func()

Callback will be call in engine run.

type ConstantEngine

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

ConstantEngine is control rate by constant.

func (ConstantEngine) Close

func (b ConstantEngine) Close()

Close close the engine.

func (ConstantEngine) Run

func (b ConstantEngine) Run(callback Callback)

Run start the engine.

type Engine

type Engine interface {
	// Run start the engine.
	Run(callback Callback)
	// Close close the engine.
	Close()
}

Engine is used to control the rate for send tx.

func NewEngine

func NewEngine(baseEngineConf BaseEngineConfig) (e Engine)

NewEngine use given baseEngineConf create Engine.