migration

type BlackoutExitedEventDetails struct {

	// Duration of the blackout phase, in milliseconds.
	BlackoutDurationMilliseconds uint64 `` /* 148-byte string literal not displayed */
	// Timestamp at which the blackout phase ended.
	BlackoutStopTimestamp *timestamppb.Timestamp `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CompressionSettings struct {

	// Number of worker threads used for [de]compression. Values higher than what the host
	// and VM configuration can support will be adjusted. The value should be non-zero.
	ThrottleWorkerCount *uint32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateDuplicateSocketRequest struct {

	// Identifier for the active LM session. Must match the session_id used
	// for the rest of this LM on this side.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Serialized WSAProtocolInfo struct describing the source socket whose
	// handle should be duplicated into the shim process. The exact layout
	// is opaque to clients; the shim feeds it directly to WSASocket to
	// create the duplicate.
	ProtocolInfo []byte `protobuf:"bytes,2,opt,name=protocol_info,json=protocolInfo,proto3" json:"protocol_info,omitempty"`
	// contains filtered or unexported fields
}

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

type FinalizeAction int32

type FinalizeSandboxRequest struct {

	// Identifier for the migration session. Must match the session_id used
	// for the rest of this LM on this side.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Action the shim should take on the sandbox during finalization. See
	// FinalizeAction and the FinalizeSandbox RPC documentation for the
	// per-side semantics of STOP vs. RESUME.
	Action FinalizeAction `protobuf:"varint,2,opt,name=action,proto3,enum=FinalizeAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

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

type ImportSandboxRequest struct {

	// Identifier for the migration session. Must match the session_id used
	// on the source for this LM.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Identifier of the new sandbox being rehydrated on the destination.
	// The destination shim is created by this RPC, so there is no prior
	// channel through which to communicate the new sandbox id; it must be
	// supplied here. The opaque config from the source will be applied to
	// a new sandbox with this id.
	SandboxID string `protobuf:"bytes,2,opt,name=sandbox_id,json=sandboxId,proto3" json:"sandbox_id,omitempty"`
	// Opaque config produced by PrepareAndExportSandbox on the source.
	// Forwarded verbatim by the caller; the destination shim is responsible
	// for decoding and applying it.
	Config *anypb.Any `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

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

type InitializeOptions struct {

	// MemoryTransport specifies the transport protocol for memory transfer during migration.
	MemoryTransport MemoryTransport `` /* 128-byte string literal not displayed */
	// MemoryTransferThrottleParams specifies settings for throttling during memory transfer.
	MemoryTransferThrottleParams *MemoryTransferThrottleParams `` /* 155-byte string literal not displayed */
	// CompressionSettings specifies additional settings when compression is enabled.
	CompressionSettings *CompressionSettings `protobuf:"bytes,3,opt,name=compression_settings,json=compressionSettings,proto3,oneof" json:"compression_settings,omitempty"`
	// ChecksumVerification enables memory checksum verification.
	ChecksumVerification bool `protobuf:"varint,4,opt,name=checksum_verification,json=checksumVerification,proto3" json:"checksum_verification,omitempty"`
	// PerfTracingEnabled enables performance tracing during migration.
	PerfTracingEnabled bool `protobuf:"varint,5,opt,name=perf_tracing_enabled,json=perfTracingEnabled,proto3" json:"perf_tracing_enabled,omitempty"`
	// CancelIfBlackoutThresholdExceeds cancels the operation if the blackout threshold is exceeded.
	CancelIfBlackoutThresholdExceeds bool `` /* 164-byte string literal not displayed */
	// PrepareMemoryTransferMode extends timeout for cross-version live migration.
	PrepareMemoryTransferMode bool `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MemoryTransferThrottleParams struct {

	// A flag indicating if throttling should be skipped.
	SkipThrottling *bool `protobuf:"varint,1,opt,name=skip_throttling,json=skipThrottling,proto3,oneof" json:"skip_throttling,omitempty"`
	// The scale of the throttling. The value is in percentage (1-100).
	ThrottlingScale *float64 `protobuf:"fixed64,2,opt,name=throttling_scale,json=throttlingScale,proto3,oneof" json:"throttling_scale,omitempty"`
	// Minimum percentage value to which memory transfer can be throttled.
	MinimumThrottlePercentage *uint32 `` /* 145-byte string literal not displayed */
	// Number of memory transfer passes targeted before the VM enters blackout.
	TargetNumberOfBrownoutTransferPasses *uint32 `` /* 184-byte string literal not displayed */
	// The starting transfer pass where throttling is starting.
	StartingBrownoutPassNumberForThrottling *uint32 `` /* 193-byte string literal not displayed */
	// Maximum number of memory transfer passes before forcing the VM to enter blackout.
	MaximumNumberOfBrownoutTransferPasses *uint32 `` /* 187-byte string literal not displayed */
	// Expected duration, in milliseconds, for the blackout memory
	// transfer to complete.
	TargetBlackoutTransferTime *uint32 `` /* 150-byte string literal not displayed */
	// Threshold, in milliseconds, for blackout duration prior to
	// cancelling migration.
	BlackoutTimeThresholdForCancellingMigration *uint32 `` /* 205-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MemoryTransport int32

type MigrationClient interface {
	PrepareAndExportSandbox(context.Context, *PrepareAndExportSandboxRequest) (*PrepareAndExportSandboxResponse, error)
	ImportSandbox(context.Context, *ImportSandboxRequest) (*ImportSandboxResponse, error)
	PrepareSandbox(context.Context, *PrepareSandboxRequest) (*PrepareSandboxResponse, error)
	TransferSandbox(context.Context, *TransferSandboxRequest) (*TransferSandboxResponse, error)
	FinalizeSandbox(context.Context, *FinalizeSandboxRequest) (*FinalizeSandboxResponse, error)
	Notifications(context.Context, *NotificationsRequest) (Migration_NotificationsClient, error)
	CreateDuplicateSocket(context.Context, *CreateDuplicateSocketRequest) (*CreateDuplicateSocketResponse, error)
}

type MigrationService interface {
	PrepareAndExportSandbox(context.Context, *PrepareAndExportSandboxRequest) (*PrepareAndExportSandboxResponse, error)
	ImportSandbox(context.Context, *ImportSandboxRequest) (*ImportSandboxResponse, error)
	PrepareSandbox(context.Context, *PrepareSandboxRequest) (*PrepareSandboxResponse, error)
	TransferSandbox(context.Context, *TransferSandboxRequest) (*TransferSandboxResponse, error)
	FinalizeSandbox(context.Context, *FinalizeSandboxRequest) (*FinalizeSandboxResponse, error)
	Notifications(context.Context, *NotificationsRequest, Migration_NotificationsServer) error
	CreateDuplicateSocket(context.Context, *CreateDuplicateSocketRequest) (*CreateDuplicateSocketResponse, error)
}

type Migration_NotificationsClient interface {
	Recv() (*NotificationsResponse, error)
	ttrpc.ClientStream
}

type Migration_NotificationsServer interface {
	Send(*NotificationsResponse) error
	ttrpc.StreamServer
}

type Notification struct {

	// Origin indicates which side of the live migration this notification
	// pertains to.
	Origin Origin `protobuf:"varint,1,opt,name=origin,proto3,enum=Origin" json:"origin,omitempty"`
	// Phase is the live migration phase being reported.
	Phase Phase `protobuf:"varint,2,opt,name=phase,proto3,enum=Phase" json:"phase,omitempty"`
	// State is an optional outcome accompanying the phase. Typically
	// populated for terminal phases.
	State PhaseState `protobuf:"varint,3,opt,name=state,proto3,enum=PhaseState" json:"state,omitempty"`
	// PhaseDetails carries extra phase-specific information whose concrete
	// type depends on the phase being reported.
	//
	// Types that are valid to be assigned to PhaseDetails:
	//
	//	*Notification_BlackoutExited
	PhaseDetails isNotification_PhaseDetails `protobuf_oneof:"phase_details"`
	// contains filtered or unexported fields
}

type Notification_BlackoutExited struct {
	// Details reported with PHASE_BLACKOUT_EXITED.
	BlackoutExited *BlackoutExitedEventDetails `protobuf:"bytes,4,opt,name=blackout_exited,json=blackoutExited,proto3,oneof"`
}

type NotificationsRequest struct {

	// Identifier for the migration session. Must match the session_id used
	// for the rest of this LM on this side.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type NotificationsResponse struct {

	// Monotonically increasing per-message counter on this stream. Useful
	// for de-duplication if the client reconnects mid-transfer.
	MessageID uint32 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Structured notification describing the current migration event. This
	// mirrors the HCS OperationSystemMigrationNotificationInfo payload
	// emitted by the underlying compute system as the transfer progresses.
	Notification *Notification `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"`
	// Server-side timestamp of when the transfer began.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Server-side timestamp of when this particular update was produced.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

type Origin int32

type Phase int32

type PhaseState int32

type PrepareAndExportSandboxRequest struct {

	// Identifier for the migration session. The same session_id is used on
	// both source and destination for the lifetime of this LM and is what
	// ties subsequent calls (TransferSandbox, FinalizeSandbox, etc.) back
	// to this sandbox.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Source-side options that control how live migration is initialized
	// on the compute system.
	InitOptions *InitializeOptions `protobuf:"bytes,2,opt,name=init_options,json=initOptions,proto3" json:"init_options,omitempty"`
	// contains filtered or unexported fields
}

type PrepareAndExportSandboxResponse struct {

	// Opaque, serialized snapshot of the source shim's view of the sandbox
	// and its containers. The caller must forward this verbatim as the
	// `config` field of ImportSandboxRequest on the destination; only the
	// destination shim knows how to decode it.
	Config *anypb.Any `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type PrepareSandboxRequest struct {

	// Identifier for the migration session. Must match the session_id used
	// by ImportSandbox on this destination.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Destination-side options that control how live migration is
	// initialized when the HCS compute system is created.
	InitOptions *InitializeOptions `protobuf:"bytes,2,opt,name=init_options,json=initOptions,proto3" json:"init_options,omitempty"`
	// contains filtered or unexported fields
}

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

type TransferSandboxRequest struct {

	// Identifier for the migration session. Must match the session_id used
	// for the rest of this LM on this side.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Maximum time to wait for the migration socket / underlying transport
	// to become ready before the server gives up and fails the transfer
	// with a TIMEOUT. If unset, the server applies a sensible default
	// (e.g. 10 minutes).
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

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