pub struct VmMigrationClient<T> { /* private fields */ }
Expand description

VM Migration Service

Implementations§

source§

impl<T> VmMigrationClient<T>
where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

source

pub fn new(inner: T) -> Self

source

pub fn with_origin(inner: T, origin: Uri) -> Self

source

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> VmMigrationClient<InterceptedService<T, F>>
where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

source

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

source

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

source

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

source

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

source

pub async fn list_sources( &mut self, request: impl IntoRequest<ListSourcesRequest>, ) -> Result<Response<ListSourcesResponse>, Status>

Lists Sources in a given project and location.

source

pub async fn get_source( &mut self, request: impl IntoRequest<GetSourceRequest>, ) -> Result<Response<Source>, Status>

Gets details of a single Source.

source

pub async fn create_source( &mut self, request: impl IntoRequest<CreateSourceRequest>, ) -> Result<Response<Operation>, Status>

Creates a new Source in a given project and location.

source

pub async fn update_source( &mut self, request: impl IntoRequest<UpdateSourceRequest>, ) -> Result<Response<Operation>, Status>

Updates the parameters of a single Source.

source

pub async fn delete_source( &mut self, request: impl IntoRequest<DeleteSourceRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single Source.

source

pub async fn fetch_inventory( &mut self, request: impl IntoRequest<FetchInventoryRequest>, ) -> Result<Response<FetchInventoryResponse>, Status>

List remote source’s inventory of VMs. The remote source is the onprem vCenter (remote in the sense it’s not in Compute Engine). The inventory describes the list of existing VMs in that source. Note that this operation lists the VMs on the remote source, as opposed to listing the MigratingVms resources in the vmmigration service.

source

pub async fn list_utilization_reports( &mut self, request: impl IntoRequest<ListUtilizationReportsRequest>, ) -> Result<Response<ListUtilizationReportsResponse>, Status>

Lists Utilization Reports of the given Source.

source

pub async fn get_utilization_report( &mut self, request: impl IntoRequest<GetUtilizationReportRequest>, ) -> Result<Response<UtilizationReport>, Status>

Gets a single Utilization Report.

source

pub async fn create_utilization_report( &mut self, request: impl IntoRequest<CreateUtilizationReportRequest>, ) -> Result<Response<Operation>, Status>

Creates a new UtilizationReport.

source

pub async fn delete_utilization_report( &mut self, request: impl IntoRequest<DeleteUtilizationReportRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single Utilization Report.

source

pub async fn list_datacenter_connectors( &mut self, request: impl IntoRequest<ListDatacenterConnectorsRequest>, ) -> Result<Response<ListDatacenterConnectorsResponse>, Status>

Lists DatacenterConnectors in a given Source.

source

pub async fn get_datacenter_connector( &mut self, request: impl IntoRequest<GetDatacenterConnectorRequest>, ) -> Result<Response<DatacenterConnector>, Status>

Gets details of a single DatacenterConnector.

source

pub async fn create_datacenter_connector( &mut self, request: impl IntoRequest<CreateDatacenterConnectorRequest>, ) -> Result<Response<Operation>, Status>

Creates a new DatacenterConnector in a given Source.

source

pub async fn delete_datacenter_connector( &mut self, request: impl IntoRequest<DeleteDatacenterConnectorRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single DatacenterConnector.

source

pub async fn upgrade_appliance( &mut self, request: impl IntoRequest<UpgradeApplianceRequest>, ) -> Result<Response<Operation>, Status>

Upgrades the appliance relate to this DatacenterConnector to the in-place updateable version.

source

pub async fn create_migrating_vm( &mut self, request: impl IntoRequest<CreateMigratingVmRequest>, ) -> Result<Response<Operation>, Status>

Creates a new MigratingVm in a given Source.

source

pub async fn list_migrating_vms( &mut self, request: impl IntoRequest<ListMigratingVmsRequest>, ) -> Result<Response<ListMigratingVmsResponse>, Status>

Lists MigratingVms in a given Source.

source

pub async fn get_migrating_vm( &mut self, request: impl IntoRequest<GetMigratingVmRequest>, ) -> Result<Response<MigratingVm>, Status>

Gets details of a single MigratingVm.

source

pub async fn update_migrating_vm( &mut self, request: impl IntoRequest<UpdateMigratingVmRequest>, ) -> Result<Response<Operation>, Status>

Updates the parameters of a single MigratingVm.

source

pub async fn delete_migrating_vm( &mut self, request: impl IntoRequest<DeleteMigratingVmRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single MigratingVm.

source

pub async fn start_migration( &mut self, request: impl IntoRequest<StartMigrationRequest>, ) -> Result<Response<Operation>, Status>

Starts migration for a VM. Starts the process of uploading data and creating snapshots, in replication cycles scheduled by the policy.

source

pub async fn resume_migration( &mut self, request: impl IntoRequest<ResumeMigrationRequest>, ) -> Result<Response<Operation>, Status>

Resumes a migration for a VM. When called on a paused migration, will start the process of uploading data and creating snapshots; when called on a completed cut-over migration, will update the migration to active state and start the process of uploading data and creating snapshots.

source

pub async fn pause_migration( &mut self, request: impl IntoRequest<PauseMigrationRequest>, ) -> Result<Response<Operation>, Status>

Pauses a migration for a VM. If cycle tasks are running they will be cancelled, preserving source task data. Further replication cycles will not be triggered while the VM is paused.

source

pub async fn finalize_migration( &mut self, request: impl IntoRequest<FinalizeMigrationRequest>, ) -> Result<Response<Operation>, Status>

Marks a migration as completed, deleting migration resources that are no longer being used. Only applicable after cutover is done.

source

pub async fn create_clone_job( &mut self, request: impl IntoRequest<CreateCloneJobRequest>, ) -> Result<Response<Operation>, Status>

Initiates a Clone of a specific migrating VM.

source

pub async fn cancel_clone_job( &mut self, request: impl IntoRequest<CancelCloneJobRequest>, ) -> Result<Response<Operation>, Status>

Initiates the cancellation of a running clone job.

source

pub async fn list_clone_jobs( &mut self, request: impl IntoRequest<ListCloneJobsRequest>, ) -> Result<Response<ListCloneJobsResponse>, Status>

Lists CloneJobs of a given migrating VM.

source

pub async fn get_clone_job( &mut self, request: impl IntoRequest<GetCloneJobRequest>, ) -> Result<Response<CloneJob>, Status>

Gets details of a single CloneJob.

source

pub async fn create_cutover_job( &mut self, request: impl IntoRequest<CreateCutoverJobRequest>, ) -> Result<Response<Operation>, Status>

Initiates a Cutover of a specific migrating VM. The returned LRO is completed when the cutover job resource is created and the job is initiated.

source

pub async fn cancel_cutover_job( &mut self, request: impl IntoRequest<CancelCutoverJobRequest>, ) -> Result<Response<Operation>, Status>

Initiates the cancellation of a running cutover job.

source

pub async fn list_cutover_jobs( &mut self, request: impl IntoRequest<ListCutoverJobsRequest>, ) -> Result<Response<ListCutoverJobsResponse>, Status>

Lists CutoverJobs of a given migrating VM.

source

pub async fn get_cutover_job( &mut self, request: impl IntoRequest<GetCutoverJobRequest>, ) -> Result<Response<CutoverJob>, Status>

Gets details of a single CutoverJob.

source

pub async fn list_groups( &mut self, request: impl IntoRequest<ListGroupsRequest>, ) -> Result<Response<ListGroupsResponse>, Status>

Lists Groups in a given project and location.

source

pub async fn get_group( &mut self, request: impl IntoRequest<GetGroupRequest>, ) -> Result<Response<Group>, Status>

Gets details of a single Group.

source

pub async fn create_group( &mut self, request: impl IntoRequest<CreateGroupRequest>, ) -> Result<Response<Operation>, Status>

Creates a new Group in a given project and location.

source

pub async fn update_group( &mut self, request: impl IntoRequest<UpdateGroupRequest>, ) -> Result<Response<Operation>, Status>

Updates the parameters of a single Group.

source

pub async fn delete_group( &mut self, request: impl IntoRequest<DeleteGroupRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single Group.

source

pub async fn add_group_migration( &mut self, request: impl IntoRequest<AddGroupMigrationRequest>, ) -> Result<Response<Operation>, Status>

Adds a MigratingVm to a Group.

source

pub async fn remove_group_migration( &mut self, request: impl IntoRequest<RemoveGroupMigrationRequest>, ) -> Result<Response<Operation>, Status>

Removes a MigratingVm from a Group.

source

pub async fn list_target_projects( &mut self, request: impl IntoRequest<ListTargetProjectsRequest>, ) -> Result<Response<ListTargetProjectsResponse>, Status>

Lists TargetProjects in a given project.

NOTE: TargetProject is a global resource; hence the only supported value for location is global.

source

pub async fn get_target_project( &mut self, request: impl IntoRequest<GetTargetProjectRequest>, ) -> Result<Response<TargetProject>, Status>

Gets details of a single TargetProject.

NOTE: TargetProject is a global resource; hence the only supported value for location is global.

source

pub async fn create_target_project( &mut self, request: impl IntoRequest<CreateTargetProjectRequest>, ) -> Result<Response<Operation>, Status>

Creates a new TargetProject in a given project.

NOTE: TargetProject is a global resource; hence the only supported value for location is global.

source

pub async fn update_target_project( &mut self, request: impl IntoRequest<UpdateTargetProjectRequest>, ) -> Result<Response<Operation>, Status>

Updates the parameters of a single TargetProject.

NOTE: TargetProject is a global resource; hence the only supported value for location is global.

source

pub async fn delete_target_project( &mut self, request: impl IntoRequest<DeleteTargetProjectRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single TargetProject.

NOTE: TargetProject is a global resource; hence the only supported value for location is global.

source

pub async fn list_replication_cycles( &mut self, request: impl IntoRequest<ListReplicationCyclesRequest>, ) -> Result<Response<ListReplicationCyclesResponse>, Status>

Lists ReplicationCycles in a given MigratingVM.

source

pub async fn get_replication_cycle( &mut self, request: impl IntoRequest<GetReplicationCycleRequest>, ) -> Result<Response<ReplicationCycle>, Status>

Gets details of a single ReplicationCycle.

Trait Implementations§

source§

impl<T: Clone> Clone for VmMigrationClient<T>

source§

fn clone(&self) -> VmMigrationClient<T>

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl<T: Debug> Debug for VmMigrationClient<T>

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> !Freeze for VmMigrationClient<T>

§

impl<T> RefUnwindSafe for VmMigrationClient<T>
where T: RefUnwindSafe,

§

impl<T> Send for VmMigrationClient<T>
where T: Send,

§

impl<T> Sync for VmMigrationClient<T>
where T: Sync,

§

impl<T> Unpin for VmMigrationClient<T>
where T: Unpin,

§

impl<T> UnwindSafe for VmMigrationClient<T>
where T: UnwindSafe,

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> FromRef<T> for T
where T: Clone,

§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more