batch

package

Go to main page

Versions in this module

v1

v1.8.5

May 1, 2024

v1.8.4

Apr 15, 2024

v1.8.3

Mar 14, 2024

v1.8.2

Mar 4, 2024

v1.8.1

Feb 21, 2024

v1.8.0

Jan 30, 2024

v1.7.0

Nov 27, 2023

v1.6.3

Nov 1, 2023

v1.6.2

Oct 31, 2023

v1.6.1

Oct 26, 2023

v1.6.0

Oct 17, 2023

v1.5.1

Oct 12, 2023

v1.5.0

Oct 4, 2023

v1.4.1

Sep 11, 2023

v1.4.0

Aug 8, 2023

v1.3.1

Jul 10, 2023

v1.3.0

Jun 20, 2023

v1.2.0

May 30, 2023

v1.1.0

May 16, 2023

v1.0.1

May 8, 2023

v1.0.0

Apr 4, 2023

Changes in this version

+ type IamPolicyCallOptions struct

+ CancelOperation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ type IamPolicyClient struct

+ CallOptions *IamPolicyCallOptions

+ func NewIamPolicyClient(ctx context.Context, opts ...option.ClientOption) (*IamPolicyClient, error)

+ func NewIamPolicyRESTClient(ctx context.Context, opts ...option.ClientOption) (*IamPolicyClient, error)

+ func (c *IamPolicyClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *IamPolicyClient) Close() error

+ func (c *IamPolicyClient) Connection() *grpc.ClientConn

+ func (c *IamPolicyClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *IamPolicyClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *IamPolicyClient) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, ...) (*locationpb.Location, error)

+ func (c *IamPolicyClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *IamPolicyClient) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, ...) *LocationIterator

+ func (c *IamPolicyClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *IamPolicyClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *IamPolicyClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

v0

v0.7.0

Feb 14, 2023

v0.6.0

Jan 5, 2023

Changes in this version

type Client

+ func NewRESTClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

v0.5.0

Dec 1, 2022

v0.4.1

Nov 16, 2022

v0.4.0

Nov 3, 2022

v0.3.0

Oct 25, 2022

v0.2.1

Sep 9, 2022

v0.2.0

Sep 6, 2022

Changes in this version

type CallOptions

+ CancelOperation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

type Client

+ func (c *Client) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *Client) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *Client) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *Client) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, ...) (*locationpb.Location, error)

+ func (c *Client) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *Client) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, ...) *LocationIterator

+ func (c *Client) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *Client) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *Client) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ type LocationIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*locationpb.Location, nextPageToken string, err error)

+ Response interface{}

+ func (it *LocationIterator) Next() (*locationpb.Location, error)

+ func (it *LocationIterator) PageInfo() *iterator.PageInfo

+ type OperationIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*longrunningpb.Operation, nextPageToken string, err error)

+ Response interface{}

+ func (it *OperationIterator) Next() (*longrunningpb.Operation, error)

+ func (it *OperationIterator) PageInfo() *iterator.PageInfo

v0.1.0

Jun 16, 2022

Changes in this version

+ func DefaultAuthScopes() []string

+ type CallOptions struct

+ CreateJob []gax.CallOption

+ DeleteJob []gax.CallOption

+ GetJob []gax.CallOption

+ GetTask []gax.CallOption

+ ListJobs []gax.CallOption

+ ListTasks []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

+ LROClient *lroauto.OperationsClient

+ func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Connection() *grpc.ClientConn

+ func (c *Client) CreateJob(ctx context.Context, req *batchpb.CreateJobRequest, opts ...gax.CallOption) (*batchpb.Job, error)

+ func (c *Client) DeleteJob(ctx context.Context, req *batchpb.DeleteJobRequest, opts ...gax.CallOption) (*DeleteJobOperation, error)

+ func (c *Client) DeleteJobOperation(name string) *DeleteJobOperation

+ func (c *Client) GetJob(ctx context.Context, req *batchpb.GetJobRequest, opts ...gax.CallOption) (*batchpb.Job, error)

+ func (c *Client) GetTask(ctx context.Context, req *batchpb.GetTaskRequest, opts ...gax.CallOption) (*batchpb.Task, error)

+ func (c *Client) ListJobs(ctx context.Context, req *batchpb.ListJobsRequest, opts ...gax.CallOption) *JobIterator

+ func (c *Client) ListTasks(ctx context.Context, req *batchpb.ListTasksRequest, opts ...gax.CallOption) *TaskIterator

+ type DeleteJobOperation struct

+ func (op *DeleteJobOperation) Done() bool

+ func (op *DeleteJobOperation) Metadata() (*batchpb.OperationMetadata, error)

+ func (op *DeleteJobOperation) Name() string

+ func (op *DeleteJobOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteJobOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type JobIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*batchpb.Job, nextPageToken string, err error)

+ Response interface{}

+ func (it *JobIterator) Next() (*batchpb.Job, error)

+ func (it *JobIterator) PageInfo() *iterator.PageInfo

+ type TaskIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*batchpb.Task, nextPageToken string, err error)

+ Response interface{}

+ func (it *TaskIterator) Next() (*batchpb.Task, error)

+ func (it *TaskIterator) PageInfo() *iterator.PageInfo

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