container

Documentation

Index

• type DIContiner
  • func NewDiContainer(ring *cluster.Ring) *DIContiner
  • func (d *DIContiner) GetDelayQueue() cluster.DelayQueue
  • func (d *DIContiner) GetFlowDao() cluster.FlowDao
  • func (d *DIContiner) GetQueue() cluster.Queue
  • func (d *DIContiner) GetStateHandler() *cluster.StateHandlerContainer
  • func (d *DIContiner) GetTaskDao() persistence.TaskDao
  • func (d *DIContiner) GetTaskRetryQueue() cluster.DelayQueue
  • func (d *DIContiner) GetTaskTimeoutQueue() cluster.DelayQueue
  • func (d *DIContiner) GetWorkflowDao() persistence.WorkflowDao
  • func (d *DIContiner) Init(conf config.Config)

Types

type DIContiner

type DIContiner struct {
	FlowContextEncDec            util.EncoderDecoder[model.FlowContext]
	ActionExecutionRequestEncDec util.EncoderDecoder[model.ActionExecutionRequest]
	TaskEncDec                   util.EncoderDecoder[model.TaskDef]
	// contains filtered or unexported fields
}

func NewDiContainer

func NewDiContainer(ring *cluster.Ring) *DIContiner

func (*DIContiner) GetDelayQueue

func (d *DIContiner) GetDelayQueue() cluster.DelayQueue

func (*DIContiner) GetFlowDao

func (d *DIContiner) GetFlowDao() cluster.FlowDao

func (*DIContiner) GetQueue

func (d *DIContiner) GetQueue() cluster.Queue

func (*DIContiner) GetStateHandler

func (d *DIContiner) GetStateHandler() *cluster.StateHandlerContainer

func (*DIContiner) GetTaskDao

func (d *DIContiner) GetTaskDao() persistence.TaskDao

func (*DIContiner) GetTaskRetryQueue

func (d *DIContiner) GetTaskRetryQueue() cluster.DelayQueue

func (*DIContiner) GetTaskTimeoutQueue

func (d *DIContiner) GetTaskTimeoutQueue() cluster.DelayQueue

func (*DIContiner) GetWorkflowDao

func (d *DIContiner) GetWorkflowDao() persistence.WorkflowDao

func (*DIContiner) Init

func (d *DIContiner) Init(conf config.Config)