worker

Documentation

Index

• type DPWorker
  • func NewDPWorker(cliCfg config.ClientInfo, chanCap int32, logger commons.TedgeLogger) (*DPWorker, error)
• type DPWorkerPool
  • func NewDPWorkerPool(cliCfg config.ClientInfo, logger commons.TedgeLogger) (*DPWorkerPool, error)
  • func (wp *DPWorkerPool) PutData(data interface{}) error
  • func (wp *DPWorkerPool) Stop()
• type TMWorker
  • func NewTMWorker(cliCfg config.ClientInfo, chanCap int32, logger commons.TedgeLogger) (*TMWorker, error)
• type TMWorkerPool
  • func NewTMWorkerPool(cliCfg config.ClientInfo, logger commons.TedgeLogger) (*TMWorkerPool, error)
  • func (wp *TMWorkerPool) DeleteMsgId(id string)
  • func (wp *TMWorkerPool) LoadMsgChan(id string) (interface{}, bool)
  • func (wp *TMWorkerPool) PutData(data *proto.ThingModelMsg) error
  • func (wp *TMWorkerPool) PutDataWithMsgId(id string, data *proto.ThingModelMsg) (interface{}, error)
  • func (wp *TMWorkerPool) Stop()
  • func (wp *TMWorkerPool) StoreMsgId(id string, ch *common.MsgAckChan)

Types

type DPWorker

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

func NewDPWorker

func NewDPWorker(cliCfg config.ClientInfo, chanCap int32, logger commons.TedgeLogger) (*DPWorker, error)

////////////////////////////////////////////////////////////////////////////////////////////////////

type DPWorkerPool

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

func NewDPWorkerPool

func NewDPWorkerPool(cliCfg config.ClientInfo, logger commons.TedgeLogger) (*DPWorkerPool, error)

////////////////////////////////////////////////////////////////////////////////////////////////////

func (*DPWorkerPool) PutData

func (wp *DPWorkerPool) PutData(data interface{}) error

func (*DPWorkerPool) Stop

func (wp *DPWorkerPool) Stop()

type TMWorker

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

func NewTMWorker

func NewTMWorker(cliCfg config.ClientInfo, chanCap int32, logger commons.TedgeLogger) (*TMWorker, error)

////////////////////////////////////////////////////////////////////////////////////////////////////

type TMWorkerPool

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

func NewTMWorkerPool

func NewTMWorkerPool(cliCfg config.ClientInfo, logger commons.TedgeLogger) (*TMWorkerPool, error)

////////////////////////////////////////////////////////////////////////////////////////////////////

func (*TMWorkerPool) DeleteMsgId

func (wp *TMWorkerPool) DeleteMsgId(id string)

func (*TMWorkerPool) LoadMsgChan

func (wp *TMWorkerPool) LoadMsgChan(id string) (interface{}, bool)

func (*TMWorkerPool) PutData

func (wp *TMWorkerPool) PutData(data *proto.ThingModelMsg) error

func (*TMWorkerPool) PutDataWithMsgId

func (wp *TMWorkerPool) PutDataWithMsgId(id string, data *proto.ThingModelMsg) (interface{}, error)

func (*TMWorkerPool) Stop

func (wp *TMWorkerPool) Stop()

func (*TMWorkerPool) StoreMsgId

func (wp *TMWorkerPool) StoreMsgId(id string, ch *common.MsgAckChan)