distributor

May 25, 2023

Changes in this version

type Limits

+ IngestionTenantShardSize func(tenantID string) int

Feb 20, 2023

Changes in this version

type Config

+ DistributorRing RingConfig

type Distributor

+ func (d *Distributor) HealthyInstancesCount() int

+ func (d *Distributor) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type Limits interface

+ IngestionBurstSizeBytes func(tenantID string) int

+ IngestionRateBytes func(tenantID string) float64

+ MaxLabelNameLength func(userID string) int

+ MaxLabelNamesPerSeries func(userID string) int

+ MaxLabelValueLength func(userID string) int

+ type ReadLifecycler interface

+ HealthyInstancesCount func() int

type RingConfig

+ func (cfg *RingConfig) ToBasicLifecyclerConfig(logger log.Logger) (ring.BasicLifecyclerConfig, error)

Oct 26, 2022

Changes in this version

+ func TokenFor(tenantID, labels string) uint32

+ type Config struct

+ PoolConfig clientpool.PoolConfig

+ PushTimeout time.Duration

+ func (cfg *Config) RegisterFlags(fs *flag.FlagSet)

+ type Distributor struct

+ func New(cfg Config, ingestersRing ring.ReadRing, factory ring_client.PoolFactory, ...) (*Distributor, error)

+ func (d *Distributor) Push(ctx context.Context, req *connect.Request[pushv1.PushRequest]) (*connect.Response[pushv1.PushResponse], error)

+ type PushClient interface

+ Push func(context.Context, *connect.Request[pushv1.PushRequest]) (*connect.Response[pushv1.PushResponse], error)

+ type RingConfig struct

+ HeartbeatPeriod time.Duration

+ HeartbeatTimeout time.Duration

+ InstanceAddr string

+ InstanceID string

+ InstanceInterfaceNames []string

+ InstancePort int

+ KVStore kv.Config

+ ListenPort int

+ func (cfg *RingConfig) RegisterFlags(f *flag.FlagSet)

+ func (cfg *RingConfig) ToLifecyclerConfig() ring.LifecyclerConfig

+ func (cfg *RingConfig) ToRingConfig() ring.Config