job

package

v0.0.3 Latest Latest Go to latest Published: Mar 16, 2026 License: CC0-1.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	// contains filtered or unexported fields
}

Client wraps the gRPC JobSchedulerService client.

func NewClient(cc grpc.ClientConnInterface) *Client

NewClient creates a new job client.

func (c *Client) CanRunUserInitiatedJobs(ctx context.Context) (bool, error)

CanRunUserInitiatedJobs calls the CanRunUserInitiatedJobs RPC.

func (c *Client) CancelInAllNamespaces(ctx context.Context) error

CancelInAllNamespaces calls the CancelInAllNamespaces RPC.

func (c *Client) ForNamespace(ctx context.Context, arg0 string) (int64, error)

ForNamespace calls the ForNamespace RPC.

func (c *Client) GetNamespace(ctx context.Context) (string, error)

GetNamespace calls the GetNamespace RPC.

func (c *Client) GetPendingJobReason(ctx context.Context, arg0 int32) (int32, error)

GetPendingJobReason calls the GetPendingJobReason RPC.

func (c *Client) GetPendingJobReasons(ctx context.Context, arg0 int32) (int64, error)

GetPendingJobReasons calls the GetPendingJobReasons RPC.

func (c *Client) GetPendingJobReasonsHistory(ctx context.Context, arg0 int32) (int64, error)

GetPendingJobReasonsHistory calls the GetPendingJobReasonsHistory RPC.