job

Documentation

Index

• type SchedulerServer
  • func (s *SchedulerServer) CanRunUserInitiatedJobs(_ context.Context, req *pb.CanRunUserInitiatedJobsRequest) (*pb.CanRunUserInitiatedJobsResponse, error)
  • func (s *SchedulerServer) Cancel(_ context.Context, req *pb.CancelRequest) (*pb.CancelResponse, error)
  • func (s *SchedulerServer) CancelAll(_ context.Context, req *pb.CancelAllRequest) (*pb.CancelAllResponse, error)
  • func (s *SchedulerServer) CancelInAllNamespaces(_ context.Context, req *pb.CancelInAllNamespacesRequest) (*pb.CancelInAllNamespacesResponse, error)
  • func (s *SchedulerServer) Enqueue(_ context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)
  • func (s *SchedulerServer) ForNamespace(_ context.Context, req *pb.ForNamespaceRequest) (*pb.ForNamespaceResponse, error)
  • func (s *SchedulerServer) GetAllPendingJobs(_ context.Context, req *pb.GetAllPendingJobsRequest) (*pb.GetAllPendingJobsResponse, error)
  • func (s *SchedulerServer) GetNamespace(_ context.Context, req *pb.GetNamespaceRequest) (*pb.GetNamespaceResponse, error)
  • func (s *SchedulerServer) GetPendingJob(_ context.Context, req *pb.GetPendingJobRequest) (*pb.GetPendingJobResponse, error)
  • func (s *SchedulerServer) GetPendingJobReason(_ context.Context, req *pb.GetPendingJobReasonRequest) (*pb.GetPendingJobReasonResponse, error)
  • func (s *SchedulerServer) GetPendingJobReasons(_ context.Context, req *pb.GetPendingJobReasonsRequest) (*pb.GetPendingJobReasonsResponse, error)
  • func (s *SchedulerServer) GetPendingJobReasonsHistory(_ context.Context, req *pb.GetPendingJobReasonsHistoryRequest) (*pb.GetPendingJobReasonsHistoryResponse, error)
  • func (s *SchedulerServer) Schedule(_ context.Context, req *pb.ScheduleRequest) (*pb.ScheduleResponse, error)

Types

type SchedulerServer

type SchedulerServer struct {
	pb.UnimplementedSchedulerServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

SchedulerServer implements pb.SchedulerServiceServer.

func (*SchedulerServer) CanRunUserInitiatedJobs

func (s *SchedulerServer) CanRunUserInitiatedJobs(_ context.Context, req *pb.CanRunUserInitiatedJobsRequest) (*pb.CanRunUserInitiatedJobsResponse, error)

func (*SchedulerServer) Cancel

func (s *SchedulerServer) Cancel(_ context.Context, req *pb.CancelRequest) (*pb.CancelResponse, error)

func (*SchedulerServer) CancelAll

func (s *SchedulerServer) CancelAll(_ context.Context, req *pb.CancelAllRequest) (*pb.CancelAllResponse, error)

func (*SchedulerServer) CancelInAllNamespaces

func (s *SchedulerServer) CancelInAllNamespaces(_ context.Context, req *pb.CancelInAllNamespacesRequest) (*pb.CancelInAllNamespacesResponse, error)

func (*SchedulerServer) Enqueue

func (s *SchedulerServer) Enqueue(_ context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)

func (*SchedulerServer) ForNamespace

func (s *SchedulerServer) ForNamespace(_ context.Context, req *pb.ForNamespaceRequest) (*pb.ForNamespaceResponse, error)

func (*SchedulerServer) GetAllPendingJobs

func (s *SchedulerServer) GetAllPendingJobs(_ context.Context, req *pb.GetAllPendingJobsRequest) (*pb.GetAllPendingJobsResponse, error)

func (*SchedulerServer) GetNamespace

func (s *SchedulerServer) GetNamespace(_ context.Context, req *pb.GetNamespaceRequest) (*pb.GetNamespaceResponse, error)

func (*SchedulerServer) GetPendingJob

func (s *SchedulerServer) GetPendingJob(_ context.Context, req *pb.GetPendingJobRequest) (*pb.GetPendingJobResponse, error)

func (*SchedulerServer) GetPendingJobReason

func (s *SchedulerServer) GetPendingJobReason(_ context.Context, req *pb.GetPendingJobReasonRequest) (*pb.GetPendingJobReasonResponse, error)

func (*SchedulerServer) GetPendingJobReasons

func (s *SchedulerServer) GetPendingJobReasons(_ context.Context, req *pb.GetPendingJobReasonsRequest) (*pb.GetPendingJobReasonsResponse, error)

func (*SchedulerServer) GetPendingJobReasonsHistory

func (s *SchedulerServer) GetPendingJobReasonsHistory(_ context.Context, req *pb.GetPendingJobReasonsHistoryRequest) (*pb.GetPendingJobReasonsHistoryResponse, error)

func (*SchedulerServer) Schedule

func (s *SchedulerServer) Schedule(_ context.Context, req *pb.ScheduleRequest) (*pb.ScheduleResponse, error)