run

package

Go to main page

Versions in this module

v1

v1.3.7

May 1, 2024

v1.3.6

Mar 14, 2024

v1.3.5

Mar 7, 2024

v1.3.4

Jan 30, 2024

v1.3.3

Nov 1, 2023

v1.3.2

Oct 26, 2023

v1.3.1

Oct 12, 2023

v1.3.0

Oct 4, 2023

Changes in this version

+ type CancelExecutionOperation struct

+ func (op *CancelExecutionOperation) Done() bool

+ func (op *CancelExecutionOperation) Metadata() (*runpb.Execution, error)

+ func (op *CancelExecutionOperation) Name() string

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

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

type ExecutionsCallOptions

+ CancelExecution []gax.CallOption

type ExecutionsClient

+ func (c *ExecutionsClient) CancelExecution(ctx context.Context, req *runpb.CancelExecutionRequest, opts ...gax.CallOption) (*CancelExecutionOperation, error)

+ func (c *ExecutionsClient) CancelExecutionOperation(name string) *CancelExecutionOperation

v1.2.0

Jul 10, 2023

v1.1.1

Jun 20, 2023

v1.1.0

May 30, 2023

v1.0.1

May 8, 2023

v1.0.0

Apr 4, 2023

v0

v0.9.0

Mar 15, 2023

Changes in this version

+ 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 LocationsCallOptions struct

+ DeleteOperation []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ WaitOperation []gax.CallOption

+ type LocationsClient struct

+ CallOptions *LocationsCallOptions

+ func NewLocationsClient(ctx context.Context, opts ...option.ClientOption) (*LocationsClient, error)

+ func NewLocationsRESTClient(ctx context.Context, opts ...option.ClientOption) (*LocationsClient, error)

+ func (c *LocationsClient) Close() error

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

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

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

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

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

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

+ func (c *LocationsClient) WaitOperation(ctx context.Context, req *longrunningpb.WaitOperationRequest, ...) (*longrunningpb.Operation, error)

v0.8.0

Jan 26, 2023

Changes in this version

type ExecutionsCallOptions

+ WaitOperation []gax.CallOption

type ExecutionsClient

+ func (c *ExecutionsClient) WaitOperation(ctx context.Context, req *longrunningpb.WaitOperationRequest, ...) (*longrunningpb.Operation, error)

type JobsCallOptions

+ WaitOperation []gax.CallOption

type JobsClient

+ func (c *JobsClient) WaitOperation(ctx context.Context, req *longrunningpb.WaitOperationRequest, ...) (*longrunningpb.Operation, error)

type RevisionsCallOptions

+ WaitOperation []gax.CallOption

type RevisionsClient

+ func (c *RevisionsClient) WaitOperation(ctx context.Context, req *longrunningpb.WaitOperationRequest, ...) (*longrunningpb.Operation, error)

type ServicesCallOptions

+ WaitOperation []gax.CallOption

type ServicesClient

+ func (c *ServicesClient) WaitOperation(ctx context.Context, req *longrunningpb.WaitOperationRequest, ...) (*longrunningpb.Operation, error)

type TasksCallOptions

+ WaitOperation []gax.CallOption

type TasksClient

+ func (c *TasksClient) WaitOperation(ctx context.Context, req *longrunningpb.WaitOperationRequest, ...) (*longrunningpb.Operation, error)

v0.5.0

Jan 5, 2023

Changes in this version

type ExecutionsClient

+ func NewExecutionsRESTClient(ctx context.Context, opts ...option.ClientOption) (*ExecutionsClient, error)

type JobsClient

+ func NewJobsRESTClient(ctx context.Context, opts ...option.ClientOption) (*JobsClient, error)

type RevisionsClient

+ func NewRevisionsRESTClient(ctx context.Context, opts ...option.ClientOption) (*RevisionsClient, error)

type ServicesClient

+ func NewServicesRESTClient(ctx context.Context, opts ...option.ClientOption) (*ServicesClient, error)

type TasksClient

+ func NewTasksRESTClient(ctx context.Context, opts ...option.ClientOption) (*TasksClient, error)

v0.4.0

Nov 9, 2022

Changes in this version

+ type CreateJobOperation struct

+ func (op *CreateJobOperation) Done() bool

+ func (op *CreateJobOperation) Metadata() (*runpb.Job, error)

+ func (op *CreateJobOperation) Name() string

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

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

+ type DeleteExecutionOperation struct

+ func (op *DeleteExecutionOperation) Done() bool

+ func (op *DeleteExecutionOperation) Metadata() (*runpb.Execution, error)

+ func (op *DeleteExecutionOperation) Name() string

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

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

+ type DeleteJobOperation struct

+ func (op *DeleteJobOperation) Done() bool

+ func (op *DeleteJobOperation) Metadata() (*runpb.Job, error)

+ func (op *DeleteJobOperation) Name() string

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

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

+ type ExecutionIterator struct

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

+ Response interface{}

+ func (it *ExecutionIterator) Next() (*runpb.Execution, error)

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

+ type ExecutionsCallOptions struct

+ DeleteExecution []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetExecution []gax.CallOption

+ GetOperation []gax.CallOption

+ ListExecutions []gax.CallOption

+ ListOperations []gax.CallOption

+ type ExecutionsClient struct

+ CallOptions *ExecutionsCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewExecutionsClient(ctx context.Context, opts ...option.ClientOption) (*ExecutionsClient, error)

+ func (c *ExecutionsClient) Close() error

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

+ func (c *ExecutionsClient) DeleteExecution(ctx context.Context, req *runpb.DeleteExecutionRequest, opts ...gax.CallOption) (*DeleteExecutionOperation, error)

+ func (c *ExecutionsClient) DeleteExecutionOperation(name string) *DeleteExecutionOperation

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

+ func (c *ExecutionsClient) GetExecution(ctx context.Context, req *runpb.GetExecutionRequest, opts ...gax.CallOption) (*runpb.Execution, error)

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

+ func (c *ExecutionsClient) ListExecutions(ctx context.Context, req *runpb.ListExecutionsRequest, opts ...gax.CallOption) *ExecutionIterator

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

+ type JobIterator struct

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

+ Response interface{}

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

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

+ type JobsCallOptions struct

+ CreateJob []gax.CallOption

+ DeleteJob []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetJob []gax.CallOption

+ GetOperation []gax.CallOption

+ ListJobs []gax.CallOption

+ ListOperations []gax.CallOption

+ RunJob []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateJob []gax.CallOption

+ type JobsClient struct

+ CallOptions *JobsCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewJobsClient(ctx context.Context, opts ...option.ClientOption) (*JobsClient, error)

+ func (c *JobsClient) Close() error

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

+ func (c *JobsClient) CreateJob(ctx context.Context, req *runpb.CreateJobRequest, opts ...gax.CallOption) (*CreateJobOperation, error)

+ func (c *JobsClient) CreateJobOperation(name string) *CreateJobOperation

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

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

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

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

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

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

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

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

+ func (c *JobsClient) RunJob(ctx context.Context, req *runpb.RunJobRequest, opts ...gax.CallOption) (*RunJobOperation, error)

+ func (c *JobsClient) RunJobOperation(name string) *RunJobOperation

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

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

+ func (c *JobsClient) UpdateJob(ctx context.Context, req *runpb.UpdateJobRequest, opts ...gax.CallOption) (*UpdateJobOperation, error)

+ func (c *JobsClient) UpdateJobOperation(name string) *UpdateJobOperation

+ type RunJobOperation struct

+ func (op *RunJobOperation) Done() bool

+ func (op *RunJobOperation) Metadata() (*runpb.Execution, error)

+ func (op *RunJobOperation) Name() string

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

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

+ type TaskIterator struct

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

+ Response interface{}

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

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

+ type TasksCallOptions struct

+ DeleteOperation []gax.CallOption

+ GetOperation []gax.CallOption

+ GetTask []gax.CallOption

+ ListOperations []gax.CallOption

+ ListTasks []gax.CallOption

+ type TasksClient struct

+ CallOptions *TasksCallOptions

+ func NewTasksClient(ctx context.Context, opts ...option.ClientOption) (*TasksClient, error)

+ func (c *TasksClient) Close() error

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

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

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

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

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

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

+ type UpdateJobOperation struct

+ func (op *UpdateJobOperation) Done() bool

+ func (op *UpdateJobOperation) Metadata() (*runpb.Job, error)

+ func (op *UpdateJobOperation) Name() string

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

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

v0.3.0

Nov 3, 2022

v0.2.0

Oct 25, 2022

Changes in this version

+ 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

type RevisionsCallOptions

+ DeleteOperation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

type RevisionsClient

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

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

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

type ServicesCallOptions

+ DeleteOperation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

type ServicesClient

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

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

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

v0.1.2

Sep 15, 2022

v0.1.1

May 24, 2022

v0.1.0

Apr 6, 2022

Changes in this version

+ func DefaultAuthScopes() []string

+ type CreateServiceOperation struct

+ func (op *CreateServiceOperation) Done() bool

+ func (op *CreateServiceOperation) Metadata() (*runpb.Service, error)

+ func (op *CreateServiceOperation) Name() string

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

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

+ type DeleteRevisionOperation struct

+ func (op *DeleteRevisionOperation) Done() bool

+ func (op *DeleteRevisionOperation) Metadata() (*runpb.Revision, error)

+ func (op *DeleteRevisionOperation) Name() string

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

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

+ type DeleteServiceOperation struct

+ func (op *DeleteServiceOperation) Done() bool

+ func (op *DeleteServiceOperation) Metadata() (*runpb.Service, error)

+ func (op *DeleteServiceOperation) Name() string

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

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

+ type RevisionIterator struct

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

+ Response interface{}

+ func (it *RevisionIterator) Next() (*runpb.Revision, error)

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

+ type RevisionsCallOptions struct

+ DeleteRevision []gax.CallOption

+ GetRevision []gax.CallOption

+ ListRevisions []gax.CallOption

+ type RevisionsClient struct

+ CallOptions *RevisionsCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewRevisionsClient(ctx context.Context, opts ...option.ClientOption) (*RevisionsClient, error)

+ func (c *RevisionsClient) Close() error

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

+ func (c *RevisionsClient) DeleteRevision(ctx context.Context, req *runpb.DeleteRevisionRequest, opts ...gax.CallOption) (*DeleteRevisionOperation, error)

+ func (c *RevisionsClient) DeleteRevisionOperation(name string) *DeleteRevisionOperation

+ func (c *RevisionsClient) GetRevision(ctx context.Context, req *runpb.GetRevisionRequest, opts ...gax.CallOption) (*runpb.Revision, error)

+ func (c *RevisionsClient) ListRevisions(ctx context.Context, req *runpb.ListRevisionsRequest, opts ...gax.CallOption) *RevisionIterator

+ type ServiceIterator struct

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

+ Response interface{}

+ func (it *ServiceIterator) Next() (*runpb.Service, error)

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

+ type ServicesCallOptions struct

+ CreateService []gax.CallOption

+ DeleteService []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetService []gax.CallOption

+ ListServices []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateService []gax.CallOption

+ type ServicesClient struct

+ CallOptions *ServicesCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewServicesClient(ctx context.Context, opts ...option.ClientOption) (*ServicesClient, error)

+ func (c *ServicesClient) Close() error

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

+ func (c *ServicesClient) CreateService(ctx context.Context, req *runpb.CreateServiceRequest, opts ...gax.CallOption) (*CreateServiceOperation, error)

+ func (c *ServicesClient) CreateServiceOperation(name string) *CreateServiceOperation

+ func (c *ServicesClient) DeleteService(ctx context.Context, req *runpb.DeleteServiceRequest, opts ...gax.CallOption) (*DeleteServiceOperation, error)

+ func (c *ServicesClient) DeleteServiceOperation(name string) *DeleteServiceOperation

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

+ func (c *ServicesClient) GetService(ctx context.Context, req *runpb.GetServiceRequest, opts ...gax.CallOption) (*runpb.Service, error)

+ func (c *ServicesClient) ListServices(ctx context.Context, req *runpb.ListServicesRequest, opts ...gax.CallOption) *ServiceIterator

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

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

+ func (c *ServicesClient) UpdateService(ctx context.Context, req *runpb.UpdateServiceRequest, opts ...gax.CallOption) (*UpdateServiceOperation, error)

+ func (c *ServicesClient) UpdateServiceOperation(name string) *UpdateServiceOperation

+ type UpdateServiceOperation struct

+ func (op *UpdateServiceOperation) Done() bool

+ func (op *UpdateServiceOperation) Metadata() (*runpb.Service, error)

+ func (op *UpdateServiceOperation) Name() string

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

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

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