Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + var ErrIntOverflowScheduler = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthScheduler = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrSchedulerIsNotRunning = errors.New("scheduler is not running") + var FrontendToSchedulerType_name = map[int32]string + var FrontendToSchedulerType_value = map[string]int32 + var SchedulerToFrontendStatus_name = map[int32]string + var SchedulerToFrontendStatus_value = map[string]int32 + func RegisterSchedulerForFrontendServer(s *grpc.Server, srv SchedulerForFrontendServer) + func RegisterSchedulerForQuerierServer(s *grpc.Server, srv SchedulerForQuerierServer) + type FrontendToScheduler struct + FrontendAddress string + HttpRequest *httpgrpc.HTTPRequest + QueryID uint64 + QueuePath []string + StatsEnabled bool + Type FrontendToSchedulerType + UserID string + func (*FrontendToScheduler) Descriptor() ([]byte, []int) + func (*FrontendToScheduler) ProtoMessage() + func (m *FrontendToScheduler) GetFrontendAddress() string + func (m *FrontendToScheduler) GetHttpRequest() *httpgrpc.HTTPRequest + func (m *FrontendToScheduler) GetQueryID() uint64 + func (m *FrontendToScheduler) GetQueuePath() []string + func (m *FrontendToScheduler) GetStatsEnabled() bool + func (m *FrontendToScheduler) GetType() FrontendToSchedulerType + func (m *FrontendToScheduler) GetUserID() string + func (m *FrontendToScheduler) Marshal() (dAtA []byte, err error) + func (m *FrontendToScheduler) MarshalTo(dAtA []byte) (int, error) + func (m *FrontendToScheduler) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FrontendToScheduler) Reset() + func (m *FrontendToScheduler) Size() (n int) + func (m *FrontendToScheduler) Unmarshal(dAtA []byte) error + func (m *FrontendToScheduler) XXX_DiscardUnknown() + func (m *FrontendToScheduler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FrontendToScheduler) XXX_Merge(src proto.Message) + func (m *FrontendToScheduler) XXX_Size() int + func (m *FrontendToScheduler) XXX_Unmarshal(b []byte) error + func (this *FrontendToScheduler) Equal(that interface{}) bool + func (this *FrontendToScheduler) GoString() string + func (this *FrontendToScheduler) String() string + type FrontendToSchedulerType int32 + const CANCEL + const ENQUEUE + const INIT + func (FrontendToSchedulerType) EnumDescriptor() ([]byte, []int) + func (x FrontendToSchedulerType) String() string + type NotifyQuerierShutdownRequest struct + QuerierID string + func (*NotifyQuerierShutdownRequest) Descriptor() ([]byte, []int) + func (*NotifyQuerierShutdownRequest) ProtoMessage() + func (m *NotifyQuerierShutdownRequest) GetQuerierID() string + func (m *NotifyQuerierShutdownRequest) Marshal() (dAtA []byte, err error) + func (m *NotifyQuerierShutdownRequest) MarshalTo(dAtA []byte) (int, error) + func (m *NotifyQuerierShutdownRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NotifyQuerierShutdownRequest) Reset() + func (m *NotifyQuerierShutdownRequest) Size() (n int) + func (m *NotifyQuerierShutdownRequest) Unmarshal(dAtA []byte) error + func (m *NotifyQuerierShutdownRequest) XXX_DiscardUnknown() + func (m *NotifyQuerierShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotifyQuerierShutdownRequest) XXX_Merge(src proto.Message) + func (m *NotifyQuerierShutdownRequest) XXX_Size() int + func (m *NotifyQuerierShutdownRequest) XXX_Unmarshal(b []byte) error + func (this *NotifyQuerierShutdownRequest) Equal(that interface{}) bool + func (this *NotifyQuerierShutdownRequest) GoString() string + func (this *NotifyQuerierShutdownRequest) String() string + type NotifyQuerierShutdownResponse struct + func (*NotifyQuerierShutdownResponse) Descriptor() ([]byte, []int) + func (*NotifyQuerierShutdownResponse) ProtoMessage() + func (m *NotifyQuerierShutdownResponse) Marshal() (dAtA []byte, err error) + func (m *NotifyQuerierShutdownResponse) MarshalTo(dAtA []byte) (int, error) + func (m *NotifyQuerierShutdownResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NotifyQuerierShutdownResponse) Reset() + func (m *NotifyQuerierShutdownResponse) Size() (n int) + func (m *NotifyQuerierShutdownResponse) Unmarshal(dAtA []byte) error + func (m *NotifyQuerierShutdownResponse) XXX_DiscardUnknown() + func (m *NotifyQuerierShutdownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotifyQuerierShutdownResponse) XXX_Merge(src proto.Message) + func (m *NotifyQuerierShutdownResponse) XXX_Size() int + func (m *NotifyQuerierShutdownResponse) XXX_Unmarshal(b []byte) error + func (this *NotifyQuerierShutdownResponse) Equal(that interface{}) bool + func (this *NotifyQuerierShutdownResponse) GoString() string + func (this *NotifyQuerierShutdownResponse) String() string + type QuerierToScheduler struct + QuerierID string + func (*QuerierToScheduler) Descriptor() ([]byte, []int) + func (*QuerierToScheduler) ProtoMessage() + func (m *QuerierToScheduler) GetQuerierID() string + func (m *QuerierToScheduler) Marshal() (dAtA []byte, err error) + func (m *QuerierToScheduler) MarshalTo(dAtA []byte) (int, error) + func (m *QuerierToScheduler) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuerierToScheduler) Reset() + func (m *QuerierToScheduler) Size() (n int) + func (m *QuerierToScheduler) Unmarshal(dAtA []byte) error + func (m *QuerierToScheduler) XXX_DiscardUnknown() + func (m *QuerierToScheduler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuerierToScheduler) XXX_Merge(src proto.Message) + func (m *QuerierToScheduler) XXX_Size() int + func (m *QuerierToScheduler) XXX_Unmarshal(b []byte) error + func (this *QuerierToScheduler) Equal(that interface{}) bool + func (this *QuerierToScheduler) GoString() string + func (this *QuerierToScheduler) String() string + type SchedulerForFrontendClient interface + FrontendLoop func(ctx context.Context, opts ...grpc.CallOption) (SchedulerForFrontend_FrontendLoopClient, error) + func NewSchedulerForFrontendClient(cc *grpc.ClientConn) SchedulerForFrontendClient + type SchedulerForFrontendServer interface + FrontendLoop func(SchedulerForFrontend_FrontendLoopServer) error + type SchedulerForFrontend_FrontendLoopClient interface + Recv func() (*SchedulerToFrontend, error) + Send func(*FrontendToScheduler) error + type SchedulerForFrontend_FrontendLoopServer interface + Recv func() (*FrontendToScheduler, error) + Send func(*SchedulerToFrontend) error + type SchedulerForQuerierClient interface + NotifyQuerierShutdown func(ctx context.Context, in *NotifyQuerierShutdownRequest, opts ...grpc.CallOption) (*NotifyQuerierShutdownResponse, error) + QuerierLoop func(ctx context.Context, opts ...grpc.CallOption) (SchedulerForQuerier_QuerierLoopClient, error) + func NewSchedulerForQuerierClient(cc *grpc.ClientConn) SchedulerForQuerierClient + type SchedulerForQuerierServer interface + NotifyQuerierShutdown func(context.Context, *NotifyQuerierShutdownRequest) (*NotifyQuerierShutdownResponse, error) + QuerierLoop func(SchedulerForQuerier_QuerierLoopServer) error + type SchedulerForQuerier_QuerierLoopClient interface + Recv func() (*SchedulerToQuerier, error) + Send func(*QuerierToScheduler) error + type SchedulerForQuerier_QuerierLoopServer interface + Recv func() (*QuerierToScheduler, error) + Send func(*SchedulerToQuerier) error + type SchedulerToFrontend struct + Error string + Status SchedulerToFrontendStatus + func (*SchedulerToFrontend) Descriptor() ([]byte, []int) + func (*SchedulerToFrontend) ProtoMessage() + func (m *SchedulerToFrontend) GetError() string + func (m *SchedulerToFrontend) GetStatus() SchedulerToFrontendStatus + func (m *SchedulerToFrontend) Marshal() (dAtA []byte, err error) + func (m *SchedulerToFrontend) MarshalTo(dAtA []byte) (int, error) + func (m *SchedulerToFrontend) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SchedulerToFrontend) Reset() + func (m *SchedulerToFrontend) Size() (n int) + func (m *SchedulerToFrontend) Unmarshal(dAtA []byte) error + func (m *SchedulerToFrontend) XXX_DiscardUnknown() + func (m *SchedulerToFrontend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SchedulerToFrontend) XXX_Merge(src proto.Message) + func (m *SchedulerToFrontend) XXX_Size() int + func (m *SchedulerToFrontend) XXX_Unmarshal(b []byte) error + func (this *SchedulerToFrontend) Equal(that interface{}) bool + func (this *SchedulerToFrontend) GoString() string + func (this *SchedulerToFrontend) String() string + type SchedulerToFrontendStatus int32 + const ERROR + const OK + const SHUTTING_DOWN + const TOO_MANY_REQUESTS_PER_TENANT + func (SchedulerToFrontendStatus) EnumDescriptor() ([]byte, []int) + func (x SchedulerToFrontendStatus) String() string + type SchedulerToQuerier struct + FrontendAddress string + HttpRequest *httpgrpc.HTTPRequest + QueryID uint64 + StatsEnabled bool + UserID string + func (*SchedulerToQuerier) Descriptor() ([]byte, []int) + func (*SchedulerToQuerier) ProtoMessage() + func (m *SchedulerToQuerier) GetFrontendAddress() string + func (m *SchedulerToQuerier) GetHttpRequest() *httpgrpc.HTTPRequest + func (m *SchedulerToQuerier) GetQueryID() uint64 + func (m *SchedulerToQuerier) GetStatsEnabled() bool + func (m *SchedulerToQuerier) GetUserID() string + func (m *SchedulerToQuerier) Marshal() (dAtA []byte, err error) + func (m *SchedulerToQuerier) MarshalTo(dAtA []byte) (int, error) + func (m *SchedulerToQuerier) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SchedulerToQuerier) Reset() + func (m *SchedulerToQuerier) Size() (n int) + func (m *SchedulerToQuerier) Unmarshal(dAtA []byte) error + func (m *SchedulerToQuerier) XXX_DiscardUnknown() + func (m *SchedulerToQuerier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SchedulerToQuerier) XXX_Merge(src proto.Message) + func (m *SchedulerToQuerier) XXX_Size() int + func (m *SchedulerToQuerier) XXX_Unmarshal(b []byte) error + func (this *SchedulerToQuerier) Equal(that interface{}) bool + func (this *SchedulerToQuerier) GoString() string + func (this *SchedulerToQuerier) String() string + type UnimplementedSchedulerForFrontendServer struct + func (*UnimplementedSchedulerForFrontendServer) FrontendLoop(srv SchedulerForFrontend_FrontendLoopServer) error + type UnimplementedSchedulerForQuerierServer struct + func (*UnimplementedSchedulerForQuerierServer) NotifyQuerierShutdown(ctx context.Context, req *NotifyQuerierShutdownRequest) (*NotifyQuerierShutdownResponse, error) + func (*UnimplementedSchedulerForQuerierServer) QuerierLoop(srv SchedulerForQuerier_QuerierLoopServer) error
Go to main page