job

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2026 License: CC0-1.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PendingJobReasonsInfoServer added in v0.0.6 

type PendingJobReasonsInfoServer struct {
	pb.UnimplementedPendingJobReasonsInfoServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

PendingJobReasonsInfoServer implements pb.PendingJobReasonsInfoServiceServer.

func (*PendingJobReasonsInfoServer) DescribeContents added in v0.0.6 

func (s *PendingJobReasonsInfoServer) DescribeContents(_ context.Context, req *pb.DescribeContentsRequest) (*pb.DescribeContentsResponse, error)

func (*PendingJobReasonsInfoServer) GetPendingJobReasons added in v0.0.6 

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

func (*PendingJobReasonsInfoServer) GetTimestampMillis added in v0.0.6 

func (s *PendingJobReasonsInfoServer) GetTimestampMillis(_ context.Context, req *pb.GetTimestampMillisRequest) (*pb.GetTimestampMillisResponse, error)

func (*PendingJobReasonsInfoServer) NewPendingJobReasonsInfo added in v0.0.6 

func (s *PendingJobReasonsInfoServer) NewPendingJobReasonsInfo(_ context.Context, req *pb.NewPendingJobReasonsInfoRequest) (*pb.NewPendingJobReasonsInfoResponse, error)

func (*PendingJobReasonsInfoServer) WriteToParcel added in v0.0.6 

func (s *PendingJobReasonsInfoServer) WriteToParcel(_ context.Context, req *pb.WriteToParcelRequest) (*pb.WriteToParcelResponse, error)

type SchedulerServer added in v0.0.4 

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

SchedulerServer implements pb.SchedulerServiceServer.

func (*SchedulerServer) CanRunUserInitiatedJobs added in v0.0.4 

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

func (*SchedulerServer) Cancel added in v0.0.4 

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

func (*SchedulerServer) CancelAll added in v0.0.4 

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

func (*SchedulerServer) CancelInAllNamespaces added in v0.0.4 

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

func (*SchedulerServer) Enqueue added in v0.0.4 

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

func (*SchedulerServer) ForNamespace added in v0.0.4 

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

func (*SchedulerServer) GetAllPendingJobs added in v0.0.4 

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

func (*SchedulerServer) GetNamespace added in v0.0.4 

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

func (*SchedulerServer) GetPendingJob added in v0.0.4 

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

func (*SchedulerServer) GetPendingJobReason added in v0.0.4 

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

func (*SchedulerServer) GetPendingJobReasons added in v0.0.4 

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

func (*SchedulerServer) GetPendingJobReasonsHistory added in v0.0.4 

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

func (*SchedulerServer) Schedule added in v0.0.4 

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

type WorkItemServer added in v0.0.6 

type WorkItemServer struct {
	pb.UnimplementedWorkItemServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

WorkItemServer implements pb.WorkItemServiceServer.

func (*WorkItemServer) DescribeContents added in v0.0.6 

func (s *WorkItemServer) DescribeContents(_ context.Context, req *pb.DescribeContentsRequest) (*pb.DescribeContentsResponse, error)

func (*WorkItemServer) GetDeliveryCount added in v0.0.6 

func (s *WorkItemServer) GetDeliveryCount(_ context.Context, req *pb.GetDeliveryCountRequest) (*pb.GetDeliveryCountResponse, error)

func (*WorkItemServer) GetEstimatedNetworkDownloadBytes added in v0.0.6 

func (s *WorkItemServer) GetEstimatedNetworkDownloadBytes(_ context.Context, req *pb.GetEstimatedNetworkDownloadBytesRequest) (*pb.GetEstimatedNetworkDownloadBytesResponse, error)

func (*WorkItemServer) GetEstimatedNetworkUploadBytes added in v0.0.6 

func (s *WorkItemServer) GetEstimatedNetworkUploadBytes(_ context.Context, req *pb.GetEstimatedNetworkUploadBytesRequest) (*pb.GetEstimatedNetworkUploadBytesResponse, error)

func (*WorkItemServer) GetExtras added in v0.0.6 

func (s *WorkItemServer) GetExtras(_ context.Context, req *pb.GetExtrasRequest) (*pb.GetExtrasResponse, error)

func (*WorkItemServer) GetIntent added in v0.0.6 

func (s *WorkItemServer) GetIntent(_ context.Context, req *pb.GetIntentRequest) (*pb.GetIntentResponse, error)

func (*WorkItemServer) GetMinimumNetworkChunkBytes added in v0.0.6 

func (s *WorkItemServer) GetMinimumNetworkChunkBytes(_ context.Context, req *pb.GetMinimumNetworkChunkBytesRequest) (*pb.GetMinimumNetworkChunkBytesResponse, error)

func (*WorkItemServer) NewWorkItem added in v0.0.6 

func (s *WorkItemServer) NewWorkItem(_ context.Context, req *pb.NewWorkItemRequest) (*pb.NewWorkItemResponse, error)

func (*WorkItemServer) ToString added in v0.0.6 

func (s *WorkItemServer) ToString(_ context.Context, req *pb.ToStringRequest) (*pb.ToStringResponse, error)

func (*WorkItemServer) WriteToParcel added in v0.0.6 

func (s *WorkItemServer) WriteToParcel(_ context.Context, req *pb.WriteToParcelRequest) (*pb.WriteToParcelResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.