loki_server

Documentation

Index

• type BasicAuth
• type ClientOpts
• type LogServer
• type LokiClient
  • func NewLokiClient(httpAddr string, opts ClientOpts) (LokiClient, error)
• type LokiClientOptions
• type StreamSelector

Types

type BasicAuth

type BasicAuth struct {
	Username string
	Password string
}

type ClientOpts

type ClientOpts struct {
	BasicAuth *BasicAuth
}

type LogServer

type LogServer *fiber.App

type LokiClient

type LokiClient interface {
	Ping(ctx context.Context) error
	Tail(streamSelectors []StreamSelector, filter *string, startTime, endTime *time.Time, limitLength *int, connection *fWebsocket.Conn) error
	Close()
}

func NewLokiClient

func NewLokiClient(httpAddr string, opts ClientOpts) (LokiClient, error)

type LokiClientOptions

type LokiClientOptions interface {
	GetLokiServerUrlAndOptions() (string, ClientOpts)
	GetLogServerPort() uint64
}

type StreamSelector

type StreamSelector struct {
	Key       string
	Value     string
	Operation string
}