The highest tagged major version is v3.

v1

package

v2.4.3 Latest Latest Go to latest Published: Mar 21, 2022 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pao214/loki

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
- func (cfg *Config) RegisterFlags(f *flag.FlagSet)
type Frontend
- func New(cfg Config, limits Limits, log log.Logger, registerer prometheus.Registerer) (*Frontend, error)
type Limits

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	MaxOutstandingPerTenant int           `yaml:"max_outstanding_per_tenant"`
	QuerierForgetDelay      time.Duration `yaml:"querier_forget_delay"`
}

Config for a Frontend.

func (*Config) RegisterFlags ¶

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet.

type Frontend ¶

type Frontend struct {
	services.Service
	// contains filtered or unexported fields
}

Frontend queues HTTP requests, dispatches them to backends, and handles retries for requests which failed.

func New ¶

func New(cfg Config, limits Limits, log log.Logger, registerer prometheus.Registerer) (*Frontend, error)

New creates a new frontend. Frontend implements service, and must be started and stopped.

func (*Frontend) CheckReady ¶

func (f *Frontend) CheckReady(_ context.Context) error

CheckReady determines if the query frontend is ready. Function parameters/return chosen to match the same method in the ingester

func (*Frontend) NotifyClientShutdown ¶

func (f *Frontend) NotifyClientShutdown(_ context.Context, req *frontendv1pb.NotifyClientShutdownRequest) (*frontendv1pb.NotifyClientShutdownResponse, error)

func (*Frontend) Process ¶

func (f *Frontend) Process(server frontendv1pb.Frontend_ProcessServer) error

Process allows backends to pull requests from the frontend.

func (*Frontend) RoundTripGRPC ¶

func (f *Frontend) RoundTripGRPC(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)

RoundTripGRPC round trips a proto (instead of a HTTP request).

type Limits ¶

type Limits interface {
	// Returns max queriers to use per tenant, or 0 if shuffle sharding is disabled.
	MaxQueriersPerUser(user string) int
}

Source Files ¶

View all Source files

frontend.go

Directories ¶

Path	Synopsis
frontendv1pb

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