Documentation ¶
Index ¶
- func CreateJob(jobRequest *pb.CreateJobRequest) (jobId string, err error)
- func DescribeJobs(jobRequest *pb.DescribeJobsRequest) (*pb.DescribeJobsResponse, error)
- func NewJobManagerClient(ctx context.Context) (pb.JobManagerClient, error)
- func SendJob(job *models.Job) (jobId string, err error)
- func WaitJob(jobId string, timeout time.Duration, waitInterval time.Duration) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DescribeJobs ¶
func DescribeJobs(jobRequest *pb.DescribeJobsRequest) (*pb.DescribeJobsResponse, error)
func NewJobManagerClient ¶
func NewJobManagerClient(ctx context.Context) (pb.JobManagerClient, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.