Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + func NewRateStore(cfg RateStoreConfig, r ring.ReadRing, cf poolClientFactory, l Limits, ...) *rateStore + type Config struct + DistributorRing RingConfig + RateStore RateStoreConfig + WriteFailuresLogging writefailures.Cfg + func (cfg *Config) RegisterFlags(fs *flag.FlagSet) + type Distributor struct + func New(cfg Config, clientCfg client.Config, configs *runtime.TenantConfigs, ...) (*Distributor, error) + func (d *Distributor) HealthyInstancesCount() int + func (d *Distributor) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error) + func (d *Distributor) PushHandler(w http.ResponseWriter, r *http.Request) + func (d *Distributor) ServeHTTP(w http.ResponseWriter, r *http.Request) + type Limits interface + CreationGracePeriod func(userID string) time.Duration + EnforceMetricName func(userID string) bool + IncrementDuplicateTimestamps func(userID string) bool + IngestionBurstSizeBytes func(userID string) int + IngestionRateBytes func(userID string) float64 + IngestionRateStrategy func() string + MaxLabelNameLength func(userID string) int + MaxLabelNamesPerSeries func(userID string) int + MaxLabelValueLength func(userID string) int + MaxLineSize func(userID string) int + MaxLineSizeTruncate func(userID string) bool + RejectOldSamples func(userID string) bool + RejectOldSamplesMaxAge func(userID string) time.Duration + ShardStreams func(userID string) *shardstreams.Config + type RateStore interface + RateFor func(tenantID string, streamHash uint64) (int64, float64) + type RateStoreConfig struct + Debug bool + IngesterReqTimeout time.Duration + MaxParallelism int + StreamRateUpdateInterval time.Duration + func (cfg *RateStoreConfig) RegisterFlagsWithPrefix(prefix string, fs *flag.FlagSet) + type ReadLifecycler interface + HealthyInstancesCount func() int + type RingConfig struct + EnableIPv6 bool + 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) ToBasicLifecyclerConfig(logger log.Logger) (ring.BasicLifecyclerConfig, error) + func (cfg *RingConfig) ToRingConfig() ring.Config + type ShardTracker struct + func NewShardTracker() *ShardTracker + func (t *ShardTracker) LastShardNum(tenant string, streamHash uint64) int + func (t *ShardTracker) SetLastShardNum(tenant string, streamHash uint64, shardNum int) + type Validator struct + func NewValidator(l Limits) (*Validator, error) + func (v Validator) ValidateEntry(ctx validationContext, labels string, entry logproto.Entry) error + func (v Validator) ValidateLabels(ctx validationContext, ls labels.Labels, stream logproto.Stream) error
Go to main page