schedulerobjects

package
v0.16.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 28, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package schedulerobjects is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSchedulerReporting        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchedulerReporting          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSchedulerReporting = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterSchedulerReportingHandler 

func RegisterSchedulerReportingHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSchedulerReportingHandler registers the http handlers for service SchedulerReporting to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSchedulerReportingHandlerClient 

func RegisterSchedulerReportingHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SchedulerReportingClient) error

RegisterSchedulerReportingHandlerClient registers the http handlers for service SchedulerReporting to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SchedulerReportingClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SchedulerReportingClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SchedulerReportingClient" to call the correct interceptors.

func RegisterSchedulerReportingHandlerFromEndpoint 

func RegisterSchedulerReportingHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSchedulerReportingHandlerFromEndpoint is same as RegisterSchedulerReportingHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSchedulerReportingHandlerServer 

func RegisterSchedulerReportingHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SchedulerReportingServer) error

RegisterSchedulerReportingHandlerServer registers the http handlers for service SchedulerReporting to "mux". UnaryRPC :call SchedulerReportingServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSchedulerReportingHandlerFromEndpoint instead.

func RegisterSchedulerReportingServer 

func RegisterSchedulerReportingServer(s *grpc.Server, srv SchedulerReportingServer)

func SwaggerJsonTemplate 

func SwaggerJsonTemplate() string

SwaggerJsonTemplate is a generated function returning the template as a string. That string should be parsed by the functions of the golang's template package.

Types

type JobReport 

type JobReport struct {
	Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}

func (*JobReport) Descriptor 

func (*JobReport) Descriptor() ([]byte, []int)

func (*JobReport) GetReport 

func (m *JobReport) GetReport() string

func (*JobReport) Marshal 

func (m *JobReport) Marshal() (dAtA []byte, err error)

func (*JobReport) MarshalTo 

func (m *JobReport) MarshalTo(dAtA []byte) (int, error)

func (*JobReport) MarshalToSizedBuffer 

func (m *JobReport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobReport) ProtoMessage 

func (*JobReport) ProtoMessage()

func (*JobReport) Reset 

func (m *JobReport) Reset()

func (*JobReport) Size 

func (m *JobReport) Size() (n int)

func (*JobReport) String 

func (m *JobReport) String() string

func (*JobReport) Unmarshal 

func (m *JobReport) Unmarshal(dAtA []byte) error

func (*JobReport) XXX_DiscardUnknown 

func (m *JobReport) XXX_DiscardUnknown()

func (*JobReport) XXX_Marshal 

func (m *JobReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReport) XXX_Merge 

func (m *JobReport) XXX_Merge(src proto.Message)

func (*JobReport) XXX_Size 

func (m *JobReport) XXX_Size() int

func (*JobReport) XXX_Unmarshal 

func (m *JobReport) XXX_Unmarshal(b []byte) error

type JobReportRequest 

type JobReportRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}

func (*JobReportRequest) Descriptor 

func (*JobReportRequest) Descriptor() ([]byte, []int)

func (*JobReportRequest) GetJobId 

func (m *JobReportRequest) GetJobId() string

func (*JobReportRequest) Marshal 

func (m *JobReportRequest) Marshal() (dAtA []byte, err error)

func (*JobReportRequest) MarshalTo 

func (m *JobReportRequest) MarshalTo(dAtA []byte) (int, error)

func (*JobReportRequest) MarshalToSizedBuffer 

func (m *JobReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobReportRequest) ProtoMessage 

func (*JobReportRequest) ProtoMessage()

func (*JobReportRequest) Reset 

func (m *JobReportRequest) Reset()

func (*JobReportRequest) Size 

func (m *JobReportRequest) Size() (n int)

func (*JobReportRequest) String 

func (m *JobReportRequest) String() string

func (*JobReportRequest) Unmarshal 

func (m *JobReportRequest) Unmarshal(dAtA []byte) error

func (*JobReportRequest) XXX_DiscardUnknown 

func (m *JobReportRequest) XXX_DiscardUnknown()

func (*JobReportRequest) XXX_Marshal 

func (m *JobReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReportRequest) XXX_Merge 

func (m *JobReportRequest) XXX_Merge(src proto.Message)

func (*JobReportRequest) XXX_Size 

func (m *JobReportRequest) XXX_Size() int

func (*JobReportRequest) XXX_Unmarshal 

func (m *JobReportRequest) XXX_Unmarshal(b []byte) error

type MostRecentForJob 

type MostRecentForJob struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}

Deprecated. This will be removed in a future release. Please use GetJobReport instead.

func (*MostRecentForJob) Descriptor 

func (*MostRecentForJob) Descriptor() ([]byte, []int)

func (*MostRecentForJob) GetJobId 

func (m *MostRecentForJob) GetJobId() string

func (*MostRecentForJob) Marshal 

func (m *MostRecentForJob) Marshal() (dAtA []byte, err error)

func (*MostRecentForJob) MarshalTo 

func (m *MostRecentForJob) MarshalTo(dAtA []byte) (int, error)

func (*MostRecentForJob) MarshalToSizedBuffer 

func (m *MostRecentForJob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MostRecentForJob) ProtoMessage 

func (*MostRecentForJob) ProtoMessage()

func (*MostRecentForJob) Reset 

func (m *MostRecentForJob) Reset()

func (*MostRecentForJob) Size 

func (m *MostRecentForJob) Size() (n int)

func (*MostRecentForJob) String 

func (m *MostRecentForJob) String() string

func (*MostRecentForJob) Unmarshal 

func (m *MostRecentForJob) Unmarshal(dAtA []byte) error

func (*MostRecentForJob) XXX_DiscardUnknown 

func (m *MostRecentForJob) XXX_DiscardUnknown()

func (*MostRecentForJob) XXX_Marshal 

func (m *MostRecentForJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MostRecentForJob) XXX_Merge 

func (m *MostRecentForJob) XXX_Merge(src proto.Message)

func (*MostRecentForJob) XXX_Size 

func (m *MostRecentForJob) XXX_Size() int

func (*MostRecentForJob) XXX_Unmarshal 

func (m *MostRecentForJob) XXX_Unmarshal(b []byte) error

type MostRecentForQueue 

type MostRecentForQueue struct {
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queueName,omitempty"`
}

Deprecated. This will be removed in a future release. Please use GetQueueReport instead.

func (*MostRecentForQueue) Descriptor 

func (*MostRecentForQueue) Descriptor() ([]byte, []int)

func (*MostRecentForQueue) GetQueueName 

func (m *MostRecentForQueue) GetQueueName() string

func (*MostRecentForQueue) Marshal 

func (m *MostRecentForQueue) Marshal() (dAtA []byte, err error)

func (*MostRecentForQueue) MarshalTo 

func (m *MostRecentForQueue) MarshalTo(dAtA []byte) (int, error)

func (*MostRecentForQueue) MarshalToSizedBuffer 

func (m *MostRecentForQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MostRecentForQueue) ProtoMessage 

func (*MostRecentForQueue) ProtoMessage()

func (*MostRecentForQueue) Reset 

func (m *MostRecentForQueue) Reset()

func (*MostRecentForQueue) Size 

func (m *MostRecentForQueue) Size() (n int)

func (*MostRecentForQueue) String 

func (m *MostRecentForQueue) String() string

func (*MostRecentForQueue) Unmarshal 

func (m *MostRecentForQueue) Unmarshal(dAtA []byte) error

func (*MostRecentForQueue) XXX_DiscardUnknown 

func (m *MostRecentForQueue) XXX_DiscardUnknown()

func (*MostRecentForQueue) XXX_Marshal 

func (m *MostRecentForQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MostRecentForQueue) XXX_Merge 

func (m *MostRecentForQueue) XXX_Merge(src proto.Message)

func (*MostRecentForQueue) XXX_Size 

func (m *MostRecentForQueue) XXX_Size() int

func (*MostRecentForQueue) XXX_Unmarshal 

func (m *MostRecentForQueue) XXX_Unmarshal(b []byte) error

type QueueReport 

type QueueReport struct {
	Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}

func (*QueueReport) Descriptor 

func (*QueueReport) Descriptor() ([]byte, []int)

func (*QueueReport) GetReport 

func (m *QueueReport) GetReport() string

func (*QueueReport) Marshal 

func (m *QueueReport) Marshal() (dAtA []byte, err error)

func (*QueueReport) MarshalTo 

func (m *QueueReport) MarshalTo(dAtA []byte) (int, error)

func (*QueueReport) MarshalToSizedBuffer 

func (m *QueueReport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueReport) ProtoMessage 

func (*QueueReport) ProtoMessage()

func (*QueueReport) Reset 

func (m *QueueReport) Reset()

func (*QueueReport) Size 

func (m *QueueReport) Size() (n int)

func (*QueueReport) String 

func (m *QueueReport) String() string

func (*QueueReport) Unmarshal 

func (m *QueueReport) Unmarshal(dAtA []byte) error

func (*QueueReport) XXX_DiscardUnknown 

func (m *QueueReport) XXX_DiscardUnknown()

func (*QueueReport) XXX_Marshal 

func (m *QueueReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueReport) XXX_Merge 

func (m *QueueReport) XXX_Merge(src proto.Message)

func (*QueueReport) XXX_Size 

func (m *QueueReport) XXX_Size() int

func (*QueueReport) XXX_Unmarshal 

func (m *QueueReport) XXX_Unmarshal(b []byte) error

type QueueReportRequest 

type QueueReportRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queueName,omitempty"`
	Verbosity int32  `protobuf:"varint,2,opt,name=verbosity,proto3" json:"verbosity,omitempty"`
}

func (*QueueReportRequest) Descriptor 

func (*QueueReportRequest) Descriptor() ([]byte, []int)

func (*QueueReportRequest) GetQueueName 

func (m *QueueReportRequest) GetQueueName() string

func (*QueueReportRequest) GetVerbosity 

func (m *QueueReportRequest) GetVerbosity() int32

func (*QueueReportRequest) Marshal 

func (m *QueueReportRequest) Marshal() (dAtA []byte, err error)

func (*QueueReportRequest) MarshalTo 

func (m *QueueReportRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueueReportRequest) MarshalToSizedBuffer 

func (m *QueueReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueReportRequest) ProtoMessage 

func (*QueueReportRequest) ProtoMessage()

func (*QueueReportRequest) Reset 

func (m *QueueReportRequest) Reset()

func (*QueueReportRequest) Size 

func (m *QueueReportRequest) Size() (n int)

func (*QueueReportRequest) String 

func (m *QueueReportRequest) String() string

func (*QueueReportRequest) Unmarshal 

func (m *QueueReportRequest) Unmarshal(dAtA []byte) error

func (*QueueReportRequest) XXX_DiscardUnknown 

func (m *QueueReportRequest) XXX_DiscardUnknown()

func (*QueueReportRequest) XXX_Marshal 

func (m *QueueReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueReportRequest) XXX_Merge 

func (m *QueueReportRequest) XXX_Merge(src proto.Message)

func (*QueueReportRequest) XXX_Size 

func (m *QueueReportRequest) XXX_Size() int

func (*QueueReportRequest) XXX_Unmarshal 

func (m *QueueReportRequest) XXX_Unmarshal(b []byte) error

type SchedulerReportingClient 

type SchedulerReportingClient interface {
	// Return the most recent scheduling report for each executor.
	GetSchedulingReport(ctx context.Context, in *SchedulingReportRequest, opts ...grpc.CallOption) (*SchedulingReport, error)
	// Return the most recent report scheduling for each executor for the given queue.
	GetQueueReport(ctx context.Context, in *QueueReportRequest, opts ...grpc.CallOption) (*QueueReport, error)
	// Return the most recent scheduling report for each executor for the given job.
	GetJobReport(ctx context.Context, in *JobReportRequest, opts ...grpc.CallOption) (*JobReport, error)
}

SchedulerReportingClient is the client API for SchedulerReporting service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchedulerReportingClient 

func NewSchedulerReportingClient(cc *grpc.ClientConn) SchedulerReportingClient

type SchedulerReportingServer 

type SchedulerReportingServer interface {
	// Return the most recent scheduling report for each executor.
	GetSchedulingReport(context.Context, *SchedulingReportRequest) (*SchedulingReport, error)
	// Return the most recent report scheduling for each executor for the given queue.
	GetQueueReport(context.Context, *QueueReportRequest) (*QueueReport, error)
	// Return the most recent scheduling report for each executor for the given job.
	GetJobReport(context.Context, *JobReportRequest) (*JobReport, error)
}

SchedulerReportingServer is the server API for SchedulerReporting service.

type SchedulingReport 

type SchedulingReport struct {
	Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}

func (*SchedulingReport) Descriptor 

func (*SchedulingReport) Descriptor() ([]byte, []int)

func (*SchedulingReport) GetReport 

func (m *SchedulingReport) GetReport() string

func (*SchedulingReport) Marshal 

func (m *SchedulingReport) Marshal() (dAtA []byte, err error)

func (*SchedulingReport) MarshalTo 

func (m *SchedulingReport) MarshalTo(dAtA []byte) (int, error)

func (*SchedulingReport) MarshalToSizedBuffer 

func (m *SchedulingReport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulingReport) ProtoMessage 

func (*SchedulingReport) ProtoMessage()

func (*SchedulingReport) Reset 

func (m *SchedulingReport) Reset()

func (*SchedulingReport) Size 

func (m *SchedulingReport) Size() (n int)

func (*SchedulingReport) String 

func (m *SchedulingReport) String() string

func (*SchedulingReport) Unmarshal 

func (m *SchedulingReport) Unmarshal(dAtA []byte) error

func (*SchedulingReport) XXX_DiscardUnknown 

func (m *SchedulingReport) XXX_DiscardUnknown()

func (*SchedulingReport) XXX_Marshal 

func (m *SchedulingReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingReport) XXX_Merge 

func (m *SchedulingReport) XXX_Merge(src proto.Message)

func (*SchedulingReport) XXX_Size 

func (m *SchedulingReport) XXX_Size() int

func (*SchedulingReport) XXX_Unmarshal 

func (m *SchedulingReport) XXX_Unmarshal(b []byte) error

type SchedulingReportRequest 

type SchedulingReportRequest struct {
	// Types that are valid to be assigned to Filter:
	//
	//	*SchedulingReportRequest_MostRecentForQueue
	//	*SchedulingReportRequest_MostRecentForJob
	Filter    isSchedulingReportRequest_Filter `protobuf_oneof:"filter"`
	Verbosity int32                            `protobuf:"varint,3,opt,name=verbosity,proto3" json:"verbosity,omitempty"`
}

func (*SchedulingReportRequest) Descriptor 

func (*SchedulingReportRequest) Descriptor() ([]byte, []int)

func (*SchedulingReportRequest) GetFilter 

func (m *SchedulingReportRequest) GetFilter() isSchedulingReportRequest_Filter

func (*SchedulingReportRequest) GetMostRecentForJob 

func (m *SchedulingReportRequest) GetMostRecentForJob() *MostRecentForJob

func (*SchedulingReportRequest) GetMostRecentForQueue 

func (m *SchedulingReportRequest) GetMostRecentForQueue() *MostRecentForQueue

func (*SchedulingReportRequest) GetVerbosity 

func (m *SchedulingReportRequest) GetVerbosity() int32

func (*SchedulingReportRequest) Marshal 

func (m *SchedulingReportRequest) Marshal() (dAtA []byte, err error)

func (*SchedulingReportRequest) MarshalTo 

func (m *SchedulingReportRequest) MarshalTo(dAtA []byte) (int, error)

func (*SchedulingReportRequest) MarshalToSizedBuffer 

func (m *SchedulingReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulingReportRequest) ProtoMessage 

func (*SchedulingReportRequest) ProtoMessage()

func (*SchedulingReportRequest) Reset 

func (m *SchedulingReportRequest) Reset()

func (*SchedulingReportRequest) Size 

func (m *SchedulingReportRequest) Size() (n int)

func (*SchedulingReportRequest) String 

func (m *SchedulingReportRequest) String() string

func (*SchedulingReportRequest) Unmarshal 

func (m *SchedulingReportRequest) Unmarshal(dAtA []byte) error

func (*SchedulingReportRequest) XXX_DiscardUnknown 

func (m *SchedulingReportRequest) XXX_DiscardUnknown()

func (*SchedulingReportRequest) XXX_Marshal 

func (m *SchedulingReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingReportRequest) XXX_Merge 

func (m *SchedulingReportRequest) XXX_Merge(src proto.Message)

func (*SchedulingReportRequest) XXX_OneofWrappers 

func (*SchedulingReportRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SchedulingReportRequest) XXX_Size 

func (m *SchedulingReportRequest) XXX_Size() int

func (*SchedulingReportRequest) XXX_Unmarshal 

func (m *SchedulingReportRequest) XXX_Unmarshal(b []byte) error

type SchedulingReportRequest_MostRecentForJob 

type SchedulingReportRequest_MostRecentForJob struct {
	MostRecentForJob *MostRecentForJob `protobuf:"bytes,2,opt,name=most_recent_for_job,json=mostRecentForJob,proto3,oneof" json:"mostRecentForJob,omitempty"`
}

func (*SchedulingReportRequest_MostRecentForJob) MarshalTo 

func (m *SchedulingReportRequest_MostRecentForJob) MarshalTo(dAtA []byte) (int, error)

func (*SchedulingReportRequest_MostRecentForJob) MarshalToSizedBuffer 

func (m *SchedulingReportRequest_MostRecentForJob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulingReportRequest_MostRecentForJob) Size 

func (m *SchedulingReportRequest_MostRecentForJob) Size() (n int)

type SchedulingReportRequest_MostRecentForQueue 

type SchedulingReportRequest_MostRecentForQueue struct {
	MostRecentForQueue *MostRecentForQueue `protobuf:"bytes,1,opt,name=most_recent_for_queue,json=mostRecentForQueue,proto3,oneof" json:"mostRecentForQueue,omitempty"`
}

func (*SchedulingReportRequest_MostRecentForQueue) MarshalTo 

func (m *SchedulingReportRequest_MostRecentForQueue) MarshalTo(dAtA []byte) (int, error)

func (*SchedulingReportRequest_MostRecentForQueue) MarshalToSizedBuffer 

func (m *SchedulingReportRequest_MostRecentForQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulingReportRequest_MostRecentForQueue) Size 

func (m *SchedulingReportRequest_MostRecentForQueue) Size() (n int)

type UnimplementedSchedulerReportingServer 

type UnimplementedSchedulerReportingServer struct {
}

UnimplementedSchedulerReportingServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerReportingServer) GetJobReport 

func (*UnimplementedSchedulerReportingServer) GetJobReport(ctx context.Context, req *JobReportRequest) (*JobReport, error)

func (*UnimplementedSchedulerReportingServer) GetQueueReport 

func (*UnimplementedSchedulerReportingServer) GetQueueReport(ctx context.Context, req *QueueReportRequest) (*QueueReport, error)

func (*UnimplementedSchedulerReportingServer) GetSchedulingReport 

func (*UnimplementedSchedulerReportingServer) GetSchedulingReport(ctx context.Context, req *SchedulingReportRequest) (*SchedulingReport, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.