eventProcessor

Documentation

Index

• Variables
• type CentralEventProcessor
  • func NewCentralEventProcessor(workflowEventProcessor *in.WorkflowEventProcessorImpl, ...) (*CentralEventProcessor, error)
  • func (impl *CentralEventProcessor) SubscribeAll() error

Variables

var EventProcessorWireSet = wire.NewSet(
	NewCentralEventProcessor,
	in.EventProcessorInWireSet,
	out.EventProcessorOutWireSet,
)

Types

type CentralEventProcessor

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

func NewCentralEventProcessor

func NewCentralEventProcessor(workflowEventProcessor *in.WorkflowEventProcessorImpl,
	logger *zap.SugaredLogger) (*CentralEventProcessor, error)

func (*CentralEventProcessor) SubscribeAll

func (impl *CentralEventProcessor) SubscribeAll() error