Versions in this module Expand all Collapse all v1 v1.0.2 Jul 26, 2019 Changes in this version + type Config struct + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Distributor struct + func New(cfg Config, clientCfg client.Config, ring ring.ReadRing, ...) (*Distributor, error) + func (*Distributor) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error) + func (d *Distributor) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error) + func (d *Distributor) PushHandler(w http.ResponseWriter, r *http.Request)
Go to main page