manager

Documentation

Index

• type Manager
  • func NewManager(config *config.Config, commonDims *metrics.CommonDim) (*Manager, error)
  • func (s *Manager) Name() string
  • func (m *Manager) OutChannel() chan *models.Event
  • func (s *Manager) Run(ctx context.Context)

Types

type Manager

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

func NewManager

func NewManager(config *config.Config, commonDims *metrics.CommonDim) (*Manager, error)

func (*Manager) Name

func (s *Manager) Name() string

func (*Manager) OutChannel

func (m *Manager) OutChannel() chan *models.Event

OutChannel returns processorChan channel which will publish events

func (*Manager) Run

func (s *Manager) Run(ctx context.Context)