pattern

type Config struct {
	Enabled              bool                  `yaml:"enabled,omitempty" doc:"description=Whether the pattern ingester is enabled."`
	LifecyclerConfig     ring.LifecyclerConfig `` /* 153-byte string literal not displayed */
	ClientConfig         clientpool.Config     `yaml:"client_config,omitempty" doc:"description=Configures how the pattern ingester will connect to the ingesters."`
	ConcurrentFlushes    int                   `yaml:"concurrent_flushes"`
	FlushCheckPeriod     time.Duration         `yaml:"flush_check_period"`
	MaxClusters          int                   `` /* 127-byte string literal not displayed */
	MaxEvictionRatio     float64               `` /* 177-byte string literal not displayed */
	MetricAggregation    aggregation.Config    `` /* 133-byte string literal not displayed */
	TeeConfig            TeeConfig             `yaml:"tee_config,omitempty" doc:"description=Configures the pattern tee which forwards requests to the pattern ingester."`
	ConnectionTimeout    time.Duration         `yaml:"connection_timeout"`
	MaxAllowedLineLength int                   `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Ingester struct {
	services.Service
	// contains filtered or unexported fields
}

type IngesterQuerier struct {
	// contains filtered or unexported fields
}

type Limits interface {
	drain.Limits
	aggregation.Limits
}

type ResponseFromIngesters struct {
	// contains filtered or unexported fields
}

type RingClient interface {
	services.Service
	Ring() ring.ReadRing
	GetClientFor(addr string) (ring_client.PoolClient, error)
}

type TeeConfig struct {
	BatchSize          int           `yaml:"batch_size"`
	BatchFlushInterval time.Duration `yaml:"batch_flush_interval"`
	FlushQueueSize     int           `yaml:"flush_queue_size"`
	FlushWorkerCount   int           `yaml:"flush_worker_count"`
	StopFlushTimeout   time.Duration `yaml:"stop_flush_timeout"`
}

type TeeService struct {
	// contains filtered or unexported fields
}