monitor

Documentation

Overview

Package monitor monitors streams.

Index

• type Manager
  • func NewManager(log *logrus.Logger, cfg *config.Config) *Manager
  • func (m *Manager) Dispatch(event *dispatcher.Event) error
  • func (m *Manager) DispatchTypes() []enum.EventTypeID
  • func (m *Manager) DispatcherType() enum.DispatcherTypeID
  • func (m *Manager) Stop()
• type Monitor
  • func NewMonitor(log *logrus.Logger, bout config.Bout, cfg *config.Config) Monitor

Types

type Manager

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

func NewManager

func NewManager(log *logrus.Logger, cfg *config.Config) *Manager

func (*Manager) Dispatch

func (m *Manager) Dispatch(event *dispatcher.Event) error

func (*Manager) DispatchTypes

func (m *Manager) DispatchTypes() []enum.EventTypeID

func (*Manager) DispatcherType

func (m *Manager) DispatcherType() enum.DispatcherTypeID

func (*Manager) Stop

func (m *Manager) Stop()

type Monitor

type Monitor interface {
	Start() error
	Stop()
	Done() <-chan struct{}
}

func NewMonitor

func NewMonitor(log *logrus.Logger, bout config.Bout, cfg *config.Config) Monitor