FakePipelineService class base

Testing fake for PipelineService.

Implemented types

• PipelineService

Constructors

FakePipelineService({Future<TrainingPipeline> createTrainingPipeline(CreateTrainingPipelineRequest request)?, Future<TrainingPipeline> getTrainingPipeline(GetTrainingPipelineRequest request)?, Future<ListTrainingPipelinesResponse> listTrainingPipelines(ListTrainingPipelinesRequest request)?, Future<Operation<Empty, DeleteOperationMetadata>> deleteTrainingPipeline(DeleteTrainingPipelineRequest request)?, Future<void> cancelTrainingPipeline(CancelTrainingPipelineRequest request)?, Future<PipelineJob> createPipelineJob(CreatePipelineJobRequest request)?, Future<PipelineJob> getPipelineJob(GetPipelineJobRequest request)?, Future<ListPipelineJobsResponse> listPipelineJobs(ListPipelineJobsRequest request)?, Future<Operation<Empty, DeleteOperationMetadata>> deletePipelineJob(DeletePipelineJobRequest request)?, Future<Operation<BatchDeletePipelineJobsResponse, DeleteOperationMetadata>> batchDeletePipelineJobs(BatchDeletePipelineJobsRequest request)?, Future<void> cancelPipelineJob(CancelPipelineJobRequest request)?, Future<Operation<BatchCancelPipelineJobsResponse, BatchCancelPipelineJobsOperationMetadata>> batchCancelPipelineJobs(BatchCancelPipelineJobsRequest request)?, Future<ListLocationsResponse> listLocations(ListLocationsRequest request)?, Future<Location> getLocation(GetLocationRequest request)?, Future<Policy> setIamPolicy(SetIamPolicyRequest request)?, Future<Policy> getIamPolicy(GetIamPolicyRequest request)?, Future<TestIamPermissionsResponse> testIamPermissions(TestIamPermissionsRequest request)?, Future<ListOperationsResponse> listOperations(ListOperationsRequest request)?, Future<Operation<T, S>> getOperation<T extends ProtoMessage, S extends ProtoMessage>(Operation<T, S> request)?, Future<void> deleteOperation(DeleteOperationRequest request)?, Future<void> cancelOperation(CancelOperationRequest request)?, Future<Operation<ProtoMessage, ProtoMessage>> waitOperation(WaitOperationRequest request)?})

Properties

hashCode → int

The hash code for this object.

no setter, inherited

isClosed ↔ bool

getter/setter pair

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

batchCancelPipelineJobs(BatchCancelPipelineJobsRequest request) → Future<Operation<BatchCancelPipelineJobsResponse, BatchCancelPipelineJobsOperationMetadata>>

Batch cancel PipelineJobs. Firstly the server will check if all the jobs are in non-terminal states, and skip the jobs that are already terminated. If the operation failed, none of the pipeline jobs are cancelled. The server will poll the states of all the pipeline jobs periodically to check the cancellation status. This operation will return an LRO.

override

batchDeletePipelineJobs(BatchDeletePipelineJobsRequest request) → Future<Operation<BatchDeletePipelineJobsResponse, DeleteOperationMetadata>>

Batch deletes PipelineJobs The Operation is atomic. If it fails, none of the PipelineJobs are deleted. If it succeeds, all of the PipelineJobs are deleted.

override

cancelOperation(CancelOperationRequest request) → Future<void>

Provides the Operations service functionality in this service.

override

cancelPipelineJob(CancelPipelineJobRequest request) → Future<void>

Cancels a PipelineJob. Starts asynchronous cancellation on the PipelineJob. The server makes a best effort to cancel the pipeline, but success is not guaranteed. Clients can use PipelineService.GetPipelineJob or other methods to check whether the cancellation succeeded or whether the pipeline completed despite cancellation. On successful cancellation, the PipelineJob is not deleted; instead it becomes a pipeline with a PipelineJob.error value with a google.rpc.Status.code of 1, corresponding to Code.CANCELLED, and PipelineJob.state is set to CANCELLED.

override

cancelTrainingPipeline(CancelTrainingPipelineRequest request) → Future<void>

Cancels a TrainingPipeline. Starts asynchronous cancellation on the TrainingPipeline. The server makes a best effort to cancel the pipeline, but success is not guaranteed. Clients can use PipelineService.GetTrainingPipeline or other methods to check whether the cancellation succeeded or whether the pipeline completed despite cancellation. On successful cancellation, the TrainingPipeline is not deleted; instead it becomes a pipeline with a TrainingPipeline.error value with a google.rpc.Status.code of 1, corresponding to Code.CANCELLED, and TrainingPipeline.state is set to CANCELLED.

override

close() → void

Closes the client and cleans up any resources associated with it.

override

createPipelineJob(CreatePipelineJobRequest request) → Future<PipelineJob>

Creates a PipelineJob. A PipelineJob will run immediately when created.

override

createTrainingPipeline(CreateTrainingPipelineRequest request) → Future<TrainingPipeline>

Creates a TrainingPipeline. A created TrainingPipeline right away will be attempted to be run.

override

deleteOperation(DeleteOperationRequest request) → Future<void>

Provides the Operations service functionality in this service.

override

deletePipelineJob(DeletePipelineJobRequest request) → Future<Operation<Empty, DeleteOperationMetadata>>

Deletes a PipelineJob.

override

deleteTrainingPipeline(DeleteTrainingPipelineRequest request) → Future<Operation<Empty, DeleteOperationMetadata>>

Deletes a TrainingPipeline.

override

getIamPolicy(GetIamPolicyRequest request) → Future<Policy>

Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.

override

getLocation(GetLocationRequest request) → Future<Location>

Gets information about a location.

override

getOperation<T extends ProtoMessage, S extends ProtoMessage>(Operation<T, S> request) → Future<Operation<T, S>>

Provides the Operations service functionality in this service.

override

getPipelineJob(GetPipelineJobRequest request) → Future<PipelineJob>

Gets a PipelineJob.

override

getTrainingPipeline(GetTrainingPipelineRequest request) → Future<TrainingPipeline>

Gets a TrainingPipeline.

override

listLocations(ListLocationsRequest request) → Future<ListLocationsResponse>

Lists information about the supported locations for this service.

override

listOperations(ListOperationsRequest request) → Future<ListOperationsResponse>

Provides the Operations service functionality in this service.

override

listPipelineJobs(ListPipelineJobsRequest request) → Future<ListPipelineJobsResponse>

Lists PipelineJobs in a Location.

override

listTrainingPipelines(ListTrainingPipelinesRequest request) → Future<ListTrainingPipelinesResponse>

Lists TrainingPipelines in a Location.

override

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

setIamPolicy(SetIamPolicyRequest request) → Future<Policy>

Sets the access control policy on the specified resource. Replaces any existing policy.

override

testIamPermissions(TestIamPermissionsRequest request) → Future<TestIamPermissionsResponse>

Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.

override

toString() → String

A string representation of this object.

inherited

waitOperation(WaitOperationRequest request) → Future<Operation<ProtoMessage, ProtoMessage>>

Provides the Operations service functionality in this service.

override

Operators

operator ==(Object other) → bool

The equality operator.

inherited