store

Documentation

Index

• type EventBarrel
• type Manager
  • func NewManager(conf conf.EventStoreConf, log *logrus.Entry) (Manager, error)
• type MessageStore
  • func NewStore(storeType string, manager *storeManager) MessageStore

Types

type EventBarrel

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

EventBarrel 事件桶 不能在此结构上起协程

type Manager

type Manager interface {
	ReceiveMessageChan() chan []byte
	SubMessageChan() chan [][]byte
	PubMessageChan() chan [][]byte
	DockerLogMessageChan() chan []byte
	MonitorMessageChan() chan [][]byte
	WebSocketMessageChan(mode, eventID, subID string) chan *db.EventLogMessage
	RealseWebSocketMessageChan(mode, EventID, subID string)
	Run() error
	Stop()
	Monitor() []db.MonitorData
	Scrape(ch chan<- prometheus.Metric, namespace, exporter, from string) error
	Error() chan error
}

Manager 存储管理器

func NewManager

func NewManager(conf conf.EventStoreConf, log *logrus.Entry) (Manager, error)

NewManager 存储管理器

type MessageStore

type MessageStore interface {
	InsertMessage(*db.EventLogMessage)
	InsertGarbageMessage(...*db.EventLogMessage)
	SubChan(eventID, subID string) chan *db.EventLogMessage
	RealseSubChan(eventID, subID string)
	GetMonitorData() *db.MonitorData
	Run()
	Gc()

	Scrape(ch chan<- prometheus.Metric, namespace, exporter, from string) error
	// contains filtered or unexported methods
}

MessageStore store

func NewStore

func NewStore(storeType string, manager *storeManager) MessageStore

NewStore 创建