monitor

package
v0.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 8, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package monitor monitors streams.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL