apiservers

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)

Types

type SchedulerServer

type SchedulerServer struct {
	Engine  engine.Engine
	Catalog catalog.Catalog
}

SchedulerServer implements scheduler.Scheduler API.

func (SchedulerServer) AbortInvocation

func (s SchedulerServer) AbortInvocation(ctx context.Context, in *scheduler.InvocationRef) (
	*empty.Empty, error)

func (SchedulerServer) AbortJob

func (s SchedulerServer) AbortJob(ctx context.Context, in *scheduler.JobRef) (*empty.Empty, error)

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

func (s SchedulerServer) PauseJob(ctx context.Context, in *scheduler.JobRef) (*empty.Empty, error)

func (SchedulerServer) ResumeJob

func (s SchedulerServer) ResumeJob(ctx context.Context, in *scheduler.JobRef) (*empty.Empty, error)