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) (*empty.Empty, error)

          func (*SchedulerServer) AbortJob

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

          func (*SchedulerServer) EmitTriggers

          func (s *SchedulerServer) EmitTriggers(ctx context.Context, in *scheduler.EmitTriggersRequest) (*empty.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) (*empty.Empty, error)

            func (*SchedulerServer) ResumeJob

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