job

Documentation

Index

• type JobSchedulerServer
  • func (s *JobSchedulerServer) CanRunUserInitiatedJobs(_ context.Context, req *pb.CanRunUserInitiatedJobsRequest) (*pb.CanRunUserInitiatedJobsResponse, error)
  • func (s *JobSchedulerServer) CancelInAllNamespaces(_ context.Context, req *pb.CancelInAllNamespacesRequest) (*pb.CancelInAllNamespacesResponse, error)
  • func (s *JobSchedulerServer) ForNamespace(_ context.Context, req *pb.ForNamespaceRequest) (*pb.ForNamespaceResponse, error)
  • func (s *JobSchedulerServer) GetNamespace(_ context.Context, req *pb.GetNamespaceRequest) (*pb.GetNamespaceResponse, error)
  • func (s *JobSchedulerServer) GetPendingJobReason(_ context.Context, req *pb.GetPendingJobReasonRequest) (*pb.GetPendingJobReasonResponse, error)
  • func (s *JobSchedulerServer) GetPendingJobReasons(_ context.Context, req *pb.GetPendingJobReasonsRequest) (*pb.GetPendingJobReasonsResponse, error)
  • func (s *JobSchedulerServer) GetPendingJobReasonsHistory(_ context.Context, req *pb.GetPendingJobReasonsHistoryRequest) (*pb.GetPendingJobReasonsHistoryResponse, error)

Types

type JobSchedulerServer

type JobSchedulerServer struct {
	pb.UnimplementedJobSchedulerServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

JobSchedulerServer implements pb.JobSchedulerServiceServer.

func (*JobSchedulerServer) CanRunUserInitiatedJobs

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

func (*JobSchedulerServer) CancelInAllNamespaces

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

func (*JobSchedulerServer) ForNamespace

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

func (*JobSchedulerServer) GetNamespace

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

func (*JobSchedulerServer) GetPendingJobReason

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

func (*JobSchedulerServer) GetPendingJobReasons

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

func (*JobSchedulerServer) GetPendingJobReasonsHistory

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