Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + func BleveDeleteLogs(idx bleve.Index, str string) (int64, error) + func BleveDuplicateIndex(from bleve.Index, to bleve.Index) error + func BleveListLogs(idx bleve.Index, str string, page int32, size int32) (chan log.ListLogResponse, error) + func BlevePutLog(idx bleve.Index, line map[string]string) error + func FromLogMsgToMap(doc *log.LogMessage, m map[string]interface{}) + func FromLogMsgToStringMap(doc *log.LogMessage, m map[string]string) + func UnmarshallLogMsgFromDoc(doc *document.Document, msg *log.LogMessage) + type IndexableLog struct + func MarshallLogMsg(line map[string]string) (*IndexableLog, error) + type MessageRepository interface + AggregatedLogs func(string, string, int32) (chan log.TimeRangeResponse, error) + DeleteLogs func(string) (int64, error) + ListLogs func(string, int32, int32) (chan log.ListLogResponse, error) + PutLog func(map[string]string) error + Resync func() error + type SyslogServer struct + Index bleve.Index + func NewSyslogServer(bleveIndexPath string, mappingName string, deleteOnClose ...bool) (*SyslogServer, error) + func (s *SyslogServer) AggregatedLogs(msgId string, timeRangeType string, refTime int32) (chan log.TimeRangeResponse, error) + func (s *SyslogServer) Close() + func (s *SyslogServer) DeleteLogs(query string) (int64, error) + func (s *SyslogServer) ListLogs(str string, page, size int32) (chan log.ListLogResponse, error) + func (s *SyslogServer) PutLog(line map[string]string) error + func (s *SyslogServer) Resync() error Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020
Go to main page