scheduler

type BidiStreamCloser[Req, Res any] struct {
	// contains filtered or unexported fields
}

type Config struct {
	MaxOutstandingPerTenant int                       `yaml:"max_outstanding_requests_per_tenant"`
	QuerierForgetDelay      time.Duration             `yaml:"querier_forget_delay" category:"experimental"`
	GRPCClientConfig        grpcclient.Config         `yaml:"grpc_client_config" doc:"description=This configures the gRPC client used to report errors back to the query-frontend."`
	ServiceDiscovery        schedulerdiscovery.Config `yaml:",inline"`

	// Dial options used to initiate outgoing gRPC connections.
	// Intended to be used by tests to use in-memory network connections.
	DialOpts []grpc.DialOption `yaml:"-"`
}

type Limits interface {
	// MaxQueriersPerTenant returns max queriers to use per tenant, or 0 if shuffle sharding is disabled.
	MaxQueriersPerTenant(tenant string) int
}

type Scheduler struct {
	services.Service

	schedulerpb.UnimplementedSchedulerForFrontendServer
	schedulerpb.UnimplementedSchedulerForQuerierServer
	// contains filtered or unexported fields
}