loki

package

v0.3.0 Latest Latest Go to latest Published: Mar 27, 2022 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

type Entry struct {
	Timestamp time.Time
	Line      string
}

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

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

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

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

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

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

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

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

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

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