agent

Documentation

Index

• type Agent
  • func NewAgent(name string) *Agent
  • func (a *Agent) Start(stop <-chan struct{}) <-chan struct{}
• type Command
• type Message
• type StartLoadCommand

Types

type Agent

type Agent struct {
	Name string
	// contains filtered or unexported fields
}

func NewAgent

func NewAgent(name string) *Agent

func (*Agent) Start

func (a *Agent) Start(stop <-chan struct{}) <-chan struct{}

type Command

type Command struct {
	Command string                 `json:"command"`
	Params  map[string]interface{} `json:"params"`
}

type Message

type Message struct {
	Type      string      `json:"type"`
	Timestamp int64       `json:"timestamp"`
	Payload   interface{} `json:"payload"`
}

type StartLoadCommand

type StartLoadCommand struct {
	Type           string                 `mapstructure:"type"`
	ChainIDs       []string               `mapstructure:"chainIds"`
	EsAddress      string                 `mapstructure:"esAddress"`
	EntrySizeRange common.IntRange        `mapstructure:"entrySizeRange"`
	Params         map[string]interface{} `mapstructure:"params"`
}