eventProcessor

Documentation

Index

• Variables
• type CentralEventProcessor
  • func NewCentralEventProcessor(logger *zap.SugaredLogger, ...) (*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(logger *zap.SugaredLogger,
	workflowEventProcessor *in.WorkflowEventProcessorImpl,
	ciPipelineEventProcessor *in.CIPipelineEventProcessorImpl,
	cdPipelineEventProcessor *in.CDPipelineEventProcessorImpl,
	deployedApplicationEventProcessorImpl *in.DeployedApplicationEventProcessorImpl,
	appStoreAppsEventProcessorImpl *in.AppStoreAppsEventProcessorImpl) (*CentralEventProcessor, error)

func (*CentralEventProcessor) SubscribeAll

func (impl *CentralEventProcessor) SubscribeAll() error