loki

type Codec interface {
	transport.Codec
	worker.RequestCodec
}

type Config struct {
	Target       flagext.StringSliceCSV `yaml:"target,omitempty"`
	AuthEnabled  bool                   `yaml:"auth_enabled,omitempty"`
	HTTPPrefix   string                 `yaml:"http_prefix" doc:"hidden"`
	BallastBytes int                    `yaml:"ballast_bytes"`

	Server              server.Config              `yaml:"server,omitempty"`
	InternalServer      internalserver.Config      `yaml:"internal_server,omitempty" doc:"hidden"`
	Distributor         distributor.Config         `yaml:"distributor,omitempty"`
	Querier             querier.Config             `yaml:"querier,omitempty"`
	QuerierRF1          querierrf1.Config          `yaml:"querier_rf1,omitempty"`
	QueryScheduler      scheduler.Config           `yaml:"query_scheduler"`
	Frontend            lokifrontend.Config        `yaml:"frontend,omitempty"`
	QueryRange          queryrange.Config          `yaml:"query_range,omitempty"`
	Ruler               ruler.Config               `yaml:"ruler,omitempty"`
	IngesterClient      ingester_client.Config     `yaml:"ingester_client,omitempty"`
	IngesterRF1Client   ingester_client.Config     `yaml:"ingester_rf1_client,omitempty"`
	Ingester            ingester.Config            `yaml:"ingester,omitempty"`
	IngesterRF1         ingester_rf1.Config        `yaml:"ingester_rf1,omitempty" category:"experimental"`
	Pattern             pattern.Config             `yaml:"pattern_ingester,omitempty"`
	IndexGateway        indexgateway.Config        `yaml:"index_gateway"`
	BloomBuild          bloombuild.Config          `yaml:"bloom_build,omitempty" category:"experimental"`
	BloomGateway        bloomgateway.Config        `yaml:"bloom_gateway,omitempty" category:"experimental"`
	StorageConfig       storage.Config             `yaml:"storage_config,omitempty"`
	ChunkStoreConfig    config.ChunkStoreConfig    `yaml:"chunk_store_config,omitempty"`
	SchemaConfig        config.SchemaConfig        `yaml:"schema_config,omitempty"`
	CompactorConfig     compactor.Config           `yaml:"compactor,omitempty"`
	CompactorHTTPClient compactorclient.HTTPConfig `yaml:"compactor_client,omitempty" doc:"hidden"`
	CompactorGRPCClient compactorclient.GRPCConfig `yaml:"compactor_grpc_client,omitempty"`
	LimitsConfig        validation.Limits          `yaml:"limits_config"`
	Worker              worker.Config              `yaml:"frontend_worker,omitempty"`
	TableManager        index.TableManagerConfig   `yaml:"table_manager,omitempty"`
	MemberlistKV        memberlist.KVConfig        `yaml:"memberlist"`
	Metastore           metastore.Config           `yaml:"metastore,omitempty"`
	MetastoreClient     metastoreclient.Config     `yaml:"metastore_client"`
	PartitionRingConfig partitionring.Config       `yaml:"partition_ring,omitempty" category:"experimental"`
	KafkaConfig         kafka.Config               `yaml:"kafka_config,omitempty" category:"experimental"`
	KafkaIngester       ingesterkafka.Config       `yaml:"kafka_ingester,omitempty" category:"experimental"`

	RuntimeConfig     runtimeconfig.Config `yaml:"runtime_config,omitempty"`
	OperationalConfig runtime.Config       `yaml:"operational_config,omitempty"`
	Tracing           tracing.Config       `yaml:"tracing"`
	Analytics         analytics.Config     `yaml:"analytics"`
	Profiling         ProfilingConfig      `yaml:"profiling,omitempty"`

	LegacyReadTarget bool `yaml:"legacy_read_target,omitempty" doc:"hidden|deprecated"`

	Common common.Config `yaml:"common,omitempty"`

	ShutdownDelay time.Duration `yaml:"shutdown_delay"`

	MetricsNamespace string `yaml:"metrics_namespace"`
}

type ConfigWrapper struct {
	Config `yaml:",inline"`

	VerifyConfig    bool
	PrintConfig     bool
	ListTargets     bool
	LogConfig       bool
	ConfigFile      string
	ConfigExpandEnv bool
	// contains filtered or unexported fields
}

type FormatQueryResponse struct {
	Status string `json:"status"`
	Data   string `json:"data,omitempty"`
	Err    string `json:"error,omitempty"`
}

type Frontend interface {
	services.Service
	CheckReady(_ context.Context) error
}

type Loki struct {
	Cfg Config

	// set during initialization
	ModuleManager *modules.Manager

	SignalHandler *signals.Handler

	Server         *server.Server
	InternalServer *server.Server

	Overrides limiter.CombinedLimits

	TenantLimits validation.TenantLimits

	Ingester              ingester.Interface
	IngesterRF1           ingester_rf1.Interface
	IngesterRF1RingClient *ingester_rf1.RingClient
	PatternIngester       *pattern.Ingester
	PatternRingClient     pattern.RingClient
	Querier               querier.Querier

	Store      storage.Store
	BloomStore bloomshipper.Store

	RulerStorage rulestore.RuleStore

	MemberlistKV *memberlist.KVInitService

	QueryFrontEndMiddleware queryrangebase.Middleware

	MetastoreClient *metastoreclient.Client

	ClientMetrics storage.ClientMetrics

	Tee                distributor.Tee
	PushParserWrapper  push.RequestParserWrapper
	HTTPAuthMiddleware middleware.Interface

	Codec   Codec
	Metrics *server.Metrics

	UsageTracker push.UsageTracker
	// contains filtered or unexported fields
}

type ProfilingConfig struct {
	BlockProfileRate     int `yaml:"block_profile_rate"`
	CPUProfileRate       int `yaml:"cpu_profile_rate"`
	MutexProfileFraction int `yaml:"mutex_profile_fraction"`
}

type RunOpts struct {
	// CustomConfigEndpointHandlerFn is the handlerFunc to be used by the /config endpoint.
	// If empty, default handlerFunc will be used.
	CustomConfigEndpointHandlerFn func(http.ResponseWriter, *http.Request)
	// StartTime is the time at which the main() function started executing.
	// It is used to determine the startup time as well as the running time of the Loki process.
	StartTime time.Time
}