Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompactorClient ¶ added in v3.6.0
type CompactorClient interface {
GetAllDeleteRequestsForUser(ctx context.Context, userID string) ([]deletionproto.DeleteRequest, error)
GetCacheGenerationNumber(ctx context.Context, userID string) (string, error)
JobQueueClient() grpc.JobQueueClient
Name() string
Stop()
}
func NewGRPCClient ¶
func NewGRPCClient(addr string, cfg GRPCConfig, r prometheus.Registerer) (CompactorClient, error)
NewGRPCClient supports only methods which are used for internal communication of Loki like loading delete requests, cache gen numbers for query time filtering and interacting with job queue for horizontal scaling of compactor.
func NewHTTPClient ¶
func NewHTTPClient(addr string, cfg HTTPConfig) (CompactorClient, error)
NewHTTPClient creates a client which talks to compactor over HTTP. It uses provided TLS config which creating HTTP client.
type GRPCConfig ¶
type GRPCConfig struct {
GRPCClientConfig grpcclient.Config `yaml:",inline"`
}
func (*GRPCConfig) RegisterFlags ¶
func (cfg *GRPCConfig) RegisterFlags(f *flag.FlagSet)
RegisterFlags registers flags.
type HTTPConfig ¶
type HTTPConfig struct {
TLSEnabled bool `yaml:"tls_enabled"`
TLS tls.ClientConfig `yaml:",inline"`
}
func (*HTTPConfig) RegisterFlags ¶
func (cfg *HTTPConfig) RegisterFlags(f *flag.FlagSet)
RegisterFlags adds the flags required to config this to the given FlagSet.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.