client

Documentation

Index

• func NewGRPCClient(addr string, cfg GRPCConfig, r prometheus.Registerer) (deletion.CompactorClient, error)
• func NewHTTPClient(addr string, cfg HTTPConfig) (deletion.CompactorClient, error)
• type GRPCConfig
  • func (cfg *GRPCConfig) RegisterFlags(f *flag.FlagSet)
• type HTTPConfig
  • func (cfg *HTTPConfig) RegisterFlags(f *flag.FlagSet)

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.