loki_client

Documentation

Index

• type BasicAuth
• type ClientOpts
• type LogResult
• type LokiClient
  • func NewLokiClient(httpAddr string, opts ClientOpts) (LokiClient, error)
• type PreWriteFunc
• type QueryArgs
• type StreamSelector

Types

type BasicAuth

type BasicAuth struct {
	Username string
	Password string
}

type ClientOpts

type ClientOpts struct {
	Logger    logging.Logger
	BasicAuth *BasicAuth
}

type LogResult

type LogResult struct {
	Data struct {
		Result []struct {
			Stream map[string]string `json:"stream,omitempty"`
			Values [][]string        `json:"values,omitempty"`
		} `json:"result,omitempty"`
	} `json:"data"`
}

type LokiClient

type LokiClient interface {
	Ping(ctx context.Context) error
	GetLogs(args QueryArgs) ([]byte, error)
	TailLogs(args QueryArgs, writer io.WriteCloser) error
	Close()
}

func NewLokiClient

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

type PreWriteFunc

type PreWriteFunc func(log *LogResult) ([]byte, error)

type QueryArgs

type QueryArgs struct {
	StreamSelectors []StreamSelector
	SearchKeyword   *string
	StartTime       *time.Time
	EndTime         *time.Time
	LimitLength     *int

	PreWriteFunc PreWriteFunc
}

type StreamSelector

type StreamSelector struct {
	Key       string
	Value     string
	Operation string
}