Documentation ¶
Overview ¶
Package apiservers implements gRPC APIs exposed by Scheduler service.
Index ¶
- type SchedulerServer
- func (s SchedulerServer) AbortInvocation(ctx context.Context, in *scheduler.InvocationRef) (*empty.Empty, error)
- func (s SchedulerServer) AbortJob(ctx context.Context, in *scheduler.JobRef) (*empty.Empty, error)
- func (s SchedulerServer) GetInvocations(ctx context.Context, in *scheduler.InvocationsRequest) (*scheduler.InvocationsReply, error)
- func (s SchedulerServer) GetJobs(ctx context.Context, in *scheduler.JobsRequest) (*scheduler.JobsReply, error)
- func (s SchedulerServer) PauseJob(ctx context.Context, in *scheduler.JobRef) (*empty.Empty, error)
- func (s SchedulerServer) ResumeJob(ctx context.Context, in *scheduler.JobRef) (*empty.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SchedulerServer ¶
SchedulerServer implements scheduler.Scheduler API.
func (SchedulerServer) AbortInvocation ¶
func (SchedulerServer) AbortJob ¶
func (SchedulerServer) GetInvocations ¶
func (s SchedulerServer) GetInvocations(ctx context.Context, in *scheduler.InvocationsRequest) (*scheduler.InvocationsReply, error)
func (SchedulerServer) GetJobs ¶
func (s SchedulerServer) GetJobs(ctx context.Context, in *scheduler.JobsRequest) (*scheduler.JobsReply, error)
GetJobs fetches all jobs satisfying JobsRequest and visibility ACLs.
func (SchedulerServer) PauseJob ¶
Click to show internal directories.
Click to hide internal directories.