db

Documentation

Index

• 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
• type ClusterMessageType
• type EventFilePlugin
  • 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
• type Manager
  • func NewManager(conf conf.DBConf, log *logrus.Entry) (Manager, error)
• type MessageData
• type MessageDataList
  • func (a MessageDataList) Len() int
  • func (a MessageDataList) Less(i, j int) bool
  • func (a MessageDataList) Swap(i, j int)
• type MonitorData

Functions

func CheckLevel

func CheckLevel(flag, level string) bool

CheckLevel

func CreateDBManager

func CreateDBManager(conf conf.DBConf) error

CreateDBManager

func GetLevelFlag

func GetLevelFlag(level string) []byte

GetLevelFlag

func GetServiceAliasID

func GetServiceAliasID(ServiceID string) string

GetServiceAliasID python: new_word = str(ord(string[10])) + string + str(ord(string[3])) + 'log' + str(ord(string[2]) / 7) new_id = hashlib.sha224(new_word).hexdigest()[0:16]

func GetTimeUnix

func GetTimeUnix(timeStr string) int64

GetTimeUnix

func MvLogFile

func MvLogFile(newName string, filePath string) error

MvLogFile - change file name, compress

Types

type ClusterMessage

type ClusterMessage struct {
	Data []byte
	Mode ClusterMessageType
}

type ClusterMessageType

type ClusterMessageType string

const (
	//EventMessage - operation log sharing
	EventMessage ClusterMessageType = "event_log"
	//ServiceMonitorMessage - business monitoring data message
	ServiceMonitorMessage ClusterMessageType = "monitor_message"
	//ServiceNewMonitorMessage - new business monitoring data message
	ServiceNewMonitorMessage ClusterMessageType = "new_monitor_message"
	//MonitorMessage - node monitoring data
	MonitorMessage ClusterMessageType = "monitor"
)

type EventFilePlugin

type EventFilePlugin struct {
	HomePath string
}

EventFilePlugin

func (*EventFilePlugin) Close

func (m *EventFilePlugin) Close() error

Close

func (*EventFilePlugin) GetMessages

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

GetMessages

func (*EventFilePlugin) SaveMessage

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

SaveMessage

type EventLogMessage

type EventLogMessage struct {
	EventID string `json:"event_id"`
	Step    string `json:"step"`
	Status  string `json:"status"`
	Message string `json:"message"`
	Level   string `json:"level"`
	Time    string `json:"time"`
	Content []byte `json:"-"`
	//monitor message usage
	MonitorData []byte `json:"monitorData,omitempty"`
}

EventLogMessage - event log entity

type Manager

type Manager interface {
	SaveMessage([]*EventLogMessage) error
	Close() error
	GetMessages(id, level string, length int) (interface{}, error)
}

func NewManager

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

NewManager - create a storage manager

type MessageData

type MessageData struct {
	Message  string `json:"message"`
	Time     string `json:"time"`
	Unixtime int64  `json:"utime"`
}

MessageData message data - obtain the operation log of the specified operation

type MessageDataList

type MessageDataList []MessageData

MessageDataList

func (MessageDataList) Len

func (a MessageDataList) Len() int

func (MessageDataList) Less

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

func (MessageDataList) Swap

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

type MonitorData

type MonitorData struct {
	InstanceID   string
	ServiceSize  int
	LogSizePeerM int64
}