Documentation

Overview

Package apiservers implements gRPC APIs exposed by Scheduler service.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminServer

type AdminServer struct {
	internal.UnimplementedAdminServer

	Engine     engine.EngineInternal
	Catalog    catalog.Catalog
	AdminGroup string
}

AdminServer implements internal.admin.Admin API.

func (*AdminServer) GetDebugJobState

func (s *AdminServer) GetDebugJobState(ctx context.Context, r *schedulerpb.JobRef) (resp *internal.DebugJobState, err error)

GetDebugJobState implements the corresponding RPC method.

type SchedulerServer

type SchedulerServer struct {
	scheduler.UnimplementedSchedulerServer

	Engine  engine.Engine
	Catalog catalog.Catalog
}

SchedulerServer implements scheduler.Scheduler API.

func (*SchedulerServer) AbortInvocation

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

func (*SchedulerServer) AbortJob

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

func (*SchedulerServer) EmitTriggers

func (s *SchedulerServer) EmitTriggers(ctx context.Context, in *scheduler.EmitTriggersRequest) (*emptypb.Empty, error)

func (*SchedulerServer) GetInvocation

func (s *SchedulerServer) GetInvocation(ctx context.Context, in *scheduler.InvocationRef) (*scheduler.Invocation, 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) (*emptypb.Empty, error)

func (*SchedulerServer) ResumeJob

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