microkernel

Documentation

Index

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

Constants

const (
	Waiting = iota
	Running
)

Variables

var WrongStateError = errors.New("can not take the operation in the current state")

Types

type Agent

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

func NewAgent

func NewAgent(sizeEvtBuf int) *Agent

func (*Agent) Destory

func (agt *Agent) Destory() error

func (*Agent) EventProcessGroutine

func (agt *Agent) EventProcessGroutine()

func (*Agent) OnEvent

func (agt *Agent) OnEvent(evt Event)

func (*Agent) RegisterCollector

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

func (*Agent) Start

func (agt *Agent) Start() error

func (*Agent) Stop

func (agt *Agent) Stop() error

type Collector

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

type CollectorsError

type CollectorsError struct {
	CollectorErrors []error
}

func (CollectorsError) Error

func (ce CollectorsError) Error() string

type Event

type Event struct {
	Source  string
	Content string
}

type EventReceiver

type EventReceiver interface {
	OnEvent(evt Event)
}