log

Documentation

Index

• Constants
• type K8sAPIRequestor
  • func (k *K8sAPIRequestor) Query(ctx context.Context, r types.LogRequest) (<-chan types.Message, error)
• type LokiAPIRequestor
  • func (l *LokiAPIRequestor) Query(ctx context.Context, r types.LogRequest) (<-chan types.Message, error)
• type RangeQueryResponse
• type Requester
  • func NewK8sAPIRequestor(client kubernetes.Interface) Requester
  • func NewLokiAPIRequestor(url, user, token string) Requester

Constants

const (

	// LogBufferSize number of log messages that may be buffered
	LogBufferSize = 500 * 2
)

Types

type K8sAPIRequestor

type K8sAPIRequestor struct {
	// contains filtered or unexported fields
}

K8sAPIRequestor implements the Requestor interface for k8s

func (*K8sAPIRequestor) Query

func (k *K8sAPIRequestor) Query(ctx context.Context,
	r types.LogRequest) (<-chan types.Message, error)

type LokiAPIRequestor

type LokiAPIRequestor struct {
	// contains filtered or unexported fields
}

func (*LokiAPIRequestor) Query

func (l *LokiAPIRequestor) Query(ctx context.Context, r types.LogRequest) (<-chan types.Message, error)

type RangeQueryResponse

type RangeQueryResponse struct {
	Data struct {
		Result []struct {
			Stream struct {
				Cluster   string `json:"cluster,omitempty"`
				Container string `json:"container,omitempty"`
				Namespace string `json:"namespace,omitempty"`
				Pod       string `json:"pod,omitempty"`
				Job       string `json:"job,omitempty"`
			}
			Values [][]string `json:"values,omitempty"`
		}
		ResultType string `json:"resultType,omitempty"`
	}
	Status string `json:"status,omitempty"`
}

type Requester

type Requester interface {
	// Query submits a log request to the actual logging system.
	Query(ctx context.Context, req types.LogRequest) (<-chan types.Message, error)
}

Requester submits queries the logging system.

func NewK8sAPIRequestor

func NewK8sAPIRequestor(client kubernetes.Interface) Requester

func NewLokiAPIRequestor

func NewLokiAPIRequestor(url, user, token string) Requester