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 ClosableHealthAndIngesterClient ¶
type ClosableHealthAndIngesterClient struct {
logproto.PusherClient
logproto.QuerierClient
logproto.StreamDataClient
grpc_health_v1.HealthClient
io.Closer
}
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 ¶
RegisterFlags registers flags.
type HealthAndIngesterClient ¶
type HealthAndIngesterClient interface {
grpc_health_v1.HealthClient
Close() error
}
Click to show internal directories.
Click to hide internal directories.