job

Documentation

Index

• type Client
  • func NewClient(cc grpc.ClientConnInterface) *Client
  • func (c *Client) CanRunUserInitiatedJobs(ctx context.Context) (bool, error)
  • func (c *Client) Cancel(ctx context.Context, arg0 int32) error
  • func (c *Client) CancelAll(ctx context.Context) error
  • func (c *Client) CancelInAllNamespaces(ctx context.Context) error
  • func (c *Client) Enqueue(ctx context.Context, arg0 int64, arg1 int64) (int32, error)
  • func (c *Client) ForNamespace(ctx context.Context, arg0 string) (int64, error)
  • func (c *Client) GetAllPendingJobs(ctx context.Context) (int64, error)
  • func (c *Client) GetNamespace(ctx context.Context) (string, error)
  • func (c *Client) GetPendingJob(ctx context.Context, arg0 int32) (int64, error)
  • func (c *Client) GetPendingJobReason(ctx context.Context, arg0 int32) (int32, error)
  • func (c *Client) GetPendingJobReasons(ctx context.Context, arg0 int32) (int64, error)
  • func (c *Client) GetPendingJobReasonsHistory(ctx context.Context, arg0 int32) (int64, error)
  • func (c *Client) Schedule(ctx context.Context, arg0 int64) (int32, error)

Types

type Client

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

Client wraps the gRPC SchedulerService client.

func NewClient

func NewClient(cc grpc.ClientConnInterface) *Client

NewClient creates a new job client.

func (*Client) CanRunUserInitiatedJobs

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

CanRunUserInitiatedJobs calls the CanRunUserInitiatedJobs RPC.

func (*Client) Cancel

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

Cancel calls the Cancel RPC.

func (*Client) CancelAll

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

CancelAll calls the CancelAll RPC.

func (*Client) CancelInAllNamespaces

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

CancelInAllNamespaces calls the CancelInAllNamespaces RPC.

func (*Client) Enqueue

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

Enqueue calls the Enqueue RPC.

func (*Client) ForNamespace

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

ForNamespace calls the ForNamespace RPC.

func (*Client) GetAllPendingJobs

func (c *Client) GetAllPendingJobs(ctx context.Context) (int64, error)

GetAllPendingJobs calls the GetAllPendingJobs RPC.

func (*Client) GetNamespace

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

GetNamespace calls the GetNamespace RPC.

func (*Client) GetPendingJob

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

GetPendingJob calls the GetPendingJob RPC.

func (*Client) GetPendingJobReason

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

GetPendingJobReason calls the GetPendingJobReason RPC.

func (*Client) GetPendingJobReasons

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

GetPendingJobReasons calls the GetPendingJobReasons RPC.

func (*Client) GetPendingJobReasonsHistory

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

GetPendingJobReasonsHistory calls the GetPendingJobReasonsHistory RPC.

func (*Client) Schedule

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

Schedule calls the Schedule RPC.