Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGRPCClient ¶
func NewGRPCClient(addr string, cfg GRPCConfig, r prometheus.Registerer) (deletion.CompactorClient, error)
NewGRPCClient supports only methods which are used for internal communication of Loki like loading delete requests and cache gen numbers for query time filtering.
func NewHTTPClient ¶
func NewHTTPClient(addr string, cfg HTTPConfig) (deletion.CompactorClient, error)
NewHTTPClient creates a client which talks to compactor over HTTP. It uses provided TLS config which creating HTTP client.
Types ¶
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.