loki

Documentation

Index

• type DroppedEntry
  • func (d *DroppedEntry) MarshalJSON() ([]byte, error)
  • func (d *DroppedEntry) UnmarshalJSON(data []byte) error
• type Entry
  • func (e *Entry) MarshalJSON() ([]byte, error)
  • func (e *Entry) UnmarshalJSON(data []byte) error
• type Loki
  • func NewLoki(url string) (*Loki, error)
  • func (l *Loki) Tail(ctx context.Context, query string, delayFor time.Duration, limit int, ...) error
• type LokiInput
  • func New(url string, query string, line log.LineReader, memory *memory.Memory) (*LokiInput, error)
  • func (l *LokiInput) Serve(ctx context.Context) error
• type Stream
• type Tail

Types

type DroppedEntry

type DroppedEntry struct {
	Labels    map[string]string `json:"labels"`
	Timestamp time.Time         `json:"timestamp"`
}

func (*DroppedEntry) MarshalJSON

func (d *DroppedEntry) MarshalJSON() ([]byte, error)

func (*DroppedEntry) UnmarshalJSON

func (d *DroppedEntry) UnmarshalJSON(data []byte) error

type Entry

type Entry struct {
	Timestamp time.Time
	Line      string
}

func (*Entry) MarshalJSON

func (e *Entry) MarshalJSON() ([]byte, error)

func (*Entry) UnmarshalJSON

func (e *Entry) UnmarshalJSON(data []byte) error

type Loki

type Loki struct {
	Url string // websocket url
	// contains filtered or unexported fields
}

func NewLoki

func NewLoki(url string) (*Loki, error)

func (*Loki) Tail

func (l *Loki) Tail(ctx context.Context, query string, delayFor time.Duration, limit int, start time.Time, handler func(*Tail) error) error

type LokiInput

type LokiInput struct {
	Url   string
	Query string
	// contains filtered or unexported fields
}

func New

func New(url string, query string, line log.LineReader, memory *memory.Memory) (*LokiInput, error)

func (*LokiInput) Serve

func (l *LokiInput) Serve(ctx context.Context) error

type Stream

type Stream struct {
	Stream  map[string]string `json:"stream"`
	Entries []Entry           `json:"values"`
}

type Tail

type Tail struct {
	Streams        []Stream       `json:"streams"`
	DroppedEntries []DroppedEntry `json:"dropped_entries"`
}