event

Documentation

Index

• type Event
  • func NewEvent(config *config.Config, resourceEventQueue *queue.OverwriteQueue, ...) (*Event, error)
  • func (e *Event) Close() error
  • func (e *Event) Start()
• type Eventor
  • func NewAlarmEventor(config *config.Config, recv *receiver.Receiver, manager *dropletqueue.Manager, ...) (*Eventor, error)
  • func NewPerfEventor(config *config.Config, recv *receiver.Receiver, manager *dropletqueue.Manager, ...) (*Eventor, error)
  • func NewResouceEventor(eventQueue *queue.OverwriteQueue, eventType common.EventType, ...) (*Eventor, error)
  • func (e *Eventor) Close()
  • func (e *Eventor) Start()

Types

type Event

type Event struct {
	Config          *config.Config
	ResourceEventor *Eventor
	PerfEventor     *Eventor
	AlarmEventor    *Eventor
}

func NewEvent

func NewEvent(config *config.Config, resourceEventQueue *queue.OverwriteQueue, recv *receiver.Receiver, platformDataManager *grpc.PlatformDataManager) (*Event, error)

func (*Event) Close

func (e *Event) Close() error

func (*Event) Start

func (e *Event) Start()

type Eventor

type Eventor struct {
	Config        *config.Config
	Decoders      []*decoder.Decoder
	PlatformDatas []*grpc.PlatformInfoTable
}

func NewAlarmEventor

func NewAlarmEventor(config *config.Config, recv *receiver.Receiver, manager *dropletqueue.Manager, platformTable *grpc.PlatformInfoTable) (*Eventor, error)

func NewPerfEventor

func NewPerfEventor(config *config.Config, recv *receiver.Receiver, manager *dropletqueue.Manager, platformDataManager *grpc.PlatformDataManager) (*Eventor, error)

func NewResouceEventor

func NewResouceEventor(eventQueue *queue.OverwriteQueue, eventType common.EventType, config *config.Config) (*Eventor, error)

func (*Eventor) Close

func (e *Eventor) Close()

func (*Eventor) Start

func (e *Eventor) Start()