job

package
v10.1.1 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Provider

type Provider interface {
	// UpdateJobState updates an existing job
	// Only acceptable values are
	// JobState_PAUSED - acceptable only from running state
	// JobState_CANCELLED - acceptable only from running/pause state
	// JobState_RUNNING - acceptable only from pause state
	UpdateJobState(ctx context.Context, in *api.SdkUpdateJobRequest) (*api.SdkUpdateJobResponse, error)
	// GetJobStatus gets the status of a job
	GetJobStatus(ctx context.Context, in *api.SdkGetJobStatusRequest) (*api.SdkGetJobStatusResponse, error)
	// EnumerateJobs returns all the jobs currently known to the system
	EnumerateJobs(ctx context.Context, in *api.SdkEnumerateJobsRequest) (*api.SdkEnumerateJobsResponse, error)
}

Provider implements the APIs for executing and querying asynchronous jobs

func NewDefaultJobProvider

func NewDefaultJobProvider() Provider

NewDefaultJobProvider does not support asynchronous jobs

type UnsupportedJobProvider

type UnsupportedJobProvider struct {
}

UnsupportedJobProvider unsupported implementation of jobs APIs

func (*UnsupportedJobProvider) EnumerateJobs

func (*UnsupportedJobProvider) GetJobStatus

func (*UnsupportedJobProvider) UpdateJobState

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL