eventbus

Documentation

Index

• Constants
• type BaseEvent
• type BaseEventImpl
• type ConsumeFunc
• type EventBus
  • func GetDefaultEventBus() EventBus
  • func NewEventBus(bufferSize int) EventBus
• type RawCGroupEvent
• type SyscallEvent
• type SyscallLog

Constants

const (
	ErrTypeNoSubscriber = "NoSubscriber"
	ErrTypeBufferFull   = "BufferFull"

	MetricNameEventBusErr = "event_bus_err"
)

Types

type BaseEvent

type BaseEvent interface {
	// contains filtered or unexported methods
}

type BaseEventImpl

type BaseEventImpl struct {
	Time time.Time
}

type ConsumeFunc

type ConsumeFunc func(interface{}) error

type EventBus

type EventBus interface {
	Publish(topic string, event interface{}) error
	Subscribe(topic string, subscriber string, bufferSize int, handler ConsumeFunc) error
	EnableStatistic()
	SetEmitter(emitter metrics.MetricEmitter)
}

EventBus TODO: support event type check, unsubscribe, stop, statistics

func GetDefaultEventBus

func GetDefaultEventBus() EventBus

func NewEventBus

func NewEventBus(bufferSize int) EventBus

type RawCGroupEvent

type RawCGroupEvent struct {
	BaseEventImpl
	Cost       time.Duration
	CGroupPath string
	CGroupFile string
	Data       string
	OldData    string
}

type SyscallEvent

type SyscallEvent struct {
	BaseEventImpl
	Cost        time.Duration
	Syscall     string
	PodUID      string
	ContainerID string
	Logs        []SyscallLog
}

type SyscallLog

type SyscallLog struct {
	Time     time.Time
	KeyValue map[string]string
}