Versions in this module Expand all Collapse all v0 v0.1.0 Jun 3, 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)