apiservers

Documentation

Overview

Package apiservers implements gRPC APIs exposed by Scheduler service.

Index

• type AdminServer
  • func (s *AdminServer) GetDebugJobState(ctx context.Context, r *schedulerpb.JobRef) (resp *internal.DebugJobState, err error)
• type SchedulerServer
  • func (s *SchedulerServer) AbortInvocation(ctx context.Context, in *scheduler.InvocationRef) (*emptypb.Empty, error)
  • func (s *SchedulerServer) AbortJob(ctx context.Context, in *scheduler.JobRef) (*emptypb.Empty, error)
  • func (s *SchedulerServer) EmitTriggers(ctx context.Context, in *scheduler.EmitTriggersRequest) (*emptypb.Empty, error)
  • func (s *SchedulerServer) GetInvocation(ctx context.Context, in *scheduler.InvocationRef) (*scheduler.Invocation, 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) (*emptypb.Empty, error)
  • func (s *SchedulerServer) ResumeJob(ctx context.Context, in *scheduler.JobRef) (*emptypb.Empty, error)

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)