eventbus

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

type BaseEventImpl struct {
	Time time.Time
}

type ConsumeFunc func(interface{}) error

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

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

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

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