search

Documentation

Index

• func NewLogReader(reader io.Reader, gzipped bool, filter Filter) (*logReader, error)
• func NewSearchLog(entriesHandler func(*entry.Entry) (continueRead bool, err error), ...) *searchLog
• type Filter
  • func NewFilter(req SearchRequest) (Filter, error)
• type SearchRequest
• type SearchResponse
• type SearchWithCursorRequest
• type SearchWithCursorResponse
• type SyncSearchLog
  • func NewSyncSearchService(req SearchRequest, baseDir string) (*SyncSearchLog, error)
  • func (s *SyncSearchLog) Next() (*entry.Entry, bool, error)

Functions

func NewLogReader

func NewLogReader(reader io.Reader, gzipped bool, filter Filter) (*logReader, error)

func NewSearchLog

func NewSearchLog(entriesHandler func(*entry.Entry) (continueRead bool, err error), baseDir string) *searchLog

Types

type Filter

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

func NewFilter

func NewFilter(req SearchRequest) (Filter, error)

type SearchRequest

type SearchRequest struct {
	ModuleName string `valid:"required~Required"`
	From       time.Time
	To         time.Time
	Host       []string
	Event      []string
	Level      []string
	Limit      int `valid:"required~Required,range(1|10000)"`
	Offset     int
}

type SearchResponse

type SearchResponse struct {
	ModuleName string `json:",omitempty"`
	Host       string `json:",omitempty"`
	Event      string `json:",omitempty"`
	Level      string `json:",omitempty"`
	Time       string `json:",omitempty"`
	Request    string `json:",omitempty"`
	Response   string `json:",omitempty"`
	ErrorText  string `json:",omitempty"`
}

type SearchWithCursorRequest

type SearchWithCursorRequest struct {
	Request   SearchRequest
	CursorId  string
	BatchSize int `valid:"required~Required,range(1|10000)"`
}

type SearchWithCursorResponse

type SearchWithCursorResponse struct {
	CursorId string
	Items    []SearchResponse
	HasMore  bool
}

type SyncSearchLog

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

func NewSyncSearchService

func NewSyncSearchService(req SearchRequest, baseDir string) (*SyncSearchLog, error)

func (*SyncSearchLog) Next

func (s *SyncSearchLog) Next() (*entry.Entry, bool, error)

return next matched log entry, never return io.EOF, if data source exhausted return false in second param idempotent return the same error while reading or opening file