Help us shape the future of Go! Take the 2026 Go Developer Survey

client

package
v3.7.8 Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2026 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FastFingerprint

func FastFingerprint(ls []logproto.LabelAdapter) model.Fingerprint

FastFingerprint runs the same algorithm as Prometheus labelSetToFastFingerprint()

func Fingerprint

func Fingerprint(lbls labels.Labels) model.Fingerprint

Fingerprint runs the same algorithm as Prometheus labelSetToFingerprint()

Types

type Config

type Config struct {
	PoolConfig                   clientpool.PoolConfig          `yaml:"pool_config,omitempty" doc:"description=Configures how connections are pooled."`
	RemoteTimeout                time.Duration                  `yaml:"remote_timeout,omitempty"`
	GRPCClientConfig             grpcclient.Config              `yaml:"grpc_client_config" doc:"description=Configures how the gRPC connection to ingesters work as a client."`
	GRPCUnaryClientInterceptors  []grpc.UnaryClientInterceptor  `yaml:"-"`
	GRCPStreamClientInterceptors []grpc.StreamClientInterceptor `yaml:"-"`

	// Internal is used to indicate that this client communicates on behalf of
	// a machine and not a user. When Internal = true, the client won't attempt
	// to inject an userid into the context.
	Internal bool `yaml:"-"`
}

Config for an ingester client.

func (*Config) RegisterFlags

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

RegisterFlags registers flags.

type HealthAndIngesterClient

type HealthAndIngesterClient interface {
	grpc_health_v1.HealthClient
	Close() error
}

func New

func New(cfg Config, addr string) (HealthAndIngesterClient, error)

New returns a new ingester client.

Jump to

Keyboard shortcuts

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