pattern

type BasicAuth struct {
	Username string        `yaml:"username"           json:"username"`
	Password config.Secret `yaml:"password,omitempty" json:"password,omitempty"`
}

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 */
	PatternPersistence    PersistenceConfig     `` /* 128-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 */
	RetainFor             time.Duration         `yaml:"retain_for,omitempty" doc:"description=How long to retain patterns in the pattern ingester after they are pushed."`
	MaxChunkAge           time.Duration         `yaml:"max_chunk_age,omitempty" doc:"description=The maximum time span for a single pattern chunk."`
	PatternSampleInterval time.Duration         `yaml:"pattern_sample_interval,omitempty" doc:"description=The time resolution for pattern samples within chunks."`
	VolumeThreshold       float64               `` /* 176-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
	MetricAggregationEnabled(userID string) bool
	PatternPersistenceEnabled(userID string) bool
	PersistenceGranularity(userID string) time.Duration
	PatternRateThreshold(userID string) float64
}

type PersistenceConfig struct {
	LokiAddr         string                  `yaml:"loki_address,omitempty" doc:"description=The address of the Loki instance to push patterns to."`
	WriteTimeout     time.Duration           `yaml:"timeout,omitempty" doc:"description=The timeout for writing patterns to Loki."`
	PushPeriod       time.Duration           `yaml:"push_period,omitempty" doc:"description=How long to wait between pattern pushes to Loki."`
	HTTPClientConfig config.HTTPClientConfig `yaml:"http_client_config,omitempty" doc:"description=The HTTP client configuration for pushing patterns to Loki."`
	UseTLS           bool                    `yaml:"use_tls,omitempty" doc:"description=Whether to use TLS for pushing patterns to Loki."`
	BasicAuth        BasicAuth               `yaml:"basic_auth,omitempty" doc:"description=The basic auth configuration for pushing patterns to Loki."`
	BackoffConfig    backoff.Config          `yaml:"backoff_config,omitempty" doc:"description=The backoff configuration for pushing patterns to Loki."`
	BatchSize        int                     `yaml:"batch_size,omitempty" doc:"description=The maximum number of patterns to accumulate before pushing."`
}

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
}