b01

Documentation

Index

• Constants
• Variables
• type Agent
  • func NewAgent(sizeEvtBuf int) *Agent
  • func (a *Agent) Destroy() error
  • func (a *Agent) EventProcessGroutine()
  • func (a *Agent) OnEvent(evt Event)
  • func (a *Agent) RegisterCollector(name string, collector Collector) error
  • func (a *Agent) Start() error
  • func (a *Agent) Stop() error
• type CollectionError
  • func (ce CollectionError) Error() string
• type Collector
• type Event
• type EventReceiver

Constants

const (
	// Waiting state.
	Waiting = iota

	// Running state.
	Running
)

Variables

var ErrWrongState = errors.New("Can not take the operation in the current state")

ErrWrongState var.

Types

type Agent

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

Agent struct.

func NewAgent

func NewAgent(sizeEvtBuf int) *Agent

NewAgent func.

func (*Agent) Destroy

func (a *Agent) Destroy() error

Destroy func.

func (*Agent) EventProcessGroutine

func (a *Agent) EventProcessGroutine()

EventProcessGroutine func.

func (*Agent) OnEvent

func (a *Agent) OnEvent(evt Event)

OnEvent func.

func (*Agent) RegisterCollector

func (a *Agent) RegisterCollector(name string, collector Collector) error

RegisterCollector func.

func (*Agent) Start

func (a *Agent) Start() error

Start func.

func (*Agent) Stop

func (a *Agent) Stop() error

Stop func.

type CollectionError

type CollectionError struct {
	CollectionErrors []error
}

CollectionError struct.

func (CollectionError) Error

func (ce CollectionError) Error() string

type Collector

type Collector interface {
	Init(evtReceiver EventReceiver) error
	Start(agtCtx context.Context) error
	Stop() error
	Destroy() error
}

Collector interface.

type Event

type Event struct {
	Source  string
	Content string
}

Event struct.

type EventReceiver

type EventReceiver interface {
	OnEvent(evt Event)
}

EventReceiver interface.