apiservers

package
Version: v0.0.0-...-51f9457 Latest Latest
Warning

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

Go to latest
Published: Jul 9, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL