loki

package
v0.0.0-...-fb7f86c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2023 License: AGPL-3.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const (
	QueryTypeRange   = dataquery.LokiQueryTypeRange
	QueryTypeInstant = dataquery.LokiQueryTypeInstant
)
View Source
const (
	SupportingQueryLogsVolume                     = dataquery.SupportingQueryTypeLogsVolume
	SupportingQueryLogsSample                     = dataquery.SupportingQueryTypeLogsSample
	SupportingQueryDataSample                     = dataquery.SupportingQueryTypeDataSample
	SupportingQueryNone       SupportingQueryType = "none"
)
View Source
const (
	DirectionBackward = dataquery.LokiQueryDirectionBackward
	DirectionForward  = dataquery.LokiQueryDirectionForward
)

Variables

This section is empty.

Functions

This section is empty.

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) (data.Frames, 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 (*Service) QueryData

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

type SupportingQueryType

type SupportingQueryType = dataquery.SupportingQueryType

Directories

Path Synopsis
kinds

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL