storage

Documentation

Index

• type Message
  • func NewMessageFromGelf(msg *gelf.Message) *Message
• type SearchQuery
• type SearchResult
• type Storage

Types

type Message

type Message struct {
	Id           string                 `json:"id,omitempty"`
	Version      string                 `json:"version"`
	Host         string                 `json:"host"`
	ShortMessage string                 `json:"short_message"`
	FullMessage  string                 `json:"full_message,omitempty"`
	Timestamp    time.Time              `json:"timestamp"`
	Level        int32                  `json:"level,omitempty"`
	Facility     string                 `json:"facility,omitempty"`
	File         string                 `json:"file,omitempty"`
	Line         int32                  `json:"line,omitempty"`
	Extra        map[string]interface{} `json:"extra,omitempty"`
}

Custom structure needed only to convert GELF unix-timestamp to time.Time

func NewMessageFromGelf

func NewMessageFromGelf(msg *gelf.Message) *Message

Returns custom message based on GELF message structure

type SearchQuery

type SearchQuery struct {
	Query  string    `json:"query"`
	Limit  int       `json:"limit,omitempty"`
	Offset int       `json:"offset,omitempty"`
	From   time.Time `json:"from,omitempty"`
	To     time.Time `json:"to,omitempty"`
}

type SearchResult

type SearchResult struct {
	Total    int64     `json:"total"`
	TookMs   int64     `json:"took_ms"`
	Limit    int       `json:"limit"`
	Offset   int       `json:"offset"`
	Messages []Message `json:"messages"`
}

type Storage

type Storage interface {
	GetMessage(string) (map[string]interface{}, error)
	GetMessages(*SearchQuery) (*SearchResult, error)
	HandleMessage(*gelf.Message)
	PeriodicFlush(chan bool)
	ValidateQuery(string) error
}