agent

Documentation

Index

• type Agent
  • func NewAgent(appCtx context.Context, logger log.Interface, config *conf.Config) (_ *Agent, err error)
  • func (b *Agent) GetClient() client.Interface
  • func (b *Agent) HandleCmd(cmdBytes []byte)
  • func (b *Agent) PostData(sid uint64, kind aranyagopb.MsgType, seq uint64, completed bool, data []byte) (uint64, error)
  • func (b *Agent) PostMsg(sid uint64, kind aranyagopb.MsgType, msg proto.Marshaler) error
  • func (b *Agent) SetClient(client client.Interface)

Types

type Agent

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

nolint:maligned

func NewAgent

func NewAgent(appCtx context.Context, logger log.Interface, config *conf.Config) (_ *Agent, err error)

func (*Agent) GetClient

func (b *Agent) GetClient() client.Interface

func (*Agent) HandleCmd

func (b *Agent) HandleCmd(cmdBytes []byte)

HandleCmd may be called from any goroutine, no calling sequence guaranteed

func (*Agent) PostData

func (b *Agent) PostData(sid uint64, kind aranyagopb.MsgType, seq uint64, completed bool, data []byte) (uint64, error)

func (*Agent) PostMsg

func (b *Agent) PostMsg(sid uint64, kind aranyagopb.MsgType, msg proto.Marshaler) error

func (*Agent) SetClient

func (b *Agent) SetClient(client client.Interface)