loki

Documentation

Index

• Constants
• type Direction
• type LokiAPI
  • func (api *LokiAPI) DataQuery(ctx context.Context, query lokiQuery, responseOpts ResponseOpts) (*backend.DataResponse, error)
  • func (api *LokiAPI) RawQuery(ctx context.Context, resourcePath string) (RawLokiResponse, error)
• type QueryJSONModel
• type QueryType
• type RawLokiResponse
• type ResponseOpts
• type Service
  • func ProvideService(httpClientProvider *httpclient.Provider, features featuremgmt.FeatureToggles, ...) *Service
  • func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
  • func (s *Service) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (s *Service) PublishStream(_ context.Context, _ *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (s *Service) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (s *Service) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (s *Service) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
• type SupportingQueryType

Constants

const (
	QueryTypeRange   = dataquery.LokiQueryTypeRange
	QueryTypeInstant = dataquery.LokiQueryTypeInstant
)

const (
	SupportingQueryLogsVolume                         = dataquery.SupportingQueryTypeLogsVolume
	SupportingQueryLogsSample                         = dataquery.SupportingQueryTypeLogsSample
	SupportingQueryDataSample                         = dataquery.SupportingQueryTypeDataSample
	SupportingQueryInfiniteScroll                     = dataquery.SupportingQueryTypeInfiniteScroll
	SupportingQueryNone           SupportingQueryType = "none"
)

const (
	DirectionBackward = dataquery.LokiQueryDirectionBackward
	DirectionForward  = dataquery.LokiQueryDirectionForward
)

Types

type Direction

type Direction = dataquery.LokiQueryDirection

type LokiAPI

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

func (*LokiAPI) DataQuery

func (api *LokiAPI) DataQuery(ctx context.Context, query lokiQuery, responseOpts ResponseOpts) (*backend.DataResponse, error)

func (*LokiAPI) RawQuery

func (api *LokiAPI) RawQuery(ctx context.Context, resourcePath string) (RawLokiResponse, error)

type QueryJSONModel

type QueryJSONModel struct {
	dataquery.LokiDataQuery
	Direction           *string `json:"direction,omitempty"`
	SupportingQueryType *string `json:"supportingQueryType"`
}

type QueryType

type QueryType = dataquery.LokiQueryType

type RawLokiResponse

type RawLokiResponse struct {
	Body     []byte
	Status   int
	Encoding string
}

type ResponseOpts

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

type Service

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

func ProvideService

func ProvideService(httpClientProvider *httpclient.Provider, features featuremgmt.FeatureToggles, tracer tracing.Tracer) *Service

func (*Service) CallResource

func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error

func (*Service) CheckHealth

func (s *Service) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult,
	error)

func (*Service) PublishStream

func (s *Service) PublishStream(_ context.Context, _ *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*Service) QueryData

func (s *Service) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*Service) RunStream

func (s *Service) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error

Single instance for each channel (results are shared with all listeners)

func (*Service) SubscribeStream

func (s *Service) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

type SupportingQueryType

type SupportingQueryType = dataquery.SupportingQueryType