batchv1sdk

Documentation

Index

• type BatchEventPubsubService
  • func (x *BatchEventPubsubService) PushPubsubMessage(ctx context.Context, r *pubsubv1.PushPubsubMessageRequest) (*pubsubv1.PushPubsubMessageResponse, error)
• type BatchJobIterator
  • func (x *BatchJobIterator) Next() (*batchpb.Job, error)
  • func (x *BatchJobIterator) PageInfo() batchv1.BatchPageInfo
• type BatchPageInfo
  • func (x *BatchPageInfo) MaxSize() int
  • func (x *BatchPageInfo) Remaining() int
  • func (x *BatchPageInfo) Token() string
• type BatchServiceClient
  • func NewBatchServiceClient(ctx context.Context, options ...option.ClientOption) (*BatchServiceClient, error)
  • func (x *BatchServiceClient) CancelOperation(ctx context.Context, r *longrunningpb.CancelOperationRequest, ...) error
  • func (x *BatchServiceClient) CreateJob(ctx context.Context, r *batchpb.CreateJobRequest, opts ...gax.CallOption) (*batchpb.Job, error)
  • func (x *BatchServiceClient) DeleteJob(ctx context.Context, r *batchpb.DeleteJobRequest, opts ...gax.CallOption) (batchv1.DeleteBatchJobOperation, error)
  • func (x *BatchServiceClient) DeleteJobOperation(name string) batchv1.DeleteBatchJobOperation
  • func (x *BatchServiceClient) DeleteOperation(ctx context.Context, r *longrunningpb.DeleteOperationRequest, ...) error
  • func (x *BatchServiceClient) GetJob(ctx context.Context, r *batchpb.GetJobRequest, opts ...gax.CallOption) (*batchpb.Job, error)
  • func (x *BatchServiceClient) GetTask(ctx context.Context, r *batchpb.GetTaskRequest, opts ...gax.CallOption) (*batchpb.Task, error)
  • func (x *BatchServiceClient) ListJobs(ctx context.Context, r *batchpb.ListJobsRequest, opts ...gax.CallOption) batchv1.BatchJobIterator
  • func (x *BatchServiceClient) ListTasks(ctx context.Context, r *batchpb.ListTasksRequest, opts ...gax.CallOption) batchv1.BatchTaskIterator
• type BatchTaskIterator
  • func (x *BatchTaskIterator) Next() (*batchpb.Task, error)
  • func (x *BatchTaskIterator) PageInfo() batchv1.BatchPageInfo

Types

type BatchEventPubsubService

type BatchEventPubsubService struct {
	// BatchJobEventHandler is a batch job event handler.
	BatchJobEventHandler batchv1.BatchJobEventHandler
	// BatchTaskEventHandler is a batch task event handler.
	BatchTaskEventHandler batchv1.BatchTaskEventHandler
}

BatchEventPubsubService represents a batch pubsub service.

func (*BatchEventPubsubService) PushPubsubMessage

func (x *BatchEventPubsubService) PushPubsubMessage(ctx context.Context, r *pubsubv1.PushPubsubMessageRequest) (*pubsubv1.PushPubsubMessageResponse, error)

PushPubsubMessage implements pubsubv1.PubsubService.

type BatchJobIterator

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

BatchJobIterator is a wrapper around batch.JobIterator.

func (*BatchJobIterator) Next

func (x *BatchJobIterator) Next() (*batchpb.Job, error)

Next implements cdk.BatchJobIterator.

func (*BatchJobIterator) PageInfo

func (x *BatchJobIterator) PageInfo() batchv1.BatchPageInfo

PageInfo implements cdk.BatchJobIterator.

type BatchPageInfo

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

BatchPageInfo is a wrapper around batch.PageInfo.

func (*BatchPageInfo) MaxSize

func (x *BatchPageInfo) MaxSize() int

MaxSize implements batchv1.BatchPageInfo.

func (*BatchPageInfo) Remaining

func (x *BatchPageInfo) Remaining() int

Remaining implements batchv1.BatchPageInfo.

func (*BatchPageInfo) Token

func (x *BatchPageInfo) Token() string

Token implements batchv1.BatchPageInfo.

type BatchServiceClient

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

BatchServiceClient is a client for interacting with Connect Batch API.

func NewBatchServiceClient

func NewBatchServiceClient(ctx context.Context, options ...option.ClientOption) (*BatchServiceClient, error)

NewBatchServiceClient creates a new BatchServiceClient.

func (*BatchServiceClient) CancelOperation

func (x *BatchServiceClient) CancelOperation(ctx context.Context, r *longrunningpb.CancelOperationRequest, opts ...gax.CallOption) error

CancelOperation implements batchv1.BatchServiceClient.

func (*BatchServiceClient) CreateJob

func (x *BatchServiceClient) CreateJob(ctx context.Context, r *batchpb.CreateJobRequest, opts ...gax.CallOption) (*batchpb.Job, error)

CreateJob implements batchv1.BatchServiceClient.

func (*BatchServiceClient) DeleteJob

func (x *BatchServiceClient) DeleteJob(ctx context.Context, r *batchpb.DeleteJobRequest, opts ...gax.CallOption) (batchv1.DeleteBatchJobOperation, error)

DeleteJob implements batchv1.BatchServiceClient.

func (*BatchServiceClient) DeleteJobOperation

func (x *BatchServiceClient) DeleteJobOperation(name string) batchv1.DeleteBatchJobOperation

DeleteJobOperation implements batchv1.BatchServiceClient.

func (*BatchServiceClient) DeleteOperation

func (x *BatchServiceClient) DeleteOperation(ctx context.Context, r *longrunningpb.DeleteOperationRequest, opts ...gax.CallOption) error

DeleteOperation implements batchv1.BatchServiceClient.

func (*BatchServiceClient) GetJob

func (x *BatchServiceClient) GetJob(ctx context.Context, r *batchpb.GetJobRequest, opts ...gax.CallOption) (*batchpb.Job, error)

GetJob implements batchv1.BatchServiceClient.

func (*BatchServiceClient) GetTask

func (x *BatchServiceClient) GetTask(ctx context.Context, r *batchpb.GetTaskRequest, opts ...gax.CallOption) (*batchpb.Task, error)

GetTask implements batchv1.BatchServiceClient.

func (*BatchServiceClient) ListJobs

func (x *BatchServiceClient) ListJobs(ctx context.Context, r *batchpb.ListJobsRequest, opts ...gax.CallOption) batchv1.BatchJobIterator

ListJobs implements batchv1.BatchServiceClient.

func (*BatchServiceClient) ListTasks

func (x *BatchServiceClient) ListTasks(ctx context.Context, r *batchpb.ListTasksRequest, opts ...gax.CallOption) batchv1.BatchTaskIterator

ListTasks implements batchv1.BatchServiceClient.

type BatchTaskIterator

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

BatchTaskIterator is a wrapper around batch.TaskIterator.

func (*BatchTaskIterator) Next

func (x *BatchTaskIterator) Next() (*batchpb.Task, error)

Next implements cdk.BatchTaskIterator.

func (*BatchTaskIterator) PageInfo

func (x *BatchTaskIterator) PageInfo() batchv1.BatchPageInfo

PageInfo implements cdk.BatchTaskIterator.