loki

Documentation

Index

• func GetLogs(namespace, containerName, limit string, url string) ([]*pb.LogEntry, error)
• func GetStreamedEntries(namespace, containerName string, srv *connect.ServerStream[pb.PodLogResponse], ...) error
• type LokiConfig
• type QueryData
• type QueryResponse
• type QueryResult
• type QueryStatus
• type TailData

Functions

func GetLogs

func GetLogs(namespace, containerName, limit string, url string) ([]*pb.LogEntry, error)

func GetStreamedEntries

func GetStreamedEntries(namespace, containerName string, srv *connect.ServerStream[pb.PodLogResponse], lokiHost string) error

Types

type LokiConfig

type LokiConfig struct {
	Host  string
	Limit string
}

type QueryData

type QueryData struct {
	ResultType string        `json:"resultType"`
	Result     []QueryResult `json:"result"`
}

type QueryResponse

type QueryResponse struct {
	Status QueryStatus `json:"status"`
	Data   QueryData   `json:"data"`
}

type QueryResult

type QueryResult struct {
	Stream map[string]string `json:"stream"`
	Values [][]string        `json:"values"`
}

type QueryStatus

type QueryStatus string

const (
	QueryStatusSuccess QueryStatus = "success"
)

type TailData

type TailData struct {
	Streams []QueryResult `json:"streams"`
}