db

Apr 17, 2024

Changes in this version

type EventLogMessage

+ TimeUnixNano int64

Jun 14, 2023

Changes in this version

+ const B

+ const KB

+ const MB

+ type ByteUnit int64

Mar 22, 2022

Changes in this version

+ func CheckLevel(flag, level string) bool

+ func CreateDBManager(conf conf.DBConf) error

+ func GetLevelFlag(level string) []byte

+ func GetServiceAliasID(ServiceID string) string

+ func GetTimeUnix(timeStr string) int64

+ func MvLogFile(newName string, filePath string) error

+ type ClusterMessage struct

+ Data []byte

+ Mode ClusterMessageType

+ type ClusterMessageType string

+ const EventMessage

+ const MonitorMessage

+ const ServiceMonitorMessage

+ const ServiceNewMonitorMessage

+ type EventFilePlugin struct

+ HomePath string

+ func (m *EventFilePlugin) Close() error

+ func (m *EventFilePlugin) GetMessages(eventID, level string, length int) (interface{}, error)

+ func (m *EventFilePlugin) SaveMessage(events []*EventLogMessage) error

+ type EventLogMessage struct

+ Content []byte

+ EventID string

+ Level string

+ Message string

+ MonitorData []byte

+ Status string

+ Step string

+ Time string

+ type Manager interface

+ Close func() error

+ GetMessages func(id, level string, length int) (interface{}, error)

+ SaveMessage func([]*EventLogMessage) error

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

+ type MessageData struct

+ Message string

+ Time string

+ Unixtime int64

+ type MessageDataList []MessageData

+ func (a MessageDataList) Len() int

+ func (a MessageDataList) Less(i, j int) bool

+ func (a MessageDataList) Swap(i, j int)

+ type MonitorData struct

+ InstanceID string

+ LogSizePeerM int64

+ ServiceSize int