swagger

package
v0.0.0-...-012d9ea Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 27, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

README

Go API client for swagger

LiveData Migrator API Documentation

Overview

This API client was generated by the swagger-codegen project. By using the swagger-spec from a remote server, you can easily generate an API client.

  • API version: 3.3.6
  • Package version: 1.0.0
  • Build package: io.swagger.codegen.v3.generators.go.GoClientCodegen

Installation

Put the package under your project folder and add the following in import:

import "./swagger"

Documentation for API Endpoints

All URIs are relative to http://liamg01-vm5.bdfrem.wandisco.com:18080/

Class Method HTTP request Description
ADLS2SourceFileSystemControllerApi AddAdls2SourceFileSystemServicePrincipal Post /fs/sources/adls2/oauth2/{fileSystemId} Add a new source ADLS2 file system with service principal and OAuth 2.0 authentication
ADLS2SourceFileSystemControllerApi AddSourceAdls2FileSystem Post /fs/sources/adls2/shared-key/{fileSystemId} Add a Adls2 file system With shared key authentication
ADLS2SourceFileSystemControllerApi UpdateAdls2SourceFileSystemServicePrincipal Patch /fs/sources/adls2/oauth2/{fileSystemId} Update a source ADLS2 file system with service principal and OAuth 2.0 authentication
ADLS2SourceFileSystemControllerApi UpdateSourceAdls2FileSystem Patch /fs/sources/adls2/shared-key/{fileSystemId} Update a Adls2 file system With shared key authentication
ADLS2TargetFileSystemControllerApi AddAdls2FileSystem Post /fs/targets/adls2/shared-key/{fileSystemId} Add a new target ADLS2 file system with Shared Key authentication
ADLS2TargetFileSystemControllerApi AddAdls2FileSystemServicePrincipal Post /fs/targets/adls2/oauth2/{fileSystemId} Add a new target ADLS2 file system with service principal and OAuth 2.0 authentication
ADLS2TargetFileSystemControllerApi UpdateAdls2FileSystem Patch /fs/targets/adls2/shared-key/{fileSystemId} Update a target ADLS2 file system with Shared Key authentication
ADLS2TargetFileSystemControllerApi UpdateAdls2FileSystemServicePrincipal Patch /fs/targets/adls2/oauth2/{fileSystemId} Update a target ADLS2 file system with service principal and OAuth 2.0 authentication
BackupsControllerApi CreateBackup Post /backups Generate a Backup.
BackupsControllerApi GetBackupByName Get /backups/{backupName}
BackupsControllerApi GetBackupConfig Get /backups/config backup config entity
BackupsControllerApi GetBackupSchedule Get /backups/config/schedule Returns current schedule configuration
BackupsControllerApi GetBackupsList Get /backups list of available LM2 backups
BackupsControllerApi RestoreBackup Post /backups/restore/{backupName} Restore application state by backup by provided backup ID
BackupsControllerApi UpdateSchedule Put /backups/config/schedule Update current schedule.
BandwidthPolicyControllerApi GetApplicationBandwidthPolicy Get /bandwidthPolicies/application Get the application's bandwidth policy
BandwidthPolicyControllerApi ResetApplicationBandwidthPolicy Delete /bandwidthPolicies/application Restore default, unlimited application bandwidth policy
BandwidthPolicyControllerApi UpdateApplicationBandwidthPolicy Post /bandwidthPolicies/application Set the application's bandwidth policy. A limit of -1 will mean no bandwidth limit is imposed.
ConfigurationControllerApi GetConfigurationProperties Get /configuration/properties Get all configuration properties
ConfigurationControllerApi GetConfigurationProperty Get /configuration/property Get value for given configuration property
ConfigurationControllerApi SetConfigurationProperty Put /configuration/property Set key/value configuration property
ConsumptionControllerApi ExtendLicense Put /consumption/extendTime Extend consumption license expiry time
ConsumptionControllerApi SwitchToConsumption Put /consumption/switchToConsumption Change license type to consumption
DataAgentDiagnosticsControllerApi FetchAllDiagnosticsByAgentName Get /diagnostics/dta/{agentName} Get all Diagnostics snapshots for all data agents over time. "kind" can be used to filter the diagnostics returned, it is a comma separated list of Diagnostics kinds.
DataAgentDiagnosticsControllerApi FetchLatestDiagnosticsByAgentName Get /diagnostics/dta/lastCollected/{agentName} Get last collected snapshot of Diagnostics for specified agent by agent name. Will return the last collected snapshot of Diagnostics. kind can be used to filter the diagnostics returned, it is a comma separated list of Diagnostics kinds.
DataAgentStatisticsControllerApi GetDtaStats Get /stats/dta/{agentName} Get full stats over for given Data Agent
DataAgentStatisticsControllerApi GetDtaStatsList Get /stats/dta/ Get full stats over all time for all Data Agents
DataAgentStatisticsControllerApi GetDtaStatsSummary Get /stats/dta/{agentName}/summary Get summary stats for given Data Agent
DataAgentsControllerApi AddDataAgent Post /scaling/dataagents/ Add new Data Transfer Agent
DataAgentsControllerApi DeleteDataAgent Delete /scaling/dataagents/{agentName} Delete Data Transfer Agent from LM2
DataAgentsControllerApi GetDataAgent Get /scaling/dataagents/{agentName} Get Data Agent with given name
DataAgentsControllerApi GetDataAgentList Get /scaling/dataagents/ Get Data Agent list
DiagnosticsControllerApi DumpActionStoreForMigration Get /diagnostics/{migrationId}/actionStore To be used for debugging purposes only - dumps the ActionStore for a Migration to file.
DiagnosticsControllerApi FetchAllDiagnostics Get /diagnostics Get all Diagnostics sets over time. kind can be used to filter the diagnostics returned, it is a comma separated list of Diagnostics kinds.
DiagnosticsControllerApi FetchCountTcpStates Get /diagnostics/netstat/tcpStatesCount Get a map of total connections to their TCP state.
DiagnosticsControllerApi FetchCurrentDiagnostics Get /diagnostics/collect Trigger Diagnostics Collection. Will trigger the collection of Diagnostics and return the new set of Diagnostics generated. kind can be used to filter the diagnostics returned, it is a comma separated list of Diagnostics kinds.
DiagnosticsControllerApi FetchDiagnosticsDescriptions Get /diagnostics/descriptions Get Diagnostics Descriptions. Return the set of available Diagnostics and a description of the information they return.
DiagnosticsControllerApi FetchDiagnosticsSummary Get /diagnostics/summary Get Diagnostic Summary
DiagnosticsControllerApi FetchDiagnosticsSummaryTxt Get /diagnostics/summary.txt Get Diagnostic Summary Plain Text
DiagnosticsControllerApi FetchLatestDiagnostics Get /diagnostics/lastCollected Get last collected set of Diagnostics. Will return the last collected set of Diagnostics. kind can be used to filter the diagnostics returned, it is a comma separated list of Diagnostics kinds.
DiagnosticsControllerApi FetchNetworkConnections Get /diagnostics/netstat/connections Get Established Connections.
DiagnosticsControllerApi FetchNetworkStatus Get /diagnostics/netstat Get Netstat Status.
DiagnosticsControllerApi FetchNetworkStatusTotals Get /diagnostics/netstat/totals Get Connections Total Queue Sizes and ReTransmit Counts.
EmailNotificationControllerApi FetchEmailNotificationTypes Get /notifications/config/email/types Get email notifications types
EmailNotificationControllerApi FetchEmailRegistrations Get /notifications/config/email/registration Get registered email address for receiving push notifications about specific notification types
EmailNotificationControllerApi FetchSmtpConfig Get /notifications/config/email Get the current SMTP adaptor config
EmailNotificationControllerApi SendTestEmail Post /notifications/config/email/test Send test e-mail to the specified list of recipient
EmailNotificationControllerApi SetEmailRegistrations Put /notifications/config/email/registration Update set of emails registered for receiving push notifications about specific notification types
EmailNotificationControllerApi SetSmtpConfig Put /notifications/config/email Update the SMTP adaptor config
ExclusionsControllerApi AddDateExclusion Put /exclusions/date/{id} Add a new date-based exclusion
ExclusionsControllerApi AddFileSizeExclusion Put /exclusions/fileSize/{id} Add a new file size exclusion
ExclusionsControllerApi AddRegexExclusion Put /exclusions/regex/{id} Add a new regex exclusion
ExclusionsControllerApi GetExclusion Get /exclusions/{exclusionId} Get exclusion for given exclusion ID
ExclusionsControllerApi GetFsRestrictions Get /exclusions/target/{fsType} See the restrictions applied automatically for the given target filesystem
ExclusionsControllerApi GetSourceFsRestrictions Get /exclusions/source/{fsType} See the restrictions applied automatically for the given source filesystem
ExclusionsControllerApi ListExclusions Get /exclusions Get all exclusions
ExclusionsControllerApi ListGlobalExclusions Get /exclusions/global Get all global exclusions
ExclusionsControllerApi ListUserDefinedExclusions Get /exclusions/userDefined Get all user defined exclusions
ExclusionsControllerApi RemoveExclusion Delete /exclusions/{exclusionId} Delete exclusion for given ID
FileSystemControllerApi CreateFile Post /fs/{role}/{fsId}/createFile Create file on the file system
FileSystemControllerApi DeleteByPath Post /fs/{role}/{fsId}/deleteByPath Delete file from the file system
FileSystemControllerApi GetFileSystemURI Get /fs/{role}/{fsId}/fileSystemURI Get file system URI for given filesystem id
FileSystemControllerApi ListPaths Get /fs/{role}/{fsId}/listPaths Get files list from the file system
FileSystemControllerApi Mkdir Post /fs/{role}/{fsId}/mkdir Create directory in the file system
FileSystemControllerApi MoveByPath Post /fs/{role}/{fsId}/moveByPath Move file or directory on the file system
FileSystemControllerApi Path Get /fs/{role}/{fsId}/pathExists Check if file or directory exists
FileSystemControllerApi ReadFile Get /fs/{role}/{fsId}/readFile Read file from the file system
FileSystemControllerApi WriteFile Post /fs/{role}/{fsId}/writeFile Write file into the file system
FilesSystemHealthControllerApi GetHealthStatus Get /fs/health/{fsId} Get health status for given ID
FilesSystemHealthControllerApi ListHealthStatuses Get /fs/health List health statues for all filesystems
GCSSourceFileSystemControllerApi AddSourceGcsFileSystemDefault Post /fs/sources/gcs/{fileSystemId} Add a new source GCS file system
GCSSourceFileSystemControllerApi AddSourceGcsFileSystemJsonKeyFile Post /fs/sources/gcs/keyfiles/json/{fileSystemId} Add a new source GCS file system with credentials uploaded with JSON key file
GCSSourceFileSystemControllerApi AddSourceGcsFileSystemP12KeyFile Post /fs/sources/gcs/keyfiles/p12/{fileSystemId} Add a new source GCS file system with credentials uploaded via P12 key file
GCSSourceFileSystemControllerApi UpdateSourceGcsFileSystemDefault Patch /fs/sources/gcs/{fileSystemId} Update a source GCS file system
GCSSourceFileSystemControllerApi UpdateSourceGcsFileSystemJsonKeyFile Patch /fs/sources/gcs/keyfiles/json/{fileSystemId} Update a source GCS file system with credentials uploaded with JSON key file
GCSSourceFileSystemControllerApi UpdateSourceGcsFileSystemP12KeyFile Patch /fs/sources/gcs/keyfiles/p12/{fileSystemId} Update a source GCS file system with credentials uploaded via P12 key file
GCSTargetFileSystemControllerApi AddTargetGcsFileSystemDefault Post /fs/targets/gcs/{fileSystemId} Add a new target GCS file system
GCSTargetFileSystemControllerApi AddTargetGcsFileSystemJsonKeyFile Post /fs/targets/gcs/keyfiles/json/{fileSystemId} Add a new target GCS file system with credentials uploaded with JSON key file
GCSTargetFileSystemControllerApi AddTargetGcsFileSystemP12KeyFile Post /fs/targets/gcs/keyfiles/p12/{fileSystemId} Add a new target GCS file system with credentials uploaded via P12 key file
GCSTargetFileSystemControllerApi UpdateTargetGcsFileSystemDefault Patch /fs/targets/gcs/{fileSystemId} Update a target GCS file system
GCSTargetFileSystemControllerApi UpdateTargetGcsFileSystemJsonKeyFile Patch /fs/targets/gcs/keyfiles/json/{fileSystemId} Update a target GCS file system with credentials uploaded with JSON key file
GCSTargetFileSystemControllerApi UpdateTargetGcsFileSystemP12KeyFile Patch /fs/targets/gcs/keyfiles/p12/{fileSystemId} Update a target GCS file system with credentials uploaded via P12 key file
HDFSSourceFileSystemAutodiscoveryControllerApi AutoDiscoverSourceFilesystem Post /fs/autodiscover/sources/hdfs Automatically discover the local hadoop source file system
HDFSSourceFileSystemControllerApi AddSourceHdfsFileSystem Post /fs/sources/hdfs/{fileSystemId} Add a new Hadoop source file system
HDFSSourceFileSystemControllerApi UpdateSourceHdfsFileSystem Patch /fs/sources/hdfs/{fileSystemId} Update a Hadoop source file system
HDFSTargetFileSystemControllerApi AddTargetHdfsFileSystem Post /fs/targets/hdfs/{fileSystemId} Add a new target Hadoop target file system
HDFSTargetFileSystemControllerApi UpdateTargetHdfsFileSystem Patch /fs/targets/hdfs/{fileSystemId} Update a target Hadoop target file system
InfoControllerApi GetNodeId Get /info/nodeID Get LiveData Migrator Node ID
InfoControllerApi GetVersion Get /info Get information on LiveData Migrator instance
LicenseControllerApi FetchConsumptionLicense Get /license/components/consumption Get Consumption License Component for LiveData Migrator
LicenseControllerApi FetchLicense Get /license Get License for LiveData Migrator
LicenseControllerApi FetchLicenseComponents Get /license/components Get License Components for LiveData Migrator
LicenseControllerApi FetchLicenseStatus Get /license/status Get License Status for LiveData Migrator
LicenseControllerApi FetchLicenseValid Get /license/valid Get whether License is valid for LiveData Migrator
LicenseControllerApi FetchMeteredLicense Get /license/components/metered Get Metered License Component for LiveData Migrator
LicenseControllerApi FetchTrialLicense Get /license/components/trial Get Trial License Component for LiveData Migrator
LicenseControllerApi FetchVolumeLicense Get /license/components/volume Get Volume License Component for LiveData Migrator
LicenseControllerApi UpdateLicense Post /license Update License for LiveData Migrator
LocalSourceFileSystemControllerApi AddSourceLocalFileSystem Post /fs/sources/local/{fileSystemId} Add a new Local source file system
LocalSourceFileSystemControllerApi UpdateSourceLocalFileSystem Patch /fs/sources/local/{fileSystemId} Update a Local source file system
LocalTargetFileSystemControllerApi AddTargetLocalFileSystem Post /fs/targets/local/{fileSystemId} Add a new target Local file system
LocalTargetFileSystemControllerApi UpdateTargetLocalFileSystem Patch /fs/targets/local/{fileSystemId} Update a target Local file system
MeteringControllerApi FetchMeteringLicense Get /metering/license Get Metered License for LiveData Migrator
MeteringControllerApi FetchMeteringStats Get /metering/stats Get metering statistics for LiveData Migrator
MeteringControllerApi GetMeteringStatsAndExtendLicense Put /metering Get metering statistics for LiveData Migrator and extend license
MigrationControllerApi AddExclusionToMigration Put /migrations/{migrationId}/exclusions/{exclusionId} Add exclusion to migration
MigrationControllerApi AddPendingRegionToMigration Post /migrations/{migrationId}/addPendingRegion Add a path as a pending region to migration, so LDM will rescan that path.
MigrationControllerApi CheckMigrationPathMappings Post /migrations/{migrationId}/checkMigrationPathMappings Check migration path mappings
MigrationControllerApi ClearMigrations Delete /migrations Delete all migrations
MigrationControllerApi DeleteExclusionFromMigration Delete /migrations/{migrationId}/exclusions/{exclusionId} Remove exclusion from migration
MigrationControllerApi DeleteMigration Delete /migrations/{migrationId} Delete migration for given migration ID
MigrationControllerApi DeleteMigrationWithAssets Delete /migrations/{migrationId}/withAssets Delete migration for given migration ID along with its assets
MigrationControllerApi FetchMigration Get /migrations/{migrationId} Get migration for given migration ID
MigrationControllerApi GetOldestIncompleteWorkItem Get /migrations/{migrationId}/oldestIncompleteWorkItem Get the oldest incomplete work item for a Migration.
MigrationControllerApi GetOldestIncompleteWorkItems Get /migrations/oldestIncompleteWorkItems Get a list of oldest incomplete work items across all migrations.
MigrationControllerApi GetPendingRegionsForMigration Get /migrations/{migrationId}/pendingRegions Get the PendingRegions for a Migration.
MigrationControllerApi ListAutoSourceCleanupQueuedPaths Get /migrations/{migrationId}/autoSourceCleanupQueuedPaths List the top 10000 Auto-source Cleanup Paths Queued for deletion.
MigrationControllerApi ListMigration Get /migrations List all migrations
MigrationControllerApi ListMigrationErrors Get /migrations/{migrationId}/failures List the last 10000 files which failed to migrate
MigrationControllerApi NewMigrationWithId Put /migrations/{migrationId} Add a new migration
MigrationControllerApi ResetMigration Post /migrations/{migrationId}/reset Reset migration for given migration ID
MigrationControllerApi ResumeMigration Post /migrations/{migrationId}/resume Resume migration for given migration ID
MigrationControllerApi StartMigration Post /migrations/{migrationId}/start Start migration for given migration ID
MigrationControllerApi StopAllMigrations Post /migrations/stop Stop all migrations
MigrationControllerApi StopMigration Post /migrations/{migrationId}/stop Stop migration for given migration ID
MigrationControllerApi ToggleMigrationDeletionMode Put /migrations/{migrationId}/toggleDeletionMode Toggle the migration deletion mode
MigrationControllerApi UpdateMigrationMaxPendingRegions Put /migrations/{migrationId}/maxPendingRegions/{maxPendingRegions} Update the maximum number of pending regions for a migration.
MigrationControllerApi UpdateMigrationMaxUnscheduledEvents Put /migrations/{migrationId}/maxStoppedUnscheduledEventBuffer/{maxEvents} Update the maximum number of unscheduled events to store for a migration if it is stopped.
MigrationControllerApi UpdateMigrationProperties Patch /migrations/{migrationId} Update a migration's additional properties
MigrationGateControllerApi BulkCheckClosedGates Post /gates/gate/bulk/check Bulk check for closed Gates by their ID's
MigrationGateControllerApi CheckClosedGates Get /gates/gate/check Check for closed Gates in bulk
MigrationGateControllerApi CloseMigrationGate Put /gates/gate/close Close a Gate by its ID
MigrationGateControllerApi CreateMigrationGate Put /gates/gate Request a gate on a given migration by path
MigrationGateControllerApi DeleteAllMigrationGates Delete /gates/gate/deleteAll Delete all Migration Gates
MigrationGateControllerApi DeleteBulkMigrationGates Post /gates/gate/bulk/delete Bulk delete migration gates by their ID's
MigrationGateControllerApi DeleteMigrationGates Delete /gates/gate Delete a Gate by its ID
MigrationGateControllerApi GetBulkMigrationGates Post /gates/gate/bulk Check status of a number of gates by their ID's
MigrationGateControllerApi GetMigrationGates Get /gates/gate Check status of a gate by its ID
MigrationPathStatusControllerApi GetPathStatus Get /migration-path-status Displays information on a path in a current migration.
NotificationControllerApi Atom Get /notifications/atom Get Atom feed for Notifications
NotificationControllerApi FetchNotification Get /notifications/{notificationId} Get a Notification
NotificationControllerApi FetchNotifications Get /notifications Notifications
PathMappingControllerApi CreateMapping Put /transformations/mappings Create a Mapping
PathMappingControllerApi Delete Delete /transformations/mappings/{id} Delete a Mapping
PathMappingControllerApi FetchAll Get /transformations/mappings Get all Mappings
PathMappingControllerApi FetchMapping Get /transformations/mappings/{id} Fetch a Mapping
PreviewFeatureControllerApi GetPreviewFeatureStatus Get /preview Get all preview features
RequeuingActionsControllerApi CancelRequeuingAction Post /requeuing-actions/queuing/{migrationId}/{actionId}/cancel Remove requeue action from migration
RequeuingActionsControllerApi GetAllRequeuingActions Get /requeuing-actions/queuing Get all requeuing actions
RequeuingActionsControllerApi GetAllRequeuingActionsStats Get /requeuing-actions/stats Get all requeuing actions stats
RequeuingActionsControllerApi GetMigrationRequeuingActions Get /requeuing-actions/queuing/{migrationId} Get all requeuing actions for specific migration
RequeuingActionsControllerApi GetMigrationRequeuingActionsStats Get /requeuing-actions/stats/{migrationId} Get all requeuing actions stats for specific migration
RequeuingActionsControllerApi GetRequeuingAction Get /requeuing-actions/queuing/{migrationId}/{actionId} Get requeue action by migration ID and action ID
S3aSourceFileSystemControllerApi AddSourceS3aFileSystem Post /fs/sources/s3a/{fileSystemId} Add a new source S3a file system
S3aSourceFileSystemControllerApi UpdateSourceS3aFileSystem Patch /fs/sources/s3a/{fileSystemId} Update a source S3a file system
S3aTargetFileSystemControllerApi AddTargetS3aFileSystem Post /fs/targets/s3a/{fileSystemId} Add a new target S3a file system
S3aTargetFileSystemControllerApi UpdateTargetS3aFileSystem Patch /fs/targets/s3a/{fileSystemId} Update a target S3a file system
SourceCleanupControllerApi DeleteSourceCleanupReport Delete /source-cleanup/reports/{migrationId} Delete source cleanup report(s) for a given migration ID and report name
SourceCleanupControllerApi GetOrphanedCleanupReportsList Get /source-cleanup/orphaned-reports Get a list of the metadata for all orphaned deletion reports
SourceCleanupControllerApi GetSourceCleanupReport Get /source-cleanup/reports/{migrationId} Get a source cleanup report for a given migration ID and report name
SourceCleanupControllerApi GetSourceCleanupReportsList Get /source-cleanup/{migrationId}/reports Get the metadata of the available source cleanup reports for the given Migration
SourceCleanupControllerApi PauseDelayedDeletionCacheReader Post /source-cleanup/pauseDelayedDeletionCacheReader Pause the Delayed Deletion Cache Reader from deleting files
SourceCleanupControllerApi ResumeDelayedDeletionCacheReader Post /source-cleanup/resumeDelayedDeletionCacheReader Resume the Delayed Deletion Cache Reader
SourceFileSystemControllerApi ClearSourceFileSystems Delete /fs/sources Delete all source file systems
SourceFileSystemControllerApi DeleteSourceFileSystem Delete /fs/sources/{sourceId} Delete source file system for given ID
SourceFileSystemControllerApi GetSourceAutoDiscoverMessage Get /fs/sources/auto-discover-message Get auto-discover file system message
SourceFileSystemControllerApi GetSourceAutoDiscoverStatus Get /fs/sources/auto-discover-status Get auto-discover file system status object
SourceFileSystemControllerApi GetSourceFileSystem Get /fs/sources/{sourceId} Get source file system for given ID
SourceFileSystemControllerApi ListSourceFileSystems Get /fs/sources List all source filesystems
StatisticsControllerApi FetchAllCurrentMigrationStats Get /stats/current Get current Stats for all migrations
StatisticsControllerApi FetchCurrentMigrationStats Get /stats/current/{migrationId} Get current Stats for given migration ID
StatisticsControllerApi FetchDiagnostics Get /stats/filetrackers Get File Trackers
StatisticsControllerApi FetchDiagnosticsActive Get /stats/filetrackers/active Get File Trackers for active transfers
StatisticsControllerApi FetchDiagnosticsActiveId Get /stats/filetrackers/active/{progressId} Get File Tracker for an active transfer
StatisticsControllerApi FetchDiagnosticsActiveIdBuckets Get /stats/filetrackers/active/{progressId}/buckets Get File Tracker Bytes per Second Buckets
StatisticsControllerApi FetchDiagnosticsComplete Get /stats/filetrackers/complete Get File Trackers for Completed Transfers.
StatisticsControllerApi FetchFileSizeDistribution Get /stats/filetrackers/fileSizes Get Transferred File Size Distribution.
StatisticsControllerApi FetchFileSizeDistributionActive Get /stats/filetrackers/active/fileSizes Get Active Transfer File Size Distribution.
StatisticsControllerApi FetchFileTransferRatesDistribution Get /stats/filetrackers/fileTransferRates Get File Transfer Rates Distribution.
StatisticsControllerApi FetchFileTransferRatesDistributionActive Get /stats/filetrackers/active/fileTransferRates Get Active File Transfer Rates Distribution.
StatisticsControllerApi FetchMigrationInfo Get /stats/migrationInfo/{migrationId} Get stats information for the given migration ID
StatisticsControllerApi FetchMigrationStats Get /stats/{migrationId} Get Stats over time for given migration ID
StatisticsControllerApi FetchMigrationSummary Get /stats/migrationSummary Get migrations summary
StatisticsControllerApi FetchThroughputInLastSecs Get /stats/throughputInLastSecs/{nSecs} Get throughput stats for all migrations during last N seconds
StatisticsControllerApi FetchThroughputSummary Get /stats/throughputSummary Get throughput summary
StatisticsControllerApi FetchTotalRollingStats Get /stats Get rolling stats over time for all migrations
StatisticsControllerApi FetchTotalStats Get /stats/cumulative Get cumulative total stats for all migrations
StatisticsControllerApi LastExcludedEvents Get /stats/excludedEvents Get most recent 1000 excluded events.
TargetFileSystemControllerApi ClearTargetFileSystems Delete /fs/targets Delete all target file systems. NOTE this endpoint is currently for test purposes only.
TargetFileSystemControllerApi DeleteTargetFileSystem Delete /fs/targets/{targetId} Delete target file system for given ID
TargetFileSystemControllerApi GetAvailableFileSystems Get /fs/targets/availableFileSystems List all available file systems
TargetFileSystemControllerApi GetFileSystem Get /fs/targets/{targetId} Get target file system for given ID
TargetFileSystemControllerApi ListTargetFileSystems Get /fs/targets List all target file systems
ThreadsControllerApi FetchThreadDump Get /threads Get Thread Dump
ThreadsControllerApi FetchThreadStates Get /threads/states Get Thread State Summary
VerificationControllerApi CancelVerification Post /verifications/{verificationId}/cancel Cancel verification with given ID
VerificationControllerApi DeleteVerification Delete /verifications/{verificationId} Delete verification with given ID
VerificationControllerApi FetchAllFilteredVerifications Get /verifications/filtered Get all Verifications filtered by migrationId and/or verification status
VerificationControllerApi FetchAllVerifications Get /verifications Get all Verifications
VerificationControllerApi GetVerification Get /verifications/{verificationId} Get verification for given ID
VerificationControllerApi GetVerificationReport Get /verifications/reports/{verificationId} Get verification report for a given ID
VerificationControllerApi GetVerificationReportsList Get /verifications/{verificationId}/reports Get the metadata for the available reports for the given verification
VerificationControllerApi TriggerVerification Put /verifications Trigger a new Verification

Documentation For Models

Documentation For Authorization

Endpoints do not require authorization.

Author

Documentation

Overview

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

* LiveData Migrator * * LiveData Migrator API Documentation * * API version: 3.3.6 * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)

Index

Constants

This section is empty.

Variables

View Source
var (
	// ContextOAuth2 takes a oauth2.TokenSource as authentication for the request.
	ContextOAuth2 = contextKey("token")

	// ContextBasicAuth takes BasicAuth as authentication for the request.
	ContextBasicAuth = contextKey("basic")

	// ContextAccessToken takes a string oauth2 access token as authentication for the request.
	ContextAccessToken = contextKey("accesstoken")

	// ContextAPIKey takes an APIKey as authentication for the request
	ContextAPIKey = contextKey("apikey")
)
View Source
var HttpStatusMap = map[int]HttpStatus{
	100: "CONTINUE",
	101: "SWITCHING_PROTOCOLS",
	102: "PROCESSING",
	103: "CHECKPOINT",
	200: "OK",
	201: "CREATED",
	202: "ACCEPTED",
	203: "NON_AUTHORITATIVE_INFORMATION",
	204: "NO_CONTENT",
	205: "RESET_CONTENT",
	206: "PARTIAL_CONTENT",
	207: "MULTI_STATUS",
	208: "ALREADY_REPORTED",
	226: "IM_USED",
	300: "MULTIPLE_CHOICES",
	301: "MOVED_PERMANENTLY",
	302: "FOUND / MOVED_TEMPORARILY",
	303: "SEE_OTHER",
	304: "NOT_MODIFIED",
	305: "USE_PROXY",
	307: "TEMPORARY_REDIRECT",
	308: "PERMANENT_REDIRECT",
	400: "BAD_REQUEST",
	401: "UNAUTHORIZED",
	402: "PAYMENT_REQUIRED",
	403: "FORBIDDEN",
	404: "NOT_FOUND",
	405: "METHOD_NOT_ALLOWED",
	406: "NOT_ACCEPTABLE",
	407: "PROXY_AUTHENTICATION_REQUIRED",
	408: "REQUEST_TIMEOUT",
	409: "CONFLICT",
	410: "GONE",
	411: "LENGTH_REQUIRED",
	412: "PRECONDITION_FAILED",
	413: "PAYLOAD_TOO_LARGE",
	414: "URI_TOO_LONG",
	415: "UNSUPPORTED_MEDIA_TYPE",
	416: "REQUESTED_RANGE_NOT_SATISFIABLE",
	417: "EXPECTATION_FAILED",
	418: "I_AM_A_TEAPOT",
	419: "INSUFFICIENT_SPACE_ON_RESOURCE",
	420: "METHOD_FAILURE",
	421: "DESTINATION_LOCKED",
	422: "UNPROCESSABLE_ENTITY",
	423: "LOCKED",
	424: "FAILED_DEPENDENCY",
	425: "TOO_EAERLY",
	426: "UPGRADE_REQUIRED",
	428: "PRECONDITION_REQUIRED",
	429: "TOO_MANY_REQUESTS",
	431: "REQUEST_HEADER_FIELD_TOO_LARGE",
	451: "UNAVAILABLE_FOR_LEGAL_REASONS",
	500: "INTERNAL_SERVER_ERROR",
	501: "NOT_IMPLEMENTED",
	502: "BAD_GATEWAY",
	503: "SERVICE_UNAVAILABLE",
	504: "GATEWAY_TIMEOUT",
	505: "HTTP_VERSION_NOT_SUPPORTED",
	506: "VARIANT_ALSO_NEGOTIATES",
	507: "INSUFFICIENT_STORAGE",
	508: "LOOP_DETECTED",
	509: "BANDWIDTH_LIMIT_EXCEEDED",
	510: "NOT_EXTENDED",
	511: "NETWORK_AUTHENTICATION_REQUIRED",
}

Functions

func CacheExpires

func CacheExpires(r *http.Response) time.Time

CacheExpires helper function to determine remaining time before repeating a request.

Types

type ADLS2SourceFileSystemControllerApiAddAdls2SourceFileSystemServicePrincipalOpts

type ADLS2SourceFileSystemControllerApiAddAdls2SourceFileSystemServicePrincipalOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2SourceFileSystemControllerApiAddSourceAdls2FileSystemOpts

type ADLS2SourceFileSystemControllerApiAddSourceAdls2FileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2SourceFileSystemControllerApiService

type ADLS2SourceFileSystemControllerApiService service

type ADLS2SourceFileSystemControllerApiUpdateAdls2SourceFileSystemServicePrincipalOpts

type ADLS2SourceFileSystemControllerApiUpdateAdls2SourceFileSystemServicePrincipalOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2SourceFileSystemControllerApiUpdateSourceAdls2FileSystemOpts

type ADLS2SourceFileSystemControllerApiUpdateSourceAdls2FileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2TargetFileSystemControllerApiAddAdls2FileSystemOpts

type ADLS2TargetFileSystemControllerApiAddAdls2FileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2TargetFileSystemControllerApiAddAdls2FileSystemServicePrincipalOpts

type ADLS2TargetFileSystemControllerApiAddAdls2FileSystemServicePrincipalOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2TargetFileSystemControllerApiService

type ADLS2TargetFileSystemControllerApiService service

func (*ADLS2TargetFileSystemControllerApiService) AddAdls2FileSystem

func (*ADLS2TargetFileSystemControllerApiService) UpdateAdls2FileSystem

type ADLS2TargetFileSystemControllerApiUpdateAdls2FileSystemOpts

type ADLS2TargetFileSystemControllerApiUpdateAdls2FileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type ADLS2TargetFileSystemControllerApiUpdateAdls2FileSystemServicePrincipalOpts

type ADLS2TargetFileSystemControllerApiUpdateAdls2FileSystemServicePrincipalOpts struct {
	PropertiesFiles optional.Interface
}

type APIClient

type APIClient struct {
	ADLS2SourceFileSystemControllerApi *ADLS2SourceFileSystemControllerApiService

	ADLS2TargetFileSystemControllerApi *ADLS2TargetFileSystemControllerApiService

	BackupsControllerApi *BackupsControllerApiService

	BandwidthPolicyControllerApi *BandwidthPolicyControllerApiService

	ConfigurationControllerApi *ConfigurationControllerApiService

	ConsumptionControllerApi *ConsumptionControllerApiService

	DataAgentDiagnosticsControllerApi *DataAgentDiagnosticsControllerApiService

	DataAgentStatisticsControllerApi *DataAgentStatisticsControllerApiService

	DataAgentsControllerApi *DataAgentsControllerApiService

	DiagnosticsControllerApi *DiagnosticsControllerApiService

	EmailNotificationControllerApi *EmailNotificationControllerApiService

	ExclusionsControllerApi *ExclusionsControllerApiService

	FileSystemControllerApi *FileSystemControllerApiService

	FilesSystemHealthControllerApi *FilesSystemHealthControllerApiService

	GCSSourceFileSystemControllerApi *GCSSourceFileSystemControllerApiService

	GCSTargetFileSystemControllerApi *GCSTargetFileSystemControllerApiService

	HDFSSourceFileSystemAutodiscoveryControllerApi *HDFSSourceFileSystemAutodiscoveryControllerApiService

	HDFSSourceFileSystemControllerApi *HDFSSourceFileSystemControllerApiService

	HDFSTargetFileSystemControllerApi *HDFSTargetFileSystemControllerApiService

	InfoControllerApi *InfoControllerApiService

	LicenseControllerApi *LicenseControllerApiService

	LocalSourceFileSystemControllerApi *LocalSourceFileSystemControllerApiService

	LocalTargetFileSystemControllerApi *LocalTargetFileSystemControllerApiService

	MeteringControllerApi *MeteringControllerApiService

	MigrationControllerApi *MigrationControllerApiService

	MigrationGateControllerApi *MigrationGateControllerApiService

	MigrationPathStatusControllerApi *MigrationPathStatusControllerApiService

	NotificationControllerApi *NotificationControllerApiService

	PathMappingControllerApi *PathMappingControllerApiService

	PreviewFeatureControllerApi *PreviewFeatureControllerApiService

	RequeuingActionsControllerApi *RequeuingActionsControllerApiService

	S3aSourceFileSystemControllerApi *S3aSourceFileSystemControllerApiService

	S3aTargetFileSystemControllerApi *S3aTargetFileSystemControllerApiService

	SourceCleanupControllerApi *SourceCleanupControllerApiService

	SourceFileSystemControllerApi *SourceFileSystemControllerApiService

	StatisticsControllerApi *StatisticsControllerApiService

	TargetFileSystemControllerApi *TargetFileSystemControllerApiService

	ThreadsControllerApi *ThreadsControllerApiService

	VerificationControllerApi *VerificationControllerApiService
	// contains filtered or unexported fields
}

APIClient manages communication with the LiveData Migrator API v3.3.6 In most cases there should be only one, shared, APIClient.

func NewAPIClient

func NewAPIClient(cfg *Configuration) *APIClient

NewAPIClient creates a new API client. Requires a userAgent string describing your application. optionally a custom http.Client to allow for advanced features such as caching.

func (*APIClient) ChangeBasePath

func (c *APIClient) ChangeBasePath(path string)

Change base path to allow switching to mocks

type APIKey

type APIKey struct {
	Key    string
	Prefix string
}

APIKey provides API key based authentication to a request passed via context using ContextAPIKey

type APIResponse

type APIResponse struct {
	*http.Response `json:"-"`
	Message        string `json:"message,omitempty"`
	// Operation is the name of the swagger operation.
	Operation string `json:"operation,omitempty"`
	// RequestURL is the request URL. This value is always available, even if the
	// embedded *http.Response is nil.
	RequestURL string `json:"url,omitempty"`
	// Method is the HTTP method used for the request.  This value is always
	// available, even if the embedded *http.Response is nil.
	Method string `json:"method,omitempty"`
	// Payload holds the contents of the response body (which may be nil or empty).
	// This is provided here as the raw response.Body() reader will have already
	// been drained.
	Payload []byte `json:"-"`
}

func NewAPIResponse

func NewAPIResponse(r *http.Response) *APIResponse

func NewAPIResponseWithError

func NewAPIResponseWithError(errorMessage string) *APIResponse

type ActionStoreDiagnostic

type ActionStoreDiagnostic struct {
	TimeStamp             int64  `json:"timeStamp,omitempty"`
	Type_                 string `json:"type"`
	TotalUnExecutedEvents int64  `json:"totalUnExecutedEvents,omitempty"`
	MaxUnexecutedEvents   int64  `json:"maxUnexecutedEvents,omitempty"`
	MigrationId           string `json:"migrationId,omitempty"`
	Id                    string `json:"id,omitempty"`
}

type ActionType

type ActionType string
const (
	CREATE_ActionType                   ActionType = "CREATE"
	MIGRATION_ActionType                ActionType = "MIGRATION"
	MARKER_ActionType                   ActionType = "MARKER"
	NIL__ActionType                     ActionType = "NIL"
	UNLINK_ActionType                   ActionType = "UNLINK"
	RESCAN_ActionType                   ActionType = "RESCAN"
	RENAME_ActionType                   ActionType = "RENAME"
	METADATA_ActionType                 ActionType = "METADATA"
	DELAY_ActionType                    ActionType = "DELAY"
	RESCAN_UNLINK_ActionType            ActionType = "RESCAN_UNLINK"
	GATE_ActionType                     ActionType = "GATE"
	LOCK_ActionType                     ActionType = "LOCK"
	VERIFY_ActionType                   ActionType = "VERIFY"
	MKDIRS_ActionType                   ActionType = "MKDIRS"
	NOT_PRESENT_ActionType              ActionType = "NOT_PRESENT"
	IMMEDIATE_SOURCE_CLEANUP_ActionType ActionType = "IMMEDIATE_SOURCE_CLEANUP"
	DELAYED_SOURCE_CLEANUP_ActionType   ActionType = "DELAYED_SOURCE_CLEANUP"
)

List of ActionType

type Adls2ServicePrincipalFilesystemProperties

type Adls2ServicePrincipalFilesystemProperties struct {
	// Storage account name
	AccountName string `json:"accountName,omitempty"`
	// OAuth Client ID
	OauthClientId string `json:"oauthClientId,omitempty"`
	// OAuth Client Secret
	OauthClientSecret string `json:"oauthClientSecret,omitempty"`
	// OAuth Client Endpoint
	OauthClientEndpoint string `json:"oauthClientEndpoint,omitempty"`
	// Container name
	ContainerName string `json:"containerName,omitempty"`
	// Adls2 endpoint for current account
	Endpoint string `json:"endpoint,omitempty"`
	// Insecure connection using abfs scheme
	Insecure bool `json:"insecure,omitempty"`
	// Additional filesystem properties
	AdditionalProperties map[string]string `json:"additionalProperties,omitempty"`
}

ADLS2 file system properties, with service principal authentication

type Adls2SharedKeyFilesystemProperties

type Adls2SharedKeyFilesystemProperties struct {
	// Storage account name
	AccountName string `json:"accountName,omitempty"`
	// Shared key
	SharedKey string `json:"sharedKey,omitempty"`
	// Container name
	ContainerName string `json:"containerName,omitempty"`
	// Insecure connection using abfs scheme
	Insecure bool `json:"insecure,omitempty"`
	// Adls2 endpoint for current account
	Endpoint string `json:"endpoint,omitempty"`
	// Additional filesystem properties
	AdditionalProperties map[string]string `json:"additionalProperties,omitempty"`
}

ADLS2 file system properties, with shared key authentication

type AllMigrationsRollingStats

type AllMigrationsRollingStats struct {
	TimeStampLastUpdateInBucketPeriod int64            `json:"timeStampLastUpdateInBucketPeriod,omitempty"`
	BucketPeriod                      string           `json:"bucketPeriod,omitempty"`
	MigrationStats                    *MigrationStats  `json:"migrationStats,omitempty"`
	TimeStampLastUpdateInBucketDate   string           `json:"timeStampLastUpdateInBucketDate,omitempty"`
	StartOfBucketPeriodTimeStamp      int64            `json:"startOfBucketPeriodTimeStamp,omitempty"`
	StartOfBucketPeriodTimeDate       string           `json:"startOfBucketPeriodTimeDate,omitempty"`
	FilesPerSecondForPeriod           float32          `json:"filesPerSecondForPeriod,omitempty"`
	DirsPerSecondForPeriod            float32          `json:"dirsPerSecondForPeriod,omitempty"`
	RawBytesPerSecondForPeriod        float32          `json:"rawBytesPerSecondForPeriod,omitempty"`
	SuccessfulBytesPerSecondForPeriod float32          `json:"successfulBytesPerSecondForPeriod,omitempty"`
	FileCountBySizePerSecondForPeriod map[string]int64 `json:"fileCountBySizePerSecondForPeriod,omitempty"`
}

type AssetDeletionStats

type AssetDeletionStats struct {
	Total        int32 `json:"total,omitempty"`
	Deleted      int32 `json:"deleted,omitempty"`
	BytesDeleted int64 `json:"bytesDeleted,omitempty"`
}

type AutoDiscoverFsStatus

type AutoDiscoverFsStatus struct {
	Message   string `json:"message,omitempty"`
	ErrorCode int32  `json:"errorCode,omitempty"`
}

type BackupConfigInfo

type BackupConfigInfo struct {
	BackupsLocation  string          `json:"backupsLocation,omitempty"`
	LastSuccessfulTs int64           `json:"lastSuccessfulTs,omitempty"`
	BackupSchedule   *BackupSchedule `json:"backupSchedule,omitempty"`
	StoredFilePaths  []string        `json:"storedFilePaths,omitempty"`
}

type BackupEntry

type BackupEntry struct {
	CreatedAt       int64  `json:"createdAt,omitempty"`
	Size            int64  `json:"size,omitempty"`
	MigrationsCount int32  `json:"migrationsCount,omitempty"`
	BackupName      string `json:"backupName,omitempty"`
}

type BackupSchedule

type BackupSchedule struct {
	Enabled       bool  `json:"enabled,omitempty"`
	PeriodMinutes int32 `json:"periodMinutes,omitempty"`
}

type BackupsControllerApiGetBackupsListOpts

type BackupsControllerApiGetBackupsListOpts struct {
	Limit optional.Int32
}

type BackupsControllerApiService

type BackupsControllerApiService service

func (*BackupsControllerApiService) CreateBackup

BackupsControllerApiService Generate a Backup.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return BackupEntry

func (*BackupsControllerApiService) GetBackupByName

func (a *BackupsControllerApiService) GetBackupByName(ctx context.Context, backupName string) (BackupEntry, *http.Response, error)

BackupsControllerApiService

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param backupName provided backup file name

@return BackupEntry

func (*BackupsControllerApiService) GetBackupConfig

BackupsControllerApiService backup config entity

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return BackupConfigInfo

func (*BackupsControllerApiService) GetBackupSchedule

BackupsControllerApiService Returns current schedule configuration

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return BackupSchedule

func (*BackupsControllerApiService) GetBackupsList

func (*BackupsControllerApiService) RestoreBackup

func (a *BackupsControllerApiService) RestoreBackup(ctx context.Context, backupName string) (BackupEntry, *http.Response, error)

BackupsControllerApiService Restore application state by backup by provided backup ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param backupName Unique identifier of backup entry

@return BackupEntry

func (*BackupsControllerApiService) UpdateSchedule

BackupsControllerApiService Update current schedule.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param body Backup schedule entity for update

@return BackupSchedule

type BandwidthPolicy

type BandwidthPolicy struct {
	Id                  string `json:"id,omitempty"`
	Description         string `json:"description,omitempty"`
	LimitBytesPerSecond int64  `json:"limitBytesPerSecond,omitempty"`
}

type BandwidthPolicyControllerApiService

type BandwidthPolicyControllerApiService service

func (*BandwidthPolicyControllerApiService) GetApplicationBandwidthPolicy

func (a *BandwidthPolicyControllerApiService) GetApplicationBandwidthPolicy(ctx context.Context) (BandwidthPolicy, *http.Response, error)

BandwidthPolicyControllerApiService Get the application's bandwidth policy

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return BandwidthPolicy

func (*BandwidthPolicyControllerApiService) ResetApplicationBandwidthPolicy

func (a *BandwidthPolicyControllerApiService) ResetApplicationBandwidthPolicy(ctx context.Context) (BandwidthPolicy, *http.Response, error)

BandwidthPolicyControllerApiService Restore default, unlimited application bandwidth policy

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return BandwidthPolicy

func (*BandwidthPolicyControllerApiService) UpdateApplicationBandwidthPolicy

func (a *BandwidthPolicyControllerApiService) UpdateApplicationBandwidthPolicy(ctx context.Context, limit int64, unit FileSizeUnit) (BandwidthPolicy, *http.Response, error)

BandwidthPolicyControllerApiService Set the application's bandwidth policy. A limit of -1 will mean no bandwidth limit is imposed.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param limit Overall application bandwidth limit to apply.
  • @param unit Unit of bandwidth - bytes per second

@return BandwidthPolicy

type BasicAuth

type BasicAuth struct {
	UserName string `json:"userName,omitempty"`
	Password string `json:"password,omitempty"`
}

BasicAuth provides basic http authentication to a request passed via context using ContextBasicAuth

type Configuration

type Configuration struct {
	BasePath      string            `json:"basePath,omitempty"`
	Host          string            `json:"host,omitempty"`
	Scheme        string            `json:"scheme,omitempty"`
	DefaultHeader map[string]string `json:"defaultHeader,omitempty"`
	UserAgent     string            `json:"userAgent,omitempty"`
	HTTPClient    *http.Client
}

func NewConfiguration

func NewConfiguration() *Configuration

func (*Configuration) AddDefaultHeader

func (c *Configuration) AddDefaultHeader(key string, value string)

type ConfigurationControllerApiService

type ConfigurationControllerApiService service

func (*ConfigurationControllerApiService) GetConfigurationProperties

func (a *ConfigurationControllerApiService) GetConfigurationProperties(ctx context.Context) ([]Configuration, *http.Response, error)

ConfigurationControllerApiService Get all configuration properties

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Configuration

func (*ConfigurationControllerApiService) GetConfigurationProperty

func (a *ConfigurationControllerApiService) GetConfigurationProperty(ctx context.Context, key string) (Configuration, *http.Response, error)

ConfigurationControllerApiService Get value for given configuration property

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param key Key - property name to be get

@return Configuration

func (*ConfigurationControllerApiService) SetConfigurationProperty

func (a *ConfigurationControllerApiService) SetConfigurationProperty(ctx context.Context, key string, value string) (*http.Response, error)

ConfigurationControllerApiService Set key/value configuration property

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param key Key - property name to be set
  • @param value Value - value to set corresponding property to

type ConsumptionControllerApiService

type ConsumptionControllerApiService service

func (*ConsumptionControllerApiService) ExtendLicense

func (a *ConsumptionControllerApiService) ExtendLicense(ctx context.Context, token string) (bool, *http.Response, error)

ConsumptionControllerApiService Extend consumption license expiry time

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param token Token used to extend license

@return bool

func (*ConsumptionControllerApiService) SwitchToConsumption

func (a *ConsumptionControllerApiService) SwitchToConsumption(ctx context.Context) (*http.Response, error)

ConsumptionControllerApiService Change license type to consumption

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

type ConsumptionLicense

type ConsumptionLicense struct {
	Warning            string `json:"warning,omitempty"`
	LicenseType        string `json:"licenseType,omitempty"`
	InvalidReason      string `json:"invalidReason,omitempty"`
	IsValid            bool   `json:"isValid,omitempty"`
	LicenseStatus      string `json:"licenseStatus,omitempty"`
	Type_              string `json:"type"`
	LastTimeChecked    int64  `json:"lastTimeChecked,omitempty"`
	GracePeriodEndTime int64  `json:"gracePeriodEndTime,omitempty"`
	ExpireTime         int64  `json:"expireTime,omitempty"`
	GracePeriodDays    int64  `json:"gracePeriodDays,omitempty"`
	Consumption        bool   `json:"consumption,omitempty"`
}

type CpuLoadDiagnostic

type CpuLoadDiagnostic struct {
	TimeStamp      int64   `json:"timeStamp,omitempty"`
	Type_          string  `json:"type"`
	ProcessCpuLoad float64 `json:"processCpuLoad,omitempty"`
	ProcessCpuTime int64   `json:"processCpuTime,omitempty"`
	SystemCpuLoad  float64 `json:"systemCpuLoad,omitempty"`
}

type DataAgent

type DataAgent struct {
	Name     string             `json:"name,omitempty"`
	Host     string             `json:"host,omitempty"`
	Port     int32              `json:"port,omitempty"`
	Type_    *DataAgentType     `json:"type,omitempty"`
	Version  string             `json:"version,omitempty"`
	Healthy  bool               `json:"healthy,omitempty"`
	Health   *DataAgentHealth   `json:"health,omitempty"`
	Security *DataAgentSecurity `json:"security,omitempty"`
}

type DataAgentAddRequest

type DataAgentAddRequest struct {
	// Name of the Data Agent. Must be unique.
	Name       string `json:"name"`
	AgentToken string `json:"agentToken"`
	Host       string `json:"host,omitempty"`
}

type DataAgentDiagnosticSummary

type DataAgentDiagnosticSummary struct {
	TimeStamp                           int64  `json:"timeStamp,omitempty"`
	Type_                               string `json:"type"`
	Uptime                              int64  `json:"uptime,omitempty"`
	FsCacheSize                         int64  `json:"fsCacheSize,omitempty"`
	ActiveTransfersCount                int64  `json:"activeTransfersCount,omitempty"`
	GrpcPoolSize                        int64  `json:"grpcPoolSize,omitempty"`
	GrpcActiveThreadsCount              int64  `json:"grpcActiveThreadsCount,omitempty"`
	GrpcTaskCount                       int64  `json:"grpcTaskCount,omitempty"`
	GrpcCompletedTaskCount              int64  `json:"grpcCompletedTaskCount,omitempty"`
	ScheduledCallbackActiveThreadsCount int64  `json:"scheduledCallbackActiveThreadsCount,omitempty"`
	ScheduledCallbackTaskCount          int64  `json:"scheduledCallbackTaskCount,omitempty"`
	ScheduledCallbackCompletedTaskCount int64  `json:"scheduledCallbackCompletedTaskCount,omitempty"`
	ScheduledCallbackQueueSize          int64  `json:"scheduledCallbackQueueSize,omitempty"`
}

type DataAgentDiagnosticsControllerApiFetchAllDiagnosticsByAgentNameOpts

type DataAgentDiagnosticsControllerApiFetchAllDiagnosticsByAgentNameOpts struct {
	Kind  optional.String
	Count optional.Int32
}

type DataAgentDiagnosticsControllerApiFetchLatestDiagnosticsByAgentNameOpts

type DataAgentDiagnosticsControllerApiFetchLatestDiagnosticsByAgentNameOpts struct {
	Kind optional.String
}

type DataAgentDiagnosticsControllerApiService

type DataAgentDiagnosticsControllerApiService service

func (*DataAgentDiagnosticsControllerApiService) FetchAllDiagnosticsByAgentName

func (*DataAgentDiagnosticsControllerApiService) FetchLatestDiagnosticsByAgentName

type DataAgentDiagnosticsSnapshot

type DataAgentDiagnosticsSnapshot struct {
	TimeStamp      int64        `json:"timeStamp,omitempty"`
	CollectionTime int64        `json:"collectionTime,omitempty"`
	Diagnostics    []Diagnostic `json:"diagnostics,omitempty"`
	ImplClassName  string       `json:"implClassName"`
	AgentName      string       `json:"agentName,omitempty"`
}

type DataAgentHealth

type DataAgentHealth struct {
	LastStatusUpdateTime int64            `json:"lastStatusUpdateTime,omitempty"`
	LastHealthMessage    string           `json:"lastHealthMessage,omitempty"`
	Status               *DataAgentStatus `json:"status,omitempty"`
}

type DataAgentSecurity

type DataAgentSecurity struct {
	CaCert        string `json:"caCert,omitempty"`
	ClientCert    string `json:"clientCert,omitempty"`
	ClientCertKey string `json:"clientCertKey,omitempty"`
	ClientSecret  string `json:"clientSecret,omitempty"`
}

type DataAgentStatisticsControllerApiService

type DataAgentStatisticsControllerApiService service

func (*DataAgentStatisticsControllerApiService) GetDtaStats

DataAgentStatisticsControllerApiService Get full stats over for given Data Agent

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param agentName User-defined name of the Data Agent

@return DataAgentStatsHistory

func (*DataAgentStatisticsControllerApiService) GetDtaStatsList

DataAgentStatisticsControllerApiService Get full stats over all time for all Data Agents

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return OverallDataAgentStatsHistory

func (*DataAgentStatisticsControllerApiService) GetDtaStatsSummary

DataAgentStatisticsControllerApiService Get summary stats for given Data Agent

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param agentName User-defined name of the Data Agent

@return DataAgentStatsSummary

type DataAgentStats

type DataAgentStats struct {
	TransferredBytes       int64 `json:"transferredBytes,omitempty"`
	TransferredFiles       int64 `json:"transferredFiles,omitempty"`
	TransferFailures       int64 `json:"transferFailures,omitempty"`
	IncomingTransportBytes int64 `json:"incomingTransportBytes,omitempty"`
	OutgoingTransportBytes int64 `json:"outgoingTransportBytes,omitempty"`
}

type DataAgentStatsHistory

type DataAgentStatsHistory struct {
	AgentName                 string                     `json:"agentName,omitempty"`
	DataAgentStatsRecordStore *DataAgentStatsRecordStore `json:"dataAgentStatsRecordStore,omitempty"`
	TotalAgentStats           *DataAgentStats            `json:"totalAgentStats,omitempty"`
}

type DataAgentStatsRecord

type DataAgentStatsRecord struct {
	TimeStamp    int64           `json:"timeStamp,omitempty"`
	Stats        *DataAgentStats `json:"stats,omitempty"`
	RecordPeriod string          `json:"RecordPeriod,omitempty"`
}

type DataAgentStatsRecordStore

type DataAgentStatsRecordStore struct {
	SecondRecords []DataAgentStatsRecord `json:"secondRecords,omitempty"`
	MinuteRecords []DataAgentStatsRecord `json:"minuteRecords,omitempty"`
	HourlyRecords []DataAgentStatsRecord `json:"hourlyRecords,omitempty"`
	DailyRecords  []DataAgentStatsRecord `json:"dailyRecords,omitempty"`
}

type DataAgentStatsSummary

type DataAgentStatsSummary struct {
	LastWeekTotalBytes int64  `json:"lastWeekTotalBytes,omitempty"`
	LastDayTotalBytes  int64  `json:"lastDayTotalBytes,omitempty"`
	AgentName          string `json:"agentName,omitempty"`
}

type DataAgentStatus

type DataAgentStatus string
const (
	CONNECTED_DataAgentStatus         DataAgentStatus = "CONNECTED"
	DISCONNECTED_DataAgentStatus      DataAgentStatus = "DISCONNECTED"
	NOT_VALID_DataAgentStatus         DataAgentStatus = "NOT_VALID"
	CREDENTIALS_ERROR_DataAgentStatus DataAgentStatus = "CREDENTIALS_ERROR"
)

List of DataAgentStatus

type DataAgentType

type DataAgentType string
const (
	LOCAL_DataAgentType DataAgentType = "LOCAL"
	GRPC_DataAgentType  DataAgentType = "GRPC"
)

List of DataAgentType

type DataAgentsControllerApiAddDataAgentOpts

type DataAgentsControllerApiAddDataAgentOpts struct {
	Body optional.Interface
}

type DataAgentsControllerApiService

type DataAgentsControllerApiService service

func (*DataAgentsControllerApiService) AddDataAgent

func (*DataAgentsControllerApiService) DeleteDataAgent

func (a *DataAgentsControllerApiService) DeleteDataAgent(ctx context.Context, agentName string) (*http.Response, error)

DataAgentsControllerApiService Delete Data Transfer Agent from LM2

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param agentName Data Agent user-defined name

func (*DataAgentsControllerApiService) GetDataAgent

func (a *DataAgentsControllerApiService) GetDataAgent(ctx context.Context, agentName string) (DataAgent, *http.Response, error)

DataAgentsControllerApiService Get Data Agent with given name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param agentName Data Agent user-defined name.

@return DataAgent

func (*DataAgentsControllerApiService) GetDataAgentList

func (a *DataAgentsControllerApiService) GetDataAgentList(ctx context.Context) ([]DataAgent, *http.Response, error)

DataAgentsControllerApiService Get Data Agent list

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []DataAgent

type DataLicense

type DataLicense struct {
	Warning                 string `json:"warning,omitempty"`
	LicenseType             string `json:"licenseType,omitempty"`
	InvalidReason           string `json:"invalidReason,omitempty"`
	IsValid                 bool   `json:"isValid,omitempty"`
	LicenseStatus           string `json:"licenseStatus,omitempty"`
	Type_                   string `json:"type"`
	MigratedDataLimit       int64  `json:"migratedDataLimit,omitempty"`
	ExpiredReason           string `json:"expiredReason,omitempty"`
	LastTimeChecked         int64  `json:"lastTimeChecked,omitempty"`
	MigratedDataSize        int64  `json:"migratedDataSize,omitempty"`
	IsMigratedDataLimited   bool   `json:"isMigratedDataLimited,omitempty"`
	PercentMigratedDataUsed int32  `json:"percentMigratedDataUsed,omitempty"`
	MigratedDataRemaining   int64  `json:"migratedDataRemaining,omitempty"`
	MigratedDataLimited     bool   `json:"migratedDataLimited,omitempty"`
}

type DataTransferTiming

type DataTransferTiming struct {
	// Time to send and retrieve request/response to/from DTA on migrating file
	FileTransferNetworkOverheadNs int64 `json:"FileTransferNetworkOverheadNs,omitempty"`
	// Total time of a file migration on DTA side, the time measured from the start of grpc-method execution to transfer the file and to the time when FINISHED report will be sent to the lm2 side
	TotalFileTransferTimeNs int64 `json:"TotalFileTransferTimeNs,omitempty"`
	// Time of reporting of PREPARING state of the file migration on data agent side in nanoseconds
	FileTransferPreparingReportTimeNs int64 `json:"FileTransferPreparingReportTimeNs,omitempty"`
	// Time to map source fs from a data transfer request to a real internal one in nanoseconds
	SrcFsMapTimeNs int64 `json:"SrcFsMapTimeNs,omitempty"`
	// Time to map target fs from a data transfer request to a real internal one in nanoseconds
	TgtFsMapTimeNs int64 `json:"TgtFsMapTimeNs,omitempty"`
	// Time to initialize a source filesystem in nanoseconds
	SrcFsInitTimeNs int64 `json:"SrcFsInitTimeNs,omitempty"`
	// Time to initialize a target filesystem in nanoseconds
	TgtFsInitTimeNs int64 `json:"TgtFsInitTimeNs,omitempty"`
	// Time to get file status info from the source filesystem in nanoseconds
	FileStatusRetrievingTimeNs int64 `json:"FileStatusRetrievingTimeNs,omitempty"`
	// Time to copy filer from the source to the target on data-agent side in nanoseconds
	FileTransferTimeNs int64 `json:"FileTransferTimeNs,omitempty"`
	// Time of opening of the source fs input stream to read the data that will be migrated
	SrcInStreamOpenTimeNs int64 `json:"SrcInStreamOpenTimeNs,omitempty"`
	// Time of opening of the target fs output stream where the data will be migrated to
	TgtOutStreamOpenTimeNs int64 `json:"TgtOutStreamOpenTimeNs,omitempty"`
	// Time of closing of the source fs input stream after migrating the data or on happening some exceptions on the file transferring
	SrcInStreamCloseTimeNs int64 `json:"SrcInStreamCloseTimeNs,omitempty"`
	// Time of closing of the target fs output stream after migrating the data
	TgtOutStreamCloseTimeNs int64 `json:"TgtOutStreamCloseTimeNs,omitempty"`
	// Total time that was spent to read bytes from source fs input stream
	SrcInStreamBytesReadTimeNs int64 `json:"SrcInStreamBytesReadTimeNs,omitempty"`
	// Total time that was spent to write bytes to target fs output stream
	TgtOutStreamBytesWriteTimeNs int64 `json:"TgtOutStreamBytesWriteTimeNs,omitempty"`
}

type DateExclusion

type DateExclusion struct {
	Id                    string `json:"id,omitempty"`
	Description           string `json:"description,omitempty"`
	FsRestriction         bool   `json:"fsRestriction,omitempty"`
	SourceFsExclusion     bool   `json:"sourceFsExclusion,omitempty"`
	GlobalExclusion       bool   `json:"globalExclusion,omitempty"`
	DefaultExclusion      bool   `json:"defaultExclusion,omitempty"`
	Type_                 string `json:"type"`
	BeforeDateEpochMillis int64  `json:"beforeDateEpochMillis,omitempty"`
	BeforeDateUtc         string `json:"beforeDateUtc,omitempty"`
}

type DeletionMode

type DeletionMode string
const (
	NO_DELETION_DeletionMode        DeletionMode = "NO_DELETION"
	IMMEDIATE_DELETION_DeletionMode DeletionMode = "IMMEDIATE_DELETION"
	DELAYED_DELETION_DeletionMode   DeletionMode = "DELAYED_DELETION"
)

List of DeletionMode

type Diagnostic

type Diagnostic struct {
	TimeStamp int64  `json:"timeStamp,omitempty"`
	Type_     string `json:"type"`
}

type DiagnosticDescription

type DiagnosticDescription struct {
	DiagnosticDescription map[string]string `json:"diagnosticDescription,omitempty"`
	Kind                  string            `json:"kind,omitempty"`
}

type DiagnosticSummary

type DiagnosticSummary struct {
	TransferRateBytes10                       int64     `json:"transferRateBytes10,omitempty"`
	TransferRateBytes60                       int64     `json:"transferRateBytes60,omitempty"`
	TransferRateBytes300                      int64     `json:"transferRateBytes300,omitempty"`
	TransferRateFiles10                       int64     `json:"transferRateFiles10,omitempty"`
	TransferRateFiles60                       int64     `json:"transferRateFiles60,omitempty"`
	TransferRateFiles300                      int64     `json:"transferRateFiles300,omitempty"`
	IncomingTransportBytes10                  int64     `json:"incomingTransportBytes10,omitempty"`
	IncomingTransportBytes60                  int64     `json:"incomingTransportBytes60,omitempty"`
	IncomingTransportBytes300                 int64     `json:"incomingTransportBytes300,omitempty"`
	OutgoingTransportBytes10                  int64     `json:"outgoingTransportBytes10,omitempty"`
	OutgoingTransportBytes60                  int64     `json:"outgoingTransportBytes60,omitempty"`
	OutgoingTransportBytes300                 int64     `json:"outgoingTransportBytes300,omitempty"`
	IncomingTransportRequestAvgSizeBytes      int64     `json:"incomingTransportRequestAvgSizeBytes,omitempty"`
	OutgoingTransportRequestAvgSizeBytes      int64     `json:"outgoingTransportRequestAvgSizeBytes,omitempty"`
	IncomingDTADiagnosticsRequestAvgSizeBytes int64     `json:"incomingDTADiagnosticsRequestAvgSizeBytes,omitempty"`
	ConnectionsEstablished                    int32     `json:"connectionsEstablished,omitempty"`
	FileSizesPercentiles                      []int64   `json:"fileSizesPercentiles,omitempty"`
	FileTransferRatesPercentiles              []int64   `json:"fileTransferRatesPercentiles,omitempty"`
	ActiveFileSizesPercentiles                []int64   `json:"activeFileSizesPercentiles,omitempty"`
	ActiveFileTransferRatesPercentiles        []int64   `json:"activeFileTransferRatesPercentiles,omitempty"`
	FileTrackerLatencyPercentiles             []int64   `json:"fileTrackerLatencyPercentiles,omitempty"`
	CpuPressureSome                           []float64 `json:"cpuPressureSome,omitempty"`
	IoPressureSome                            []float64 `json:"ioPressureSome,omitempty"`
	IoPressureFull                            []float64 `json:"ioPressureFull,omitempty"`
	MemoryPressureSome                        []float64 `json:"memoryPressureSome,omitempty"`
	MemoryPressureFull                        []float64 `json:"memoryPressureFull,omitempty"`
	ActiveFileTransferCount                   int64     `json:"activeFileTransferCount,omitempty"`
	TotalActiveFileSizeToTransfer             int64     `json:"totalActiveFileSizeToTransfer,omitempty"`
	TotalActiveFileSizeTransferred            int64     `json:"totalActiveFileSizeTransferred,omitempty"`
	PullThreads                               int32     `json:"pullThreads,omitempty"`
	Uptime                                    int64     `json:"uptime,omitempty"`
	IowaitPercentage                          float64   `json:"iowaitPercentage,omitempty"`
	FailedPathsAverage                        int64     `json:"failedPathsAverage,omitempty"`
	ConnectionsTxOSBufferedBytes              int32     `json:"connectionsTxOSBufferedBytes,omitempty"`
	ConnectionsRxOSBufferedBytes              int32     `json:"connectionsRxOSBufferedBytes,omitempty"`
	ConnectionsRetransmit                     int32     `json:"connectionsRetransmit,omitempty"`
	ProcessCpuLoad                            float64   `json:"processCpuLoad,omitempty"`
	SystemCpuLoad                             float64   `json:"systemCpuLoad,omitempty"`
	ActionStoreCurrent                        int64     `json:"actionStoreCurrent,omitempty"`
	ActionStoreLargestMigration               int64     `json:"actionStoreLargestMigration,omitempty"`
	ActionStoreLargestMigrationId             string    `json:"actionStoreLargestMigrationId,omitempty"`
	ActionStoreMigrationPeak                  int64     `json:"actionStoreMigrationPeak,omitempty"`
	ActionStorePeakMigrationId                string    `json:"actionStorePeakMigrationId,omitempty"`
	MigrationsRunning                         int32     `json:"migrationsRunning,omitempty"`
	MigrationsLive                            int32     `json:"migrationsLive,omitempty"`
	MigrationsStopped                         int32     `json:"migrationsStopped,omitempty"`
	PendingRegionCurrent                      int64     `json:"pendingRegionCurrent,omitempty"`
	PendingRegionAverage                      int64     `json:"pendingRegionAverage,omitempty"`
	PendingRegionMaxMigration                 int64     `json:"pendingRegionMaxMigration,omitempty"`
	PendingRegionMaxMigrationPath             string    `json:"pendingRegionMaxMigrationPath,omitempty"`
	TotalEventAdded                           int64     `json:"totalEventAdded,omitempty"`
	TotalEventQueued                          int64     `json:"totalEventQueued,omitempty"`
	EventsBehindNameNode                      int64     `json:"eventsBehindNameNode,omitempty"`
	EventsBehindMax                           int64     `json:"eventsBehindMax,omitempty"`
	EventsBehindAverage                       int64     `json:"eventsBehindAverage,omitempty"`
	EventRPCMax                               int64     `json:"eventRPCMax,omitempty"`
	EventRPCAverage                           int64     `json:"eventRPCAverage,omitempty"`
	FailedPathsCount                          int64     `json:"failedPathsCount,omitempty"`
	RetryAverage                              int64     `json:"retryAverage,omitempty"`
	MigrationIdMostFailedPaths                string    `json:"migrationIdMostFailedPaths,omitempty"`
	MigrationCountMostFailedPaths             int64     `json:"migrationCountMostFailedPaths,omitempty"`
	RetryCount                                int64     `json:"retryCount,omitempty"`
	MigrationIdMostRetries                    string    `json:"migrationIdMostRetries,omitempty"`
	MigrationCountMostRetries                 int64     `json:"migrationCountMostRetries,omitempty"`
	TotalFilesIterated                        int64     `json:"totalFilesIterated,omitempty"`
	TotalDirsIterated                         int64     `json:"totalDirsIterated,omitempty"`
	TotalBytesIterated                        int64     `json:"totalBytesIterated,omitempty"`
	TotalFilesExcluded                        int64     `json:"totalFilesExcluded,omitempty"`
	TotalDirsExcluded                         int64     `json:"totalDirsExcluded,omitempty"`
	TotalBytesExcluded                        int64     `json:"totalBytesExcluded,omitempty"`
	GcCount                                   int64     `json:"gcCount,omitempty"`
	GcPauseTime                               int64     `json:"gcPauseTime,omitempty"`
	BusyMigration                             string    `json:"busyMigration,omitempty"`
	TotalFileTrackerCount                     int32     `json:"totalFileTrackerCount,omitempty"`
	ActiveMigrationCount                      int32     `json:"activeMigrationCount,omitempty"`
	BusyMigrationCount                        int32     `json:"busyMigrationCount,omitempty"`
	AvgFailedPaths                            int64     `json:"avgFailedPaths,omitempty"`
	AvgRetries                                int64     `json:"avgRetries,omitempty"`
	TotalMigrationPathsRequeued               int64     `json:"totalMigrationPathsRequeued,omitempty"`
}

type DiagnosticsControllerApiFetchAllDiagnosticsOpts

type DiagnosticsControllerApiFetchAllDiagnosticsOpts struct {
	Kind  optional.String
	Count optional.Int32
}

type DiagnosticsControllerApiFetchCurrentDiagnosticsOpts

type DiagnosticsControllerApiFetchCurrentDiagnosticsOpts struct {
	Kind optional.String
}

type DiagnosticsControllerApiFetchLatestDiagnosticsOpts

type DiagnosticsControllerApiFetchLatestDiagnosticsOpts struct {
	Kind optional.String
}

type DiagnosticsControllerApiService

type DiagnosticsControllerApiService service

func (*DiagnosticsControllerApiService) DumpActionStoreForMigration

func (a *DiagnosticsControllerApiService) DumpActionStoreForMigration(ctx context.Context, migrationId string) (*http.Response, error)

DiagnosticsControllerApiService To be used for debugging purposes only - dumps the ActionStore for a Migration to file.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

func (*DiagnosticsControllerApiService) FetchAllDiagnostics

func (*DiagnosticsControllerApiService) FetchCountTcpStates

func (a *DiagnosticsControllerApiService) FetchCountTcpStates(ctx context.Context) (map[string]int32, *http.Response, error)

DiagnosticsControllerApiService Get a map of total connections to their TCP state.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]int32

func (*DiagnosticsControllerApiService) FetchCurrentDiagnostics

func (*DiagnosticsControllerApiService) FetchDiagnosticsDescriptions

func (a *DiagnosticsControllerApiService) FetchDiagnosticsDescriptions(ctx context.Context) ([]DiagnosticDescription, *http.Response, error)

DiagnosticsControllerApiService Get Diagnostics Descriptions. Return the set of available Diagnostics and a description of the information they return.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []DiagnosticDescription

func (*DiagnosticsControllerApiService) FetchDiagnosticsSummary

DiagnosticsControllerApiService Get Diagnostic Summary

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return DiagnosticSummary

func (*DiagnosticsControllerApiService) FetchDiagnosticsSummaryTxt

func (a *DiagnosticsControllerApiService) FetchDiagnosticsSummaryTxt(ctx context.Context) (string, *http.Response, error)

DiagnosticsControllerApiService Get Diagnostic Summary Plain Text

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*DiagnosticsControllerApiService) FetchLatestDiagnostics

func (*DiagnosticsControllerApiService) FetchNetworkConnections

func (a *DiagnosticsControllerApiService) FetchNetworkConnections(ctx context.Context) ([]NetworkConnection, *http.Response, error)

DiagnosticsControllerApiService Get Established Connections.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []NetworkConnection

func (*DiagnosticsControllerApiService) FetchNetworkStatus

func (a *DiagnosticsControllerApiService) FetchNetworkStatus(ctx context.Context) (string, *http.Response, error)

DiagnosticsControllerApiService Get Netstat Status.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*DiagnosticsControllerApiService) FetchNetworkStatusTotals

func (a *DiagnosticsControllerApiService) FetchNetworkStatusTotals(ctx context.Context) (map[string]RxTxTotals, *http.Response, error)

DiagnosticsControllerApiService Get Connections Total Queue Sizes and ReTransmit Counts.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]RxTxTotals

type DiagnosticsSnapshot

type DiagnosticsSnapshot struct {
	TimeStamp      int64        `json:"timeStamp,omitempty"`
	CollectionTime int64        `json:"collectionTime,omitempty"`
	Diagnostics    []Diagnostic `json:"diagnostics,omitempty"`
	ImplClassName  string       `json:"implClassName"`
}

type EmailNotificationControllerApiService

type EmailNotificationControllerApiService service

func (*EmailNotificationControllerApiService) FetchEmailNotificationTypes

func (a *EmailNotificationControllerApiService) FetchEmailNotificationTypes(ctx context.Context) ([]string, *http.Response, error)

EmailNotificationControllerApiService Get email notifications types

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []string

func (*EmailNotificationControllerApiService) FetchEmailRegistrations

EmailNotificationControllerApiService Get registered email address for receiving push notifications about specific notification types

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return EmailRegistrations

func (*EmailNotificationControllerApiService) FetchSmtpConfig

EmailNotificationControllerApiService Get the current SMTP adaptor config

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return SmtpConfiguration

func (*EmailNotificationControllerApiService) SendTestEmail

func (a *EmailNotificationControllerApiService) SendTestEmail(ctx context.Context, addresses []string) (*http.Response, error)

EmailNotificationControllerApiService Send test e-mail to the specified list of recipient

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param addresses Emails of receivers

func (*EmailNotificationControllerApiService) SetEmailRegistrations

func (*EmailNotificationControllerApiService) SetSmtpConfig

type EmailNotificationControllerApiSetEmailRegistrationsOpts

type EmailNotificationControllerApiSetEmailRegistrationsOpts struct {
	Types     optional.Interface
	Addresses optional.Interface
}

type EmailNotificationControllerApiSetSmtpConfigOpts

type EmailNotificationControllerApiSetSmtpConfigOpts struct {
	AuthEnabled   optional.Bool
	Login         optional.String
	Password      optional.String
	SubjectPrefix optional.String
}

type EmailRegistrations

type EmailRegistrations struct {
	// Types of notifications that this email should be receiving
	Types []string `json:"types"`
	// Email addresses of receivers
	Addresses []string `json:"addresses"`
}

Notification receiver properties

type EnrichedMigratorEvent

type EnrichedMigratorEvent struct {
	EventType      string `json:"eventType,omitempty"`
	SrcPath        string `json:"srcPath,omitempty"`
	DestPath       string `json:"destPath,omitempty"`
	FileSize       int64  `json:"fileSize,omitempty"`
	MigrationId    string `json:"migrationId,omitempty"`
	TargetFsType   string `json:"targetFsType,omitempty"`
	Excluded       bool   `json:"excluded,omitempty"`
	ExcludedSource bool   `json:"excludedSource,omitempty"`
	ExcludedTarget bool   `json:"excludedTarget,omitempty"`
}

type ErrorCode

type ErrorCode string
const (
	FILE_SYSTEM_ALREADY_EXISTS_ErrorCode                  ErrorCode = "FILE_SYSTEM_ALREADY_EXISTS"
	FILE_SYSTEM_NOT_FOUND_ErrorCode                       ErrorCode = "FILE_SYSTEM_NOT_FOUND"
	UNSUPPORTED_VALUE_ErrorCode                           ErrorCode = "UNSUPPORTED_VALUE"
	INVALID_FILESYSTEM_PATH_ErrorCode                     ErrorCode = "INVALID_FILESYSTEM_PATH"
	FILE_SYSTEM_ROOT_PATH_NOT_FOUND_ErrorCode             ErrorCode = "FILE_SYSTEM_ROOT_PATH_NOT_FOUND"
	FILE_IO_ERROR_ErrorCode                               ErrorCode = "FILE_IO_ERROR"
	FILE_SYSTEM_ACCESS_RESTRICTED_ErrorCode               ErrorCode = "FILE_SYSTEM_ACCESS_RESTRICTED"
	FILE_NOT_FOUND_ErrorCode                              ErrorCode = "FILE_NOT_FOUND"
	INVALID_FILESYSTEM_CREDENTIALS_ErrorCode              ErrorCode = "INVALID_FILESYSTEM_CREDENTIALS"
	UNSUPPORTED_FS_EVENT_ErrorCode                        ErrorCode = "UNSUPPORTED_FS_EVENT"
	FILE_SYSTEM_INSUFFICIENT_PERMISSIONS_ErrorCode        ErrorCode = "FILE_SYSTEM_INSUFFICIENT_PERMISSIONS"
	INCOMPATIBLE_FILE_SYSTEM_ErrorCode                    ErrorCode = "INCOMPATIBLE_FILE_SYSTEM"
	FILESYSTEM_AUTHORIZATION_MISMATCH_ErrorCode           ErrorCode = "FILESYSTEM_AUTHORIZATION_MISMATCH"
	KERBEROS_AUTH_PROBLEM_ErrorCode                       ErrorCode = "KERBEROS_AUTH_PROBLEM"
	KERBEROS_INVALID_AUTH_TYPE_ErrorCode                  ErrorCode = "KERBEROS_INVALID_AUTH_TYPE"
	KERBEROS_SPECIFY_PRINCIPAL_ErrorCode                  ErrorCode = "KERBEROS_SPECIFY_PRINCIPAL"
	KERBEROS_KEYTAB_FILE_UNREADABLE_ErrorCode             ErrorCode = "KERBEROS_KEYTAB_FILE_UNREADABLE"
	KERBEROS_CREDENTIALS_ALREADY_SET_AND_IN_USE_ErrorCode ErrorCode = "KERBEROS_CREDENTIALS_ALREADY_SET_AND_IN_USE"
	AUTO_DISCOVERY_IS_DISABLED_ErrorCode                  ErrorCode = "AUTO_DISCOVERY_IS_DISABLED"
	AUTO_DISCOVERY_KERBEROS_ERROR_ErrorCode               ErrorCode = "AUTO_DISCOVERY_KERBEROS_ERROR"
	AUTO_DISCOVERY_UNKNOWN_ERROR_ErrorCode                ErrorCode = "AUTO_DISCOVERY_UNKNOWN_ERROR"
	SOURCE_FILE_SYSTEM_ALREADY_EXISTS_ErrorCode           ErrorCode = "SOURCE_FILE_SYSTEM_ALREADY_EXISTS"
	EVENT_LISTENER_START_ErrorCode                        ErrorCode = "EVENT_LISTENER_START"
	NO_SOURCE_CONFIGURATION_ErrorCode                     ErrorCode = "NO_SOURCE_CONFIGURATION"
	DEFAULT_SOURCE_CANNOT_BE_DETERMINED_ErrorCode         ErrorCode = "DEFAULT_SOURCE_CANNOT_BE_DETERMINED"
	SUCCESS_FILE_GLOB_CREATION_EXCEPTION_ErrorCode        ErrorCode = "SUCCESS_FILE_GLOB_CREATION_EXCEPTION"
	ACTIVE_MIGRATIONS_ErrorCode                           ErrorCode = "ACTIVE_MIGRATIONS"
	ACTIVE_PATH_MAPPINGS_ErrorCode                        ErrorCode = "ACTIVE_PATH_MAPPINGS"
	MIGRATION_ALREADY_DEFINED_ErrorCode                   ErrorCode = "MIGRATION_ALREADY_DEFINED"
	MIGRATION_START_PATH_NOT_FOUND_ErrorCode              ErrorCode = "MIGRATION_START_PATH_NOT_FOUND"
	MIGRATION_NOT_RUNNABLE_ErrorCode                      ErrorCode = "MIGRATION_NOT_RUNNABLE"
	MULTIPLE_MIGRATIONS_FOUND_ErrorCode                   ErrorCode = "MULTIPLE_MIGRATIONS_FOUND"
	FAILED_TO_DELETE_FROM_CURRENT_STATE_ErrorCode         ErrorCode = "FAILED_TO_DELETE_FROM_CURRENT_STATE"
	MIGRATION_NOT_STOPPABLE_ErrorCode                     ErrorCode = "MIGRATION_NOT_STOPPABLE"
	FAILED_TO_MIGRATE_PATH_ErrorCode                      ErrorCode = "FAILED_TO_MIGRATE_PATH"
	DUPLICATE_MIGRATION_PATH_ErrorCode                    ErrorCode = "DUPLICATE_MIGRATION_PATH"
	MIGRATION_QUEUE_NOT_FOUND_ErrorCode                   ErrorCode = "MIGRATION_QUEUE_NOT_FOUND"
	MIGRATION_NOT_FOUND_ErrorCode                         ErrorCode = "MIGRATION_NOT_FOUND"
	INVALID_ACTION_POLICY_ErrorCode                       ErrorCode = "INVALID_ACTION_POLICY"
	MIGRATION_NOT_RESUMABLE_ErrorCode                     ErrorCode = "MIGRATION_NOT_RESUMABLE"
	MIGRATION_NOT_RESETTABLE_ErrorCode                    ErrorCode = "MIGRATION_NOT_RESETTABLE"
	MORE_PENDING_REGIONS_THAN_NEW_MAX_ErrorCode           ErrorCode = "MORE_PENDING_REGIONS_THAN_NEW_MAX"
	SCAN_ONLY_MIGRATION_PERMITTED_ErrorCode               ErrorCode = "SCAN_ONLY_MIGRATION_PERMITTED"
	SCAN_ONLY_OPERATIONS_PERMITTED_ErrorCode              ErrorCode = "SCAN_ONLY_OPERATIONS_PERMITTED"
	MIGRATION_GATE_NOT_FOUND_ErrorCode                    ErrorCode = "MIGRATION_GATE_NOT_FOUND"
	MIGRATION_GATE_DUPLICATE_ID_ErrorCode                 ErrorCode = "MIGRATION_GATE_DUPLICATE_ID"
	MIGRATION_GATE_NOT_APPLICABLE_ErrorCode               ErrorCode = "MIGRATION_GATE_NOT_APPLICABLE"
	MIGRATION_GATE_CANNOT_BE_DELETED_ErrorCode            ErrorCode = "MIGRATION_GATE_CANNOT_BE_DELETED"
	UNAVAILABLE_ACTION_STORE_ErrorCode                    ErrorCode = "UNAVAILABLE_ACTION_STORE"
	MIGRATION_ACTION_NOT_FOUND_ErrorCode                  ErrorCode = "MIGRATION_ACTION_NOT_FOUND"
	VERIFICATION_JOB_NOT_FOUND_ErrorCode                  ErrorCode = "VERIFICATION_JOB_NOT_FOUND"
	VERIFICATION_ALREADY_RUNNING_ErrorCode                ErrorCode = "VERIFICATION_ALREADY_RUNNING"
	EXCLUSION_CREATION_EXCEPTION_ErrorCode                ErrorCode = "EXCLUSION_CREATION_EXCEPTION"
	EXCLUSION_NOT_FOUND_ErrorCode                         ErrorCode = "EXCLUSION_NOT_FOUND"
	EXCLUSION_ALREADY_EXISTS_ErrorCode                    ErrorCode = "EXCLUSION_ALREADY_EXISTS"
	EXCLUSION_DELETION_EXCEPTION_ErrorCode                ErrorCode = "EXCLUSION_DELETION_EXCEPTION"
	CONVERSION_FAILED_ErrorCode                           ErrorCode = "CONVERSION_FAILED"
	LICENSE_NOT_FOUND_ErrorCode                           ErrorCode = "LICENSE_NOT_FOUND"
	LICENSE_EXCEPTION_ErrorCode                           ErrorCode = "LICENSE_EXCEPTION"
	INVALID_LICENSE_ErrorCode                             ErrorCode = "INVALID_LICENSE"
	NON_VALID_LICENSE_ErrorCode                           ErrorCode = "NON_VALID_LICENSE"
	DECRYPT_LICENSE_ErrorCode                             ErrorCode = "DECRYPT_LICENSE"
	LICENSE_RETRIEVAL_EXCEPTION_ErrorCode                 ErrorCode = "LICENSE_RETRIEVAL_EXCEPTION"
	UPLOAD_DIR_NOT_CREATED_ErrorCode                      ErrorCode = "UPLOAD_DIR_NOT_CREATED"
	LICENSE_ACCESS_DENIED_ErrorCode                       ErrorCode = "LICENSE_ACCESS_DENIED"
	TRACKER_NOT_FOUND_ErrorCode                           ErrorCode = "TRACKER_NOT_FOUND"
	BANDWIDTH_POLICY_CREATION_EXCEPTION_ErrorCode         ErrorCode = "BANDWIDTH_POLICY_CREATION_EXCEPTION"
	BANDWIDTH_POLICY_NOT_FOUND_ErrorCode                  ErrorCode = "BANDWIDTH_POLICY_NOT_FOUND"
	PENDING_REGION_ALREADY_EXISTS_ErrorCode               ErrorCode = "PENDING_REGION_ALREADY_EXISTS"
	PENDING_REGION_PATH_NOT_FOUND_ErrorCode               ErrorCode = "PENDING_REGION_PATH_NOT_FOUND"
	PENDING_REGION_OUTSIDE_MIGRATION_ErrorCode            ErrorCode = "PENDING_REGION_OUTSIDE_MIGRATION"
	HTTP_METHOD_NOT_SUPPORTED_ErrorCode                   ErrorCode = "HTTP_METHOD_NOT_SUPPORTED"
	HTTP_MEDIA_TYPE_NOT_SUPPORTED_ErrorCode               ErrorCode = "HTTP_MEDIA_TYPE_NOT_SUPPORTED"
	HTTP_MEDIA_TYPE_NOT_ACCEPTABLE_ErrorCode              ErrorCode = "HTTP_MEDIA_TYPE_NOT_ACCEPTABLE"
	MISSING_PATH_VARIABLE_ErrorCode                       ErrorCode = "MISSING_PATH_VARIABLE"
	MISSING_SERVLET_REQUEST_PARAMETER_ErrorCode           ErrorCode = "MISSING_SERVLET_REQUEST_PARAMETER"
	TYPE_MISMATCH_EXCEPTION_ErrorCode                     ErrorCode = "TYPE_MISMATCH_EXCEPTION"
	CONVERSION_NOT_SUPPORTED_ErrorCode                    ErrorCode = "CONVERSION_NOT_SUPPORTED"
	HTTP_MESSAGE_NOT_READABLE_ErrorCode                   ErrorCode = "HTTP_MESSAGE_NOT_READABLE"
	HTTP_MESSAGE_NOT_WRITABLE_ErrorCode                   ErrorCode = "HTTP_MESSAGE_NOT_WRITABLE"
	SERVLET_REQUEST_BINDING_ErrorCode                     ErrorCode = "SERVLET_REQUEST_BINDING"
	METHOD_ARGUMENT_NOT_VALID_ErrorCode                   ErrorCode = "METHOD_ARGUMENT_NOT_VALID"
	MISSING_SERVLET_REQUEST_PART_ErrorCode                ErrorCode = "MISSING_SERVLET_REQUEST_PART"
	BIND_EXCEPTION_ErrorCode                              ErrorCode = "BIND_EXCEPTION"
	ASYNC_REQUEST_TIMEOUT_ErrorCode                       ErrorCode = "ASYNC_REQUEST_TIMEOUT"
	NOTIFICATION_NOT_FOUND_ErrorCode                      ErrorCode = "NOTIFICATION_NOT_FOUND"
	NOT_EMAIL_NOTIFICATION_TYPE_ErrorCode                 ErrorCode = "NOT_EMAIL_NOTIFICATION_TYPE"
	PATH_MAPPING_NOT_FOUND_ErrorCode                      ErrorCode = "PATH_MAPPING_NOT_FOUND"
	PATH_MAPPING_ALREADY_DEFINED_ErrorCode                ErrorCode = "PATH_MAPPING_ALREADY_DEFINED"
	PATH_MAPPING_OVERLAP_CONFLICT_ErrorCode               ErrorCode = "PATH_MAPPING_OVERLAP_CONFLICT"
	PATH_MAPPING_CONFIGURATION_ErrorCode                  ErrorCode = "PATH_MAPPING_CONFIGURATION"
	PATH_MAPPING_MIGRATION_CONFLICT_ErrorCode             ErrorCode = "PATH_MAPPING_MIGRATION_CONFLICT"
	PREVIEW_FEATURE_ENDPOINT_NOT_FOUND_ErrorCode          ErrorCode = "PREVIEW_FEATURE_ENDPOINT_NOT_FOUND"
	ILLEGAL_ARGUMENTS_ErrorCode                           ErrorCode = "ILLEGAL_ARGUMENTS"
	INVALID_REQUEST_PARAMETERS_ErrorCode                  ErrorCode = "INVALID_REQUEST_PARAMETERS"
	MISSING_PROPERTY_ErrorCode                            ErrorCode = "MISSING_PROPERTY"
	RESOURCE_FILE_NOT_FOUND_ErrorCode                     ErrorCode = "RESOURCE_FILE_NOT_FOUND"
	UPDATE_REQUIRED_ErrorCode                             ErrorCode = "UPDATE_REQUIRED"
	KAFKA_NOT_AVAILABLE_ErrorCode                         ErrorCode = "KAFKA_NOT_AVAILABLE"
	SQS_NOT_AVAILABLE_ErrorCode                           ErrorCode = "SQS_NOT_AVAILABLE"
	SQS_QUEUE_DOES_NOT_EXIST_ErrorCode                    ErrorCode = "SQS_QUEUE_DOES_NOT_EXIST"
	HDFS_NAMENODE_NOT_AVAILABLE_ErrorCode                 ErrorCode = "HDFS_NAMENODE_NOT_AVAILABLE"
	UNKNOWN_PROPERTY_ErrorCode                            ErrorCode = "UNKNOWN_PROPERTY"
	EVENTS_RESOURCE_ErrorCode                             ErrorCode = "EVENTS_RESOURCE"
	INVALID_PATH_FORMAT_ErrorCode                         ErrorCode = "INVALID_PATH_FORMAT"
	VERIFICATION_NOT_FOUND_ErrorCode                      ErrorCode = "VERIFICATION_NOT_FOUND"
	VERIFICATION_ALREADY_DEFINED_ErrorCode                ErrorCode = "VERIFICATION_ALREADY_DEFINED"
	ILLEGAL_STATE_ErrorCode                               ErrorCode = "ILLEGAL_STATE"
	VERIFICATION_PATHS_NOT_FOUND_ErrorCode                ErrorCode = "VERIFICATION_PATHS_NOT_FOUND"
	TOO_MANY_VERIFICATION_PATHS_ErrorCode                 ErrorCode = "TOO_MANY_VERIFICATION_PATHS"
	VERIFICATION_PATHS_OVERLAP_ErrorCode                  ErrorCode = "VERIFICATION_PATHS_OVERLAP"
	VERIFICATION_PATH_NOT_IN_MIGRATION_ErrorCode          ErrorCode = "VERIFICATION_PATH_NOT_IN_MIGRATION"
	VERIFICATION_PATHS_NOT_SET_ErrorCode                  ErrorCode = "VERIFICATION_PATHS_NOT_SET"
	VERIFICATION_MIGRATION_STATE_EXCEPTION_ErrorCode      ErrorCode = "VERIFICATION_MIGRATION_STATE_EXCEPTION"
	MIGRATION_DELETION_MODE_CONFLICT_ErrorCode            ErrorCode = "MIGRATION_DELETION_MODE_CONFLICT"
	BACKUP_DESERIALIZATION_EXCEPTION_ErrorCode            ErrorCode = "BACKUP_DESERIALIZATION_EXCEPTION"
	BACKUP_WRITE_IO_EXCEPTION_ErrorCode                   ErrorCode = "BACKUP_WRITE_IO_EXCEPTION"
	BACKUP_READ_IO_EXCEPTION_ErrorCode                    ErrorCode = "BACKUP_READ_IO_EXCEPTION"
	BACKUP_ACCESS_DENIED_EXCEPTION_ErrorCode              ErrorCode = "BACKUP_ACCESS_DENIED_EXCEPTION"
	BACKUP_SERIALIZATION_EXCEPTION_ErrorCode              ErrorCode = "BACKUP_SERIALIZATION_EXCEPTION"
	BACKUP_SCHEDULE_CONFIG_INVALID_EXCEPTION_ErrorCode    ErrorCode = "BACKUP_SCHEDULE_CONFIG_INVALID_EXCEPTION"
	PENDING_REGIONS_NOT_PERMITTED_ErrorCode               ErrorCode = "PENDING_REGIONS_NOT_PERMITTED"
	RECURRING_MIGRATION_NOT_PERMITTED_ErrorCode           ErrorCode = "RECURRING_MIGRATION_NOT_PERMITTED"
	VERIFICATION_REPORT_NOT_FOUND_EXCEPTION_ErrorCode     ErrorCode = "VERIFICATION_REPORT_NOT_FOUND_EXCEPTION"
	VERIFICATION_REPORT_STATE_EXCEPTION_ErrorCode         ErrorCode = "VERIFICATION_REPORT_STATE_EXCEPTION"
	VERIFICATION_ALREADY_IN_PROGRESS_ErrorCode            ErrorCode = "VERIFICATION_ALREADY_IN_PROGRESS"
	DATA_AGENT_WRONG_CREDENTIALS_ErrorCode                ErrorCode = "DATA_AGENT_WRONG_CREDENTIALS"
	DATA_AGENT_COULD_NOT_CONNECT_ErrorCode                ErrorCode = "DATA_AGENT_COULD_NOT_CONNECT"
	DATA_AGENT_INCOMPATIBLE_ErrorCode                     ErrorCode = "DATA_AGENT_INCOMPATIBLE"
	DATA_AGENT_NOT_FOUND_ErrorCode                        ErrorCode = "DATA_AGENT_NOT_FOUND"
	DATA_AGENT_ALREADY_EXISTS_ErrorCode                   ErrorCode = "DATA_AGENT_ALREADY_EXISTS"
	VERIFICATION_DEPTH_NEGATIVE_OR_NULL_ErrorCode         ErrorCode = "VERIFICATION_DEPTH_NEGATIVE_OR_NULL"
	VERIFICATION_CANT_BE_DELETED_ErrorCode                ErrorCode = "VERIFICATION_CANT_BE_DELETED"
	SOURCE_DELETION_NOT_PERMITTED_ErrorCode               ErrorCode = "SOURCE_DELETION_NOT_PERMITTED"
	MIGRATION_CONFIGURATION_EXCEPTION_ErrorCode           ErrorCode = "MIGRATION_CONFIGURATION_EXCEPTION"
	SOURCE_CLEANUP_REPORT_NOT_FOUND_EXCEPTION_ErrorCode   ErrorCode = "SOURCE_CLEANUP_REPORT_NOT_FOUND_EXCEPTION"
)

List of ErrorCode

type EventManagerDiagnostic

type EventManagerDiagnostic struct {
	TimeStamp                     int64            `json:"timeStamp,omitempty"`
	Type_                         string           `json:"type"`
	TotalAddEventsCallCount       int64            `json:"totalAddEventsCallCount,omitempty"`
	TotalEventAdded               int64            `json:"totalEventAdded,omitempty"`
	TotalDbAddEventsCallCount     int64            `json:"totalDbAddEventsCallCount,omitempty"`
	MaxDbTime                     int64            `json:"maxDbTime,omitempty"`
	TotalDbTime                   int64            `json:"totalDbTime,omitempty"`
	MeanDbTime                    int64            `json:"meanDbTime,omitempty"`
	TotalQueuedEvents             int64            `json:"totalQueuedEvents,omitempty"`
	TotalQueuedEventsPerMigration map[string]int32 `json:"totalQueuedEventsPerMigration,omitempty"`
}

type Exclusion

type Exclusion struct {
	Id                string `json:"id,omitempty"`
	Description       string `json:"description,omitempty"`
	FsRestriction     bool   `json:"fsRestriction,omitempty"`
	SourceFsExclusion bool   `json:"sourceFsExclusion,omitempty"`
	GlobalExclusion   bool   `json:"globalExclusion,omitempty"`
	DefaultExclusion  bool   `json:"defaultExclusion,omitempty"`
	Type_             string `json:"type"`
}

type ExclusionsControllerApiAddRegexExclusionOpts

type ExclusionsControllerApiAddRegexExclusionOpts struct {
	PatternType optional.String
}

type ExclusionsControllerApiService

type ExclusionsControllerApiService service

func (*ExclusionsControllerApiService) AddDateExclusion

func (a *ExclusionsControllerApiService) AddDateExclusion(ctx context.Context, id string, description string, beforeIsoDateTime time.Time) (Exclusion, *http.Response, error)

ExclusionsControllerApiService Add a new date-based exclusion

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param id ID of the exclusion to create
  • @param description Description of the exclusion to create
  • @param beforeIsoDateTime If a file's modification time is earlier than this, it will be excluded from migration. Expects the ISO format e.g. \"2020-02-03T10:15:05-05:00\".

@return Exclusion

func (*ExclusionsControllerApiService) AddFileSizeExclusion

func (a *ExclusionsControllerApiService) AddFileSizeExclusion(ctx context.Context, id string, description string, value int64, unit FileSizeUnit) (Exclusion, *http.Response, error)

ExclusionsControllerApiService Add a new file size exclusion

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param id ID of the exclusion to create
  • @param description Description of the exclusion to create
  • @param value File size, if greater, file will be excluded from migration
  • @param unit Unit of file size

@return Exclusion

func (*ExclusionsControllerApiService) AddRegexExclusion

func (a *ExclusionsControllerApiService) AddRegexExclusion(ctx context.Context, id string, description string, regex string, localVarOptionals *ExclusionsControllerApiAddRegexExclusionOpts) (Exclusion, *http.Response, error)

func (*ExclusionsControllerApiService) GetExclusion

func (a *ExclusionsControllerApiService) GetExclusion(ctx context.Context, exclusionId string) (Exclusion, *http.Response, error)

ExclusionsControllerApiService Get exclusion for given exclusion ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param exclusionId

@return Exclusion

func (*ExclusionsControllerApiService) GetFsRestrictions

func (a *ExclusionsControllerApiService) GetFsRestrictions(ctx context.Context, fsType string) ([]Exclusion, *http.Response, error)

ExclusionsControllerApiService See the restrictions applied automatically for the given target filesystem

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsType Filesystem type

@return []Exclusion

func (*ExclusionsControllerApiService) GetSourceFsRestrictions

func (a *ExclusionsControllerApiService) GetSourceFsRestrictions(ctx context.Context, fsType string) ([]Exclusion, *http.Response, error)

ExclusionsControllerApiService See the restrictions applied automatically for the given source filesystem

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsType Filesystem type

@return []Exclusion

func (*ExclusionsControllerApiService) ListExclusions

ExclusionsControllerApiService Get all exclusions

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Exclusion

func (*ExclusionsControllerApiService) ListGlobalExclusions

func (a *ExclusionsControllerApiService) ListGlobalExclusions(ctx context.Context) ([]Exclusion, *http.Response, error)

ExclusionsControllerApiService Get all global exclusions

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Exclusion

func (*ExclusionsControllerApiService) ListUserDefinedExclusions

func (a *ExclusionsControllerApiService) ListUserDefinedExclusions(ctx context.Context) ([]Exclusion, *http.Response, error)

ExclusionsControllerApiService Get all user defined exclusions

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Exclusion

func (*ExclusionsControllerApiService) RemoveExclusion

func (a *ExclusionsControllerApiService) RemoveExclusion(ctx context.Context, exclusionId string) (*http.Response, error)

ExclusionsControllerApiService Delete exclusion for given ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param exclusionId

type FailedPath

type FailedPath struct {
	Path           string      `json:"path,omitempty"`
	RenamePath     string      `json:"renamePath,omitempty"`
	FailureMessage string      `json:"failureMessage,omitempty"`
	TimeStamp      int64       `json:"timeStamp,omitempty"`
	Action         *ActionType `json:"action,omitempty"`
	DateFailed     time.Time   `json:"dateFailed,omitempty"`
}

type FailedPathsSummary

type FailedPathsSummary struct {
	MigrationId            string `json:"migrationId,omitempty"`
	FailedPathCount        int64  `json:"failedPathCount,omitempty"`
	AttemptedTransferCount int64  `json:"attemptedTransferCount,omitempty"`
	FailureRate            int64  `json:"failureRate,omitempty"`
}

type FailedToDeleteExclusionException

type FailedToDeleteExclusionException struct {
	Status           *HttpStatus `json:"status,omitempty"`
	ErrorCode        *ErrorCode  `json:"errorCode,omitempty"`
	Message          string      `json:"message,omitempty"`
	LocalizedMessage string      `json:"localizedMessage,omitempty"`
}

type FileDeleteRequest

type FileDeleteRequest struct {
	Recursive bool `json:"recursive,omitempty"`
}

type FileSizeExclusion

type FileSizeExclusion struct {
	Id                string        `json:"id,omitempty"`
	Description       string        `json:"description,omitempty"`
	FsRestriction     bool          `json:"fsRestriction,omitempty"`
	SourceFsExclusion bool          `json:"sourceFsExclusion,omitempty"`
	GlobalExclusion   bool          `json:"globalExclusion,omitempty"`
	DefaultExclusion  bool          `json:"defaultExclusion,omitempty"`
	Type_             string        `json:"type"`
	MaxBytes          int64         `json:"maxBytes,omitempty"`
	DisplayUnit       *FileSizeUnit `json:"displayUnit,omitempty"`
	MaxBytesFormatted string        `json:"maxBytesFormatted,omitempty"`
}

type FileSizeUnit

type FileSizeUnit string
const (
	B_FileSizeUnit    FileSizeUnit = "B"
	KB_FileSizeUnit   FileSizeUnit = "KB"
	MB_FileSizeUnit   FileSizeUnit = "MB"
	GB_FileSizeUnit   FileSizeUnit = "GB"
	TB_FileSizeUnit   FileSizeUnit = "TB"
	PB_FileSizeUnit   FileSizeUnit = "PB"
	KI_B_FileSizeUnit FileSizeUnit = "KiB"
	MI_B_FileSizeUnit FileSizeUnit = "MiB"
	GI_B_FileSizeUnit FileSizeUnit = "GiB"
	TI_B_FileSizeUnit FileSizeUnit = "TiB"
	PI_B_FileSizeUnit FileSizeUnit = "PiB"
)

List of FileSizeUnit

type FileStatus

type FileStatus struct {
	Path             string `json:"path,omitempty"`
	IsDirectory      bool   `json:"isDirectory,omitempty"`
	Length           int64  `json:"length,omitempty"`
	ModificationTime int64  `json:"modificationTime,omitempty"`
}

type FileSystemConfiguration

type FileSystemConfiguration struct {
	FileSystemId   string            `json:"fileSystemId,omitempty"`
	FsType         string            `json:"fsType,omitempty"`
	IsSource       bool              `json:"isSource,omitempty"`
	Properties     map[string]string `json:"properties,omitempty"`
	EventsPosition int64             `json:"eventsPosition,omitempty"`
	IsScanOnly     bool              `json:"isScanOnly,omitempty"`
}

type FileSystemControllerApiCreateFileOpts

type FileSystemControllerApiCreateFileOpts struct {
	Path     optional.String
	FileBody optional.Interface
}

type FileSystemControllerApiService

type FileSystemControllerApiService service

func (*FileSystemControllerApiService) CreateFile

func (*FileSystemControllerApiService) DeleteByPath

func (a *FileSystemControllerApiService) DeleteByPath(ctx context.Context, body FileDeleteRequest, path string, fsId string, role string) (bool, *http.Response, error)

FileSystemControllerApiService Delete file from the file system

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param body File delete parameters
  • @param path Path to the file or directory
  • @param fsId
  • @param role

@return bool

func (*FileSystemControllerApiService) GetFileSystemURI

func (a *FileSystemControllerApiService) GetFileSystemURI(ctx context.Context, fsId string, role string) (FileSystemUri, *http.Response, error)

FileSystemControllerApiService Get file system URI for given filesystem id

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId
  • @param role

@return FileSystemUri

func (*FileSystemControllerApiService) ListPaths

func (a *FileSystemControllerApiService) ListPaths(ctx context.Context, fsId string, role string, path string) ([]FileStatus, *http.Response, error)

FileSystemControllerApiService Get files list from the file system

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId
  • @param role
  • @param path Path to the file or directory

@return []FileStatus

func (*FileSystemControllerApiService) Mkdir

FileSystemControllerApiService Create directory in the file system

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId
  • @param role
  • @param path Path to the directory

@return bool

func (*FileSystemControllerApiService) MoveByPath

func (a *FileSystemControllerApiService) MoveByPath(ctx context.Context, fsId string, role string, path string, destPath string) (bool, *http.Response, error)

FileSystemControllerApiService Move file or directory on the file system

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId
  • @param role
  • @param path Path to the file or directory
  • @param destPath Destination path to the file or directory

@return bool

func (*FileSystemControllerApiService) Path

FileSystemControllerApiService Check if file or directory exists

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId
  • @param role
  • @param path Path to the file or directory

@return bool

func (*FileSystemControllerApiService) ReadFile

func (a *FileSystemControllerApiService) ReadFile(ctx context.Context, fsId string, role string, path string) (*os.File, *http.Response, error)

FileSystemControllerApiService Read file from the file system

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId
  • @param role
  • @param path Path to the file

@return *os.File

func (*FileSystemControllerApiService) WriteFile

func (a *FileSystemControllerApiService) WriteFile(ctx context.Context, body FileWriteRequest, path string, fsId string, role string) (bool, *http.Response, error)

FileSystemControllerApiService Write file into the file system

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param body File write parameters
  • @param path Path to the file
  • @param fsId
  • @param role

@return bool

type FileSystemHealthStatus

type FileSystemHealthStatus struct {
	FsId                 string `json:"fsId,omitempty"`
	Healthy              bool   `json:"healthy,omitempty"`
	TimeStampEpochMillis int64  `json:"timeStampEpochMillis,omitempty"`
	Cause                string `json:"cause,omitempty"`
	HealthReason         string `json:"healthReason,omitempty"`
}

type FileSystemUri

type FileSystemUri struct {
	FileSystemURI string `json:"fileSystemURI,omitempty"`
}

type FileTracker

type FileTracker struct {
	MigrationId                  string              `json:"MigrationId,omitempty"`
	StatsType                    string              `json:"StatsType,omitempty"`
	Path                         string              `json:"Path,omitempty"`
	FileLength                   int64               `json:"FileLength,omitempty"`
	TransferId                   int64               `json:"TransferId,omitempty"`
	DataAgentName                string              `json:"DataAgentName,omitempty"`
	AttemptCount                 int64               `json:"AttemptCount,omitempty"`
	Thread                       string              `json:"Thread,omitempty"`
	StartTime                    int64               `json:"StartTime,omitempty"`
	CompleteTime                 int64               `json:"CompleteTime,omitempty"`
	SourceEventCreationTimeStamp int64               `json:"SourceEventCreationTimeStamp,omitempty"`
	LdmEventCreationTimeStamp    int64               `json:"LdmEventCreationTimeStamp,omitempty"`
	EventLatency                 int64               `json:"EventLatency,omitempty"`
	BytesTransferred             int64               `json:"BytesTransferred,omitempty"`
	LastUpdate                   int64               `json:"LastUpdate,omitempty"`
	TimeBetweenUpdates           int64               `json:"TimeBetweenUpdates,omitempty"`
	UpdateCount                  int64               `json:"UpdateCount,omitempty"`
	IsSuccessful                 bool                `json:"IsSuccessful,omitempty"`
	Buckets                      []FileTrackerBucket `json:"Buckets,omitempty"`
	BytesPerSecond               int64               `json:"BytesPerSecond,omitempty"`
	IsComplete                   bool                `json:"IsComplete,omitempty"`
	IncomingTransportBytes       int64               `json:"IncomingTransportBytes,omitempty"`
	OutgoingTransportBytes       int64               `json:"OutgoingTransportBytes,omitempty"`
	DataTransferTiming           *DataTransferTiming `json:"DataTransferTiming,omitempty"`
}

type FileTrackerBucket

type FileTrackerBucket struct {
	Second         int64 `json:"Second,omitempty"`
	BytesForSecond int64 `json:"BytesForSecond,omitempty"`
}

type FileTrackerDiagnostic

type FileTrackerDiagnostic struct {
	TimeStamp                   int64                   `json:"timeStamp,omitempty"`
	Type_                       string                  `json:"type"`
	FileTrackers                []FileTracker           `json:"fileTrackers,omitempty"`
	FileSizePercentiles         *FileTrackerPercentiles `json:"fileSizePercentiles,omitempty"`
	FileTransferRatePercentiles *FileTrackerPercentiles `json:"fileTransferRatePercentiles,omitempty"`
	RecentActivityByMigration   map[string]int32        `json:"recentActivityByMigration,omitempty"`
	NumberOfActiveFileTransfers int32                   `json:"numberOfActiveFileTransfers,omitempty"`
	LatencyPercentiles          []FileTrackerPercentile `json:"latencyPercentiles,omitempty"`
}

type FileTrackerPercentile

type FileTrackerPercentile struct {
	Percentile int32 `json:"percentile,omitempty"`
	Value      int64 `json:"value,omitempty"`
}

type FileTrackerPercentiles

type FileTrackerPercentiles struct {
	Type_                 string                  `json:"type,omitempty"`
	SuccessfulFileCount   int32                   `json:"successfulFileCount,omitempty"`
	FailedFileCount       int32                   `json:"failedFileCount,omitempty"`
	FileTrackerPercentile []FileTrackerPercentile `json:"fileTrackerPercentile,omitempty"`
}

type FileWriteRequest

type FileWriteRequest struct {
	FileBody          string `json:"fileBody,omitempty"`
	CreateIfNotExists bool   `json:"createIfNotExists,omitempty"`
	Overwrite         bool   `json:"overwrite,omitempty"`
}

type FilesSystemHealthControllerApiService

type FilesSystemHealthControllerApiService service

func (*FilesSystemHealthControllerApiService) GetHealthStatus

FilesSystemHealthControllerApiService Get health status for given ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param fsId Unique identifier of the source filesystem

@return FileSystemHealthStatus

func (*FilesSystemHealthControllerApiService) ListHealthStatuses

FilesSystemHealthControllerApiService List health statues for all filesystems

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []FileSystemHealthStatus

type FsType

type FsType struct {
	Autoconfigurable           bool        `json:"autoconfigurable,omitempty"`
	Fs                         string      `json:"fs,omitempty"`
	FsDescription              string      `json:"fsDescription,omitempty"`
	FsRestrictions             []Exclusion `json:"fsRestrictions,omitempty"`
	MultipleSourceAllowed      bool        `json:"multipleSourceAllowed,omitempty"`
	SourceFilesystemExclusions []Exclusion `json:"sourceFilesystemExclusions,omitempty"`
}

type GCSSourceFileSystemControllerApiAddSourceGcsFileSystemDefaultOpts

type GCSSourceFileSystemControllerApiAddSourceGcsFileSystemDefaultOpts struct {
	PropertiesFiles optional.Interface
}

type GCSSourceFileSystemControllerApiAddSourceGcsFileSystemJsonKeyFileOpts

type GCSSourceFileSystemControllerApiAddSourceGcsFileSystemJsonKeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSSourceFileSystemControllerApiAddSourceGcsFileSystemP12KeyFileOpts

type GCSSourceFileSystemControllerApiAddSourceGcsFileSystemP12KeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSSourceFileSystemControllerApiService

type GCSSourceFileSystemControllerApiService service

func (*GCSSourceFileSystemControllerApiService) AddSourceGcsFileSystemDefault

func (*GCSSourceFileSystemControllerApiService) AddSourceGcsFileSystemJsonKeyFile

func (*GCSSourceFileSystemControllerApiService) AddSourceGcsFileSystemP12KeyFile

func (*GCSSourceFileSystemControllerApiService) UpdateSourceGcsFileSystemDefault

func (*GCSSourceFileSystemControllerApiService) UpdateSourceGcsFileSystemJsonKeyFile

func (*GCSSourceFileSystemControllerApiService) UpdateSourceGcsFileSystemP12KeyFile

type GCSSourceFileSystemControllerApiUpdateSourceGcsFileSystemDefaultOpts

type GCSSourceFileSystemControllerApiUpdateSourceGcsFileSystemDefaultOpts struct {
	PropertiesFiles optional.Interface
}

type GCSSourceFileSystemControllerApiUpdateSourceGcsFileSystemJsonKeyFileOpts

type GCSSourceFileSystemControllerApiUpdateSourceGcsFileSystemJsonKeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSSourceFileSystemControllerApiUpdateSourceGcsFileSystemP12KeyFileOpts

type GCSSourceFileSystemControllerApiUpdateSourceGcsFileSystemP12KeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSTargetFileSystemControllerApiAddTargetGcsFileSystemDefaultOpts

type GCSTargetFileSystemControllerApiAddTargetGcsFileSystemDefaultOpts struct {
	PropertiesFiles optional.Interface
}

type GCSTargetFileSystemControllerApiAddTargetGcsFileSystemJsonKeyFileOpts

type GCSTargetFileSystemControllerApiAddTargetGcsFileSystemJsonKeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSTargetFileSystemControllerApiAddTargetGcsFileSystemP12KeyFileOpts

type GCSTargetFileSystemControllerApiAddTargetGcsFileSystemP12KeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSTargetFileSystemControllerApiService

type GCSTargetFileSystemControllerApiService service

func (*GCSTargetFileSystemControllerApiService) AddTargetGcsFileSystemDefault

func (*GCSTargetFileSystemControllerApiService) AddTargetGcsFileSystemJsonKeyFile

func (*GCSTargetFileSystemControllerApiService) AddTargetGcsFileSystemP12KeyFile

func (*GCSTargetFileSystemControllerApiService) UpdateTargetGcsFileSystemDefault

func (*GCSTargetFileSystemControllerApiService) UpdateTargetGcsFileSystemJsonKeyFile

func (*GCSTargetFileSystemControllerApiService) UpdateTargetGcsFileSystemP12KeyFile

type GCSTargetFileSystemControllerApiUpdateTargetGcsFileSystemDefaultOpts

type GCSTargetFileSystemControllerApiUpdateTargetGcsFileSystemDefaultOpts struct {
	PropertiesFiles optional.Interface
}

type GCSTargetFileSystemControllerApiUpdateTargetGcsFileSystemJsonKeyFileOpts

type GCSTargetFileSystemControllerApiUpdateTargetGcsFileSystemJsonKeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GCSTargetFileSystemControllerApiUpdateTargetGcsFileSystemP12KeyFileOpts

type GCSTargetFileSystemControllerApiUpdateTargetGcsFileSystemP12KeyFileOpts struct {
	FsProperties    optional.Interface
	File            optional.Interface
	PropertiesFiles optional.Interface
}

type GateActionStatus

type GateActionStatus string
const (
	CREATED_GateActionStatus                    GateActionStatus = "CREATED"
	INJECTED_GateActionStatus                   GateActionStatus = "INJECTED"
	AWAITING_DEPENDENT_REGIONS_GateActionStatus GateActionStatus = "AWAITING_DEPENDENT_REGIONS"
	SCHEDULED_GateActionStatus                  GateActionStatus = "SCHEDULED"
	COMPLETED_GateActionStatus                  GateActionStatus = "COMPLETED"
)

List of GateActionStatus

type GcsFilesystemProperties

type GcsFilesystemProperties struct {
	// JSON KeyFile location for GCS filesystem
	JsonKeyFile string `json:"jsonKeyFile,omitempty"`
	// P12 KeyFile location for GCS filesystem
	P12KeyFile string `json:"p12KeyFile,omitempty"`
	// GCS Bucket Name
	BucketName string `json:"bucketName"`
	// GCS Private key
	PrivateKey string `json:"privateKey,omitempty"`
	// GCS Private key id
	PrivateKeyId string `json:"privateKeyId,omitempty"`
	// GCS Service Account Email
	ClientEmail string `json:"clientEmail,omitempty"`
	// Additional filesystem properties
	AdditionalProperties map[string]string `json:"additionalProperties,omitempty"`
}

Target file system properties

type GenericSwaggerError

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

GenericSwaggerError Provides access to the body, error and model on returned errors.

func (GenericSwaggerError) Body

func (e GenericSwaggerError) Body() []byte

Body returns the raw bytes of the response

func (GenericSwaggerError) Error

func (e GenericSwaggerError) Error() string

Error returns non-empty string if there was an error.

func (GenericSwaggerError) Model

func (e GenericSwaggerError) Model() interface{}

Model returns the unpacked model of the error

type HDFSSourceFileSystemAutodiscoveryControllerApiAutoDiscoverSourceFilesystemOpts

type HDFSSourceFileSystemAutodiscoveryControllerApiAutoDiscoverSourceFilesystemOpts struct {
	ScanOnly optional.Bool
}

type HDFSSourceFileSystemAutodiscoveryControllerApiService

type HDFSSourceFileSystemAutodiscoveryControllerApiService service

type HDFSSourceFileSystemControllerApiAddSourceHdfsFileSystemOpts

type HDFSSourceFileSystemControllerApiAddSourceHdfsFileSystemOpts struct {
	PropertiesFiles optional.Interface
	ScanOnly        optional.Bool
}

type HDFSSourceFileSystemControllerApiService

type HDFSSourceFileSystemControllerApiService service

func (*HDFSSourceFileSystemControllerApiService) AddSourceHdfsFileSystem

func (*HDFSSourceFileSystemControllerApiService) UpdateSourceHdfsFileSystem

type HDFSSourceFileSystemControllerApiUpdateSourceHdfsFileSystemOpts

type HDFSSourceFileSystemControllerApiUpdateSourceHdfsFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type HDFSTargetFileSystemControllerApiAddTargetHdfsFileSystemOpts

type HDFSTargetFileSystemControllerApiAddTargetHdfsFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type HDFSTargetFileSystemControllerApiService

type HDFSTargetFileSystemControllerApiService service

func (*HDFSTargetFileSystemControllerApiService) AddTargetHdfsFileSystem

func (*HDFSTargetFileSystemControllerApiService) UpdateTargetHdfsFileSystem

type HDFSTargetFileSystemControllerApiUpdateTargetHdfsFileSystemOpts

type HDFSTargetFileSystemControllerApiUpdateTargetHdfsFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type HdfsFilesystemProperties

type HdfsFilesystemProperties struct {
	// Default filesystem
	DefaultFS string `json:"defaultFS,omitempty"`
	// FileSystem username to perform migration actions as
	User string `json:"user,omitempty"`
	// Kerberos principal
	KerberosPrincipal string `json:"kerberosPrincipal,omitempty"`
	// Kerberos keytab location
	KerberosKeyTab string `json:"kerberosKeyTab,omitempty"`
	// Success File GLOB pattern
	SuccessFile string `json:"successFile,omitempty"`
	// Additional filesystem properties
	AdditionalProperties map[string]string `json:"additionalProperties,omitempty"`
}

HDFS file system properties

type HttpStatus

type HttpStatus string

type InfoControllerApiService

type InfoControllerApiService service

func (*InfoControllerApiService) GetNodeId

InfoControllerApiService Get LiveData Migrator Node ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*InfoControllerApiService) GetVersion

InfoControllerApiService Get information on LiveData Migrator instance

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]string

type InotifyDiagnostic

type InotifyDiagnostic struct {
	TimeStamp               int64  `json:"timeStamp,omitempty"`
	Type_                   string `json:"type"`
	AvgEventsBehind         int64  `json:"avgEventsBehind,omitempty"`
	MaxEventsBehind         int64  `json:"maxEventsBehind,omitempty"`
	TotalEventsRead         int64  `json:"totalEventsRead,omitempty"`
	AvgEventsReadPerCall    int64  `json:"avgEventsReadPerCall,omitempty"`
	MaxEventsReadPerCall    int64  `json:"maxEventsReadPerCall,omitempty"`
	AvgRpcCallTime          int64  `json:"avgRpcCallTime,omitempty"`
	MaxRpcCallTime          int64  `json:"maxRpcCallTime,omitempty"`
	EventsBehind            int64  `json:"eventsBehind,omitempty"`
	NameNodeRetained        int64  `json:"nameNodeRetained,omitempty"`
	NameNodeMaxEventsPerRpc int64  `json:"nameNodeMaxEventsPerRpc,omitempty"`
	NameNodeCheckpointTxs   int64  `json:"nameNodeCheckpointTxs,omitempty"`
}

type InsufficientFsPermissionsException

type InsufficientFsPermissionsException struct {
	Status           *HttpStatus `json:"status,omitempty"`
	ErrorCode        *ErrorCode  `json:"errorCode,omitempty"`
	Message          string      `json:"message,omitempty"`
	LocalizedMessage string      `json:"localizedMessage,omitempty"`
}

type JvmGcDiagnostic

type JvmGcDiagnostic struct {
	TimeStamp   int64  `json:"timeStamp,omitempty"`
	Type_       string `json:"type"`
	GcCount     int64  `json:"gcCount,omitempty"`
	GcPauseTime int64  `json:"gcPauseTime,omitempty"`
}

type License

type License struct {
	Id                      string             `json:"id,omitempty"`
	ProductLicense          string             `json:"productLicense,omitempty"`
	LicenseSource           string             `json:"licenseSource,omitempty"`
	LicenseStatus           string             `json:"licenseStatus,omitempty"`
	Warning                 string             `json:"warning,omitempty"`
	LastTimeChecked         int64              `json:"lastTimeChecked,omitempty"`
	IsValid                 bool               `json:"isValid,omitempty"`
	Components              []LicenseComponent `json:"components,omitempty"`
	LicenseExceptionMessage string             `json:"licenseExceptionMessage,omitempty"`
	InvalidReason           string             `json:"invalidReason,omitempty"`
	ExpiredReason           string             `json:"expiredReason,omitempty"`
	ExpiryDate              string             `json:"expiryDate,omitempty"`
}

type LicenseComponent

type LicenseComponent struct {
	Warning       string `json:"warning,omitempty"`
	LicenseType   string `json:"licenseType,omitempty"`
	InvalidReason string `json:"invalidReason,omitempty"`
	IsValid       bool   `json:"isValid,omitempty"`
	LicenseStatus string `json:"licenseStatus,omitempty"`
	Type_         string `json:"type"`
}

type LicenseControllerApiFetchLicenseOpts

type LicenseControllerApiFetchLicenseOpts struct {
	FullLicense optional.Bool
}

type LicenseControllerApiService

type LicenseControllerApiService service

func (*LicenseControllerApiService) FetchConsumptionLicense

func (a *LicenseControllerApiService) FetchConsumptionLicense(ctx context.Context) (ConsumptionLicense, *http.Response, error)

LicenseControllerApiService Get Consumption License Component for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return ConsumptionLicense

func (*LicenseControllerApiService) FetchLicense

func (*LicenseControllerApiService) FetchLicenseComponents

func (a *LicenseControllerApiService) FetchLicenseComponents(ctx context.Context) ([]LicenseComponent, *http.Response, error)

LicenseControllerApiService Get License Components for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []LicenseComponent

func (*LicenseControllerApiService) FetchLicenseStatus

func (a *LicenseControllerApiService) FetchLicenseStatus(ctx context.Context) (string, *http.Response, error)

LicenseControllerApiService Get License Status for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*LicenseControllerApiService) FetchLicenseValid

func (a *LicenseControllerApiService) FetchLicenseValid(ctx context.Context) (string, *http.Response, error)

LicenseControllerApiService Get whether License is valid for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*LicenseControllerApiService) FetchMeteredLicense

func (a *LicenseControllerApiService) FetchMeteredLicense(ctx context.Context) (MeteredLicense, *http.Response, error)

LicenseControllerApiService Get Metered License Component for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return MeteredLicense

func (*LicenseControllerApiService) FetchTrialLicense

LicenseControllerApiService Get Trial License Component for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return TrialLicense

func (*LicenseControllerApiService) FetchVolumeLicense

func (a *LicenseControllerApiService) FetchVolumeLicense(ctx context.Context) (DataLicense, *http.Response, error)

LicenseControllerApiService Get Volume License Component for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return DataLicense

func (*LicenseControllerApiService) UpdateLicense

type LicenseControllerApiUpdateLicenseOpts

type LicenseControllerApiUpdateLicenseOpts struct {
	File optional.Interface
}

type LicenseFileBody

type LicenseFileBody struct {
	File **os.File `json:"file"`
}

type LinuxPressureDiagnostic

type LinuxPressureDiagnostic struct {
	TimeStamp        int64      `json:"timeStamp,omitempty"`
	Type_            string     `json:"type"`
	Pressure         []Pressure `json:"pressure,omitempty"`
	IowaitPercentage float64    `json:"iowaitPercentage,omitempty"`
}

type LiveMigratorDiagnosticsSnapshot

type LiveMigratorDiagnosticsSnapshot struct {
	TimeStamp                     int64                          `json:"timeStamp,omitempty"`
	CollectionTime                int64                          `json:"collectionTime,omitempty"`
	Diagnostics                   []Diagnostic                   `json:"diagnostics,omitempty"`
	ImplClassName                 string                         `json:"implClassName"`
	DataAgentDiagnosticsSnapshots []DataAgentDiagnosticsSnapshot `json:"dataAgentDiagnosticsSnapshots,omitempty"`
}

type LiveMigratorRestException

type LiveMigratorRestException struct {
	Title   string `json:"title,omitempty"`
	Status  int32  `json:"status,omitempty"`
	Error_  int32  `json:"error,omitempty"`
	Message string `json:"message,omitempty"`
}

type LocalFilesystemProperties

type LocalFilesystemProperties struct {
	// Root path of local file system
	FsRoot string `json:"fsRoot,omitempty"`
	// Additional filesystem properties
	AdditionalProperties map[string]string `json:"additionalProperties,omitempty"`
}

Local file system properties

type LocalSourceFileSystemControllerApiAddSourceLocalFileSystemOpts

type LocalSourceFileSystemControllerApiAddSourceLocalFileSystemOpts struct {
	ScanOnly        optional.Bool
	PropertiesFiles optional.Interface
}

type LocalSourceFileSystemControllerApiService

type LocalSourceFileSystemControllerApiService service

func (*LocalSourceFileSystemControllerApiService) AddSourceLocalFileSystem

func (*LocalSourceFileSystemControllerApiService) UpdateSourceLocalFileSystem

type LocalSourceFileSystemControllerApiUpdateSourceLocalFileSystemOpts

type LocalSourceFileSystemControllerApiUpdateSourceLocalFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type LocalTargetFileSystemControllerApiAddTargetLocalFileSystemOpts

type LocalTargetFileSystemControllerApiAddTargetLocalFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type LocalTargetFileSystemControllerApiService

type LocalTargetFileSystemControllerApiService service

func (*LocalTargetFileSystemControllerApiService) AddTargetLocalFileSystem

func (*LocalTargetFileSystemControllerApiService) UpdateTargetLocalFileSystem

type LocalTargetFileSystemControllerApiUpdateTargetLocalFileSystemOpts

type LocalTargetFileSystemControllerApiUpdateTargetLocalFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type MeterBucket

type MeterBucket struct {
	KbCnt               int64  `json:"kbCnt,omitempty"`
	Aggregation         string `json:"aggregation,omitempty"`
	TransactionCnt      int64  `json:"transactionCnt,omitempty"`
	KbCntScan           int64  `json:"kbCntScan,omitempty"`
	KbCntPostScan       int64  `json:"kbCntPostScan,omitempty"`
	TxnScan             int64  `json:"txnScan,omitempty"`
	TxnPostScan         int64  `json:"txnPostScan,omitempty"`
	BucketStartTime     string `json:"bucketStartTime,omitempty"`
	TotalTransactionCnt int64  `json:"totalTransactionCnt,omitempty"`
	TotalKbCnt          int64  `json:"totalKbCnt,omitempty"`
	TotalKbCntScan      int64  `json:"totalKbCntScan,omitempty"`
	TotalKbCntPostScan  int64  `json:"totalKbCntPostScan,omitempty"`
}

type MeteredLicense

type MeteredLicense struct {
	Warning                  string `json:"warning,omitempty"`
	LicenseType              string `json:"licenseType,omitempty"`
	InvalidReason            string `json:"invalidReason,omitempty"`
	IsValid                  bool   `json:"isValid,omitempty"`
	LicenseStatus            string `json:"licenseStatus,omitempty"`
	Type_                    string `json:"type"`
	IsMetered                bool   `json:"isMetered,omitempty"`
	MeteredLicenseExpiryDate int64  `json:"meteredLicenseExpiryDate,omitempty"`
	LastMeteringUpdate       int64  `json:"lastMeteringUpdate,omitempty"`
	LastTimeChecked          int64  `json:"lastTimeChecked,omitempty"`
	ExpiredReason            string `json:"expiredReason,omitempty"`
	Metered                  bool   `json:"metered,omitempty"`
}

type Metering

type Metering struct {
	HistoryBuckets             []MeterBucket `json:"historyBuckets,omitempty"`
	TotalCurrentTransactionCnt int64         `json:"totalCurrentTransactionCnt,omitempty"`
	TotalCurrentKbCnt          int64         `json:"totalCurrentKbCnt,omitempty"`
	StaticKbCnt                int64         `json:"staticKbCnt,omitempty"`
	LiveKbCnt                  int64         `json:"liveKbCnt,omitempty"`
}

type MeteringControllerApiFetchMeteringStatsOpts

type MeteringControllerApiFetchMeteringStatsOpts struct {
	UseMinutes optional.Bool
}

type MeteringControllerApiGetMeteringStatsAndExtendLicenseOpts

type MeteringControllerApiGetMeteringStatsAndExtendLicenseOpts struct {
	UseMinutes            optional.Bool
	OverrideExtensionTime optional.Int64
}

type MeteringControllerApiService

type MeteringControllerApiService service

func (*MeteringControllerApiService) FetchMeteringLicense

func (a *MeteringControllerApiService) FetchMeteringLicense(ctx context.Context) (MeteredLicense, *http.Response, error)

MeteringControllerApiService Get Metered License for LiveData Migrator

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return MeteredLicense

func (*MeteringControllerApiService) FetchMeteringStats

func (*MeteringControllerApiService) GetMeteringStatsAndExtendLicense

type Migration

type Migration struct {
	MigrationId                          string                     `json:"migrationId,omitempty"`
	InternalId                           string                     `json:"internalId,omitempty"`
	Path                                 string                     `json:"path,omitempty"`
	ScanOnlyMigration                    bool                       `json:"scanOnlyMigration,omitempty"`
	RecurringMigration                   bool                       `json:"recurringMigration,omitempty"`
	RecurringPeriodSeconds               int32                      `json:"recurringPeriodSeconds,omitempty"`
	DeletionMode                         *DeletionMode              `json:"deletionMode,omitempty"`
	DelayedDeletionPeriodSeconds         int32                      `json:"delayedDeletionPeriodSeconds,omitempty"`
	AutoSourceCleanupEnabled             bool                       `json:"autoSourceCleanupEnabled,omitempty"`
	Source                               string                     `json:"source,omitempty"`
	Target                               string                     `json:"target,omitempty"`
	State                                *MigrationState            `json:"state,omitempty"`
	Resumable                            bool                       `json:"resumable,omitempty"`
	AbortReason                          string                     `json:"abortReason,omitempty"`
	Exclusions                           []Exclusion                `json:"exclusions,omitempty"`
	UserDefinedExclusions                []Exclusion                `json:"userDefinedExclusions,omitempty"`
	TargetActionPolicy                   string                     `json:"targetActionPolicy,omitempty"`
	PathMappings                         []PathMapping              `json:"pathMappings,omitempty"`
	UnscheduledEvents                    int32                      `json:"unscheduledEvents,omitempty"`
	ScheduledEvents                      int32                      `json:"scheduledEvents,omitempty"`
	FailedPathCount                      int64                      `json:"failedPathCount,omitempty"`
	AutoSourceCleanupQueuedPaths         int64                      `json:"autoSourceCleanupQueuedPaths,omitempty"`
	MaxStoppedUnscheduledEventBufferSize int32                      `json:"maxStoppedUnscheduledEventBufferSize,omitempty"`
	MigrationCreatedTime                 time.Time                  `json:"migrationCreatedTime,omitempty"`
	MigrationStartTime                   time.Time                  `json:"migrationStartTime,omitempty"`
	MigrationCompleteTime                time.Time                  `json:"migrationCompleteTime,omitempty"`
	MigrationEdge                        string                     `json:"migrationEdge,omitempty"`
	ScannerSummary                       *ScannerContentSummary     `json:"scannerSummary,omitempty"`
	ClientActivitySummary                *ScannerContentMatrix      `json:"clientActivitySummary,omitempty"`
	MaxPendingRegions                    int32                      `json:"maxPendingRegions,omitempty"`
	PendingRegionCount                   int64                      `json:"pendingRegionCount,omitempty"`
	MigrationGates                       []MigrationGate            `json:"migrationGates,omitempty"`
	RecurringMigrationTracker            *RecurringMigrationTracker `json:"recurringMigrationTracker,omitempty"`
	SourceCleanupTracker                 *SourceCleanupTracker      `json:"sourceCleanupTracker,omitempty"`
	AdditionalProperties                 map[string]string          `json:"additionalProperties,omitempty"`
	OldestIncompleteWorkItem             *OldestIncompleteWorkItem  `json:"oldestIncompleteWorkItem,omitempty"`
	NumberPathsRequeued                  int64                      `json:"numberPathsRequeued,omitempty"`
	MigrationPriority                    *MigrationPriority         `json:"migrationPriority,omitempty"`
}

type MigrationControllerApiAddPendingRegionToMigrationOpts

type MigrationControllerApiAddPendingRegionToMigrationOpts struct {
	ActionPolicy optional.String
}

type MigrationControllerApiCheckMigrationPathMappingsOpts

type MigrationControllerApiCheckMigrationPathMappingsOpts struct {
	Source optional.String
}

type MigrationControllerApiListMigrationErrorsOpts

type MigrationControllerApiListMigrationErrorsOpts struct {
	Since optional.Time
}

type MigrationControllerApiNewMigrationWithIdOpts

type MigrationControllerApiNewMigrationWithIdOpts struct {
	Source                   optional.String
	Exclusions               optional.Interface
	ActionPolicy             optional.String
	AutoStart                optional.Bool
	ScanOnlyMigration        optional.Bool
	AdditionalProperties     optional.Interface
	DeletionMode             optional.String
	DelayedDeletionPeriod    optional.Int32
	AutoSourceCleanupEnabled optional.Bool
	RecurringMigration       optional.Bool
	RecurringPeriod          optional.Int32
	MigrationPriority        optional.String
}

type MigrationControllerApiResetMigrationOpts

type MigrationControllerApiResetMigrationOpts struct {
	ActionPolicy   optional.String
	ReloadMappings optional.Bool
}

type MigrationControllerApiService

type MigrationControllerApiService service

func (*MigrationControllerApiService) AddExclusionToMigration

func (a *MigrationControllerApiService) AddExclusionToMigration(ctx context.Context, migrationId string, exclusionId string) (*http.Response, error)

MigrationControllerApiService Add exclusion to migration

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object
  • @param exclusionId Unique identifier of the exclusion object

func (*MigrationControllerApiService) AddPendingRegionToMigration

func (a *MigrationControllerApiService) AddPendingRegionToMigration(ctx context.Context, migrationId string, path string, localVarOptionals *MigrationControllerApiAddPendingRegionToMigrationOpts) (*http.Response, error)

func (*MigrationControllerApiService) CheckMigrationPathMappings

func (a *MigrationControllerApiService) CheckMigrationPathMappings(ctx context.Context, migrationId string, path string, target string, localVarOptionals *MigrationControllerApiCheckMigrationPathMappingsOpts) (MigrationMappingCheckResult, *http.Response, error)

func (*MigrationControllerApiService) ClearMigrations

func (a *MigrationControllerApiService) ClearMigrations(ctx context.Context) (*http.Response, error)

MigrationControllerApiService Delete all migrations

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*MigrationControllerApiService) DeleteExclusionFromMigration

func (a *MigrationControllerApiService) DeleteExclusionFromMigration(ctx context.Context, migrationId string, exclusionId string) (*http.Response, error)

MigrationControllerApiService Remove exclusion from migration

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object
  • @param exclusionId Unique identifier of the exclusion object

func (*MigrationControllerApiService) DeleteMigration

func (a *MigrationControllerApiService) DeleteMigration(ctx context.Context, migrationId string) (*http.Response, error)

MigrationControllerApiService Delete migration for given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

func (*MigrationControllerApiService) DeleteMigrationWithAssets

func (a *MigrationControllerApiService) DeleteMigrationWithAssets(ctx context.Context, migrationId string) (map[string]AssetDeletionStats, *http.Response, error)

MigrationControllerApiService Delete migration for given migration ID along with its assets

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return map[string]AssetDeletionStats

func (*MigrationControllerApiService) FetchMigration

func (a *MigrationControllerApiService) FetchMigration(ctx context.Context, migrationId string) (Migration, *http.Response, error)

MigrationControllerApiService Get migration for given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return Migration

func (*MigrationControllerApiService) GetOldestIncompleteWorkItem

func (a *MigrationControllerApiService) GetOldestIncompleteWorkItem(ctx context.Context, migrationId string) (OldestIncompleteWorkItem, *http.Response, error)

MigrationControllerApiService Get the oldest incomplete work item for a Migration.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return OldestIncompleteWorkItem

func (*MigrationControllerApiService) GetOldestIncompleteWorkItems

func (a *MigrationControllerApiService) GetOldestIncompleteWorkItems(ctx context.Context) ([]OldestIncompleteWorkItem, *http.Response, error)

MigrationControllerApiService Get a list of oldest incomplete work items across all migrations.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []OldestIncompleteWorkItem

func (*MigrationControllerApiService) GetPendingRegionsForMigration

func (a *MigrationControllerApiService) GetPendingRegionsForMigration(ctx context.Context, migrationId string) ([]PendingRegion, *http.Response, error)

MigrationControllerApiService Get the PendingRegions for a Migration.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return []PendingRegion

func (*MigrationControllerApiService) ListAutoSourceCleanupQueuedPaths

func (a *MigrationControllerApiService) ListAutoSourceCleanupQueuedPaths(ctx context.Context, migrationId string) ([]SourceCleanupQueuedPath, *http.Response, error)

MigrationControllerApiService List the top 10000 Auto-source Cleanup Paths Queued for deletion.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return []SourceCleanupQueuedPath

func (*MigrationControllerApiService) ListMigration

MigrationControllerApiService List all migrations

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Migration

func (*MigrationControllerApiService) ListMigrationErrors

func (*MigrationControllerApiService) NewMigrationWithId

func (a *MigrationControllerApiService) NewMigrationWithId(ctx context.Context, migrationId string, path string, target string, localVarOptionals *MigrationControllerApiNewMigrationWithIdOpts) (Migration, *http.Response, error)

func (*MigrationControllerApiService) ResetMigration

func (a *MigrationControllerApiService) ResetMigration(ctx context.Context, migrationId string, localVarOptionals *MigrationControllerApiResetMigrationOpts) (Migration, *http.Response, error)

func (*MigrationControllerApiService) ResumeMigration

func (a *MigrationControllerApiService) ResumeMigration(ctx context.Context, migrationId string) (Migration, *http.Response, error)

MigrationControllerApiService Resume migration for given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return Migration

func (*MigrationControllerApiService) StartMigration

func (a *MigrationControllerApiService) StartMigration(ctx context.Context, migrationId string) (Migration, *http.Response, error)

MigrationControllerApiService Start migration for given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return Migration

func (*MigrationControllerApiService) StopAllMigrations

func (*MigrationControllerApiService) StopMigration

func (a *MigrationControllerApiService) StopMigration(ctx context.Context, migrationId string, localVarOptionals *MigrationControllerApiStopMigrationOpts) (*http.Response, error)

func (*MigrationControllerApiService) ToggleMigrationDeletionMode

func (a *MigrationControllerApiService) ToggleMigrationDeletionMode(ctx context.Context, migrationId string, deletionMode string, actionPolicy string, localVarOptionals *MigrationControllerApiToggleMigrationDeletionModeOpts) (Migration, *http.Response, error)

func (*MigrationControllerApiService) UpdateMigrationMaxPendingRegions

func (a *MigrationControllerApiService) UpdateMigrationMaxPendingRegions(ctx context.Context, migrationId string, maxPendingRegions int32) (*http.Response, error)

MigrationControllerApiService Update the maximum number of pending regions for a migration.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object
  • @param maxPendingRegions Maximum number of pending regions

func (*MigrationControllerApiService) UpdateMigrationMaxUnscheduledEvents

func (a *MigrationControllerApiService) UpdateMigrationMaxUnscheduledEvents(ctx context.Context, migrationId string, maxEvents int32) (*http.Response, error)

MigrationControllerApiService Update the maximum number of unscheduled events to store for a migration if it is stopped.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object
  • @param maxEvents Maximum number of unscheduled events to store

func (*MigrationControllerApiService) UpdateMigrationProperties

func (a *MigrationControllerApiService) UpdateMigrationProperties(ctx context.Context, migrationId string, localVarOptionals *MigrationControllerApiUpdateMigrationPropertiesOpts) (*http.Response, error)

type MigrationControllerApiStopAllMigrationsOpts

type MigrationControllerApiStopAllMigrationsOpts struct {
	Resumable optional.Bool
}

type MigrationControllerApiStopMigrationOpts

type MigrationControllerApiStopMigrationOpts struct {
	Resumable optional.Bool
}

type MigrationControllerApiToggleMigrationDeletionModeOpts

type MigrationControllerApiToggleMigrationDeletionModeOpts struct {
	DelayedDeletionPeriod optional.Int32
}

type MigrationControllerApiUpdateMigrationPropertiesOpts

type MigrationControllerApiUpdateMigrationPropertiesOpts struct {
	Body                 optional.Interface
	AdditionalProperties optional.Interface
}

type MigrationDiagnostic

type MigrationDiagnostic struct {
	TimeStamp              int64                            `json:"timeStamp,omitempty"`
	Type_                  string                           `json:"type"`
	PendingRegions         map[string]int32                 `json:"pendingRegions,omitempty"`
	PendingRegionsMax      map[string]int32                 `json:"pendingRegionsMax,omitempty"`
	MigrationStateCounts   map[string]int32                 `json:"migrationStateCounts,omitempty"`
	FailedPaths            map[string]int64                 `json:"failedPaths,omitempty"`
	PathRetryCount         map[string]int64                 `json:"pathRetryCount,omitempty"`
	MigrationPathsRequeued map[string]int64                 `json:"migrationPathsRequeued,omitempty"`
	ScannerProgress        map[string]ScannerProgressMatrix `json:"scannerProgress,omitempty"`
	AverageFailedPaths     int64                            `json:"averageFailedPaths,omitempty"`
	AveragePendingRegions  int64                            `json:"averagePendingRegions,omitempty"`
	AveragePathRetries     int64                            `json:"averagePathRetries,omitempty"`
	TotalPendingRegions    int64                            `json:"totalPendingRegions,omitempty"`
	TotalFailedPaths       int64                            `json:"totalFailedPaths,omitempty"`
	TotalPathRetryCount    int64                            `json:"totalPathRetryCount,omitempty"`
}

type MigrationDuration

type MigrationDuration struct {
	AsText    string `json:"asText,omitempty"`
	InSeconds int64  `json:"inSeconds,omitempty"`
}

type MigrationFailures

type MigrationFailures struct {
	MigrationId     string       `json:"migrationId,omitempty"`
	InternalId      string       `json:"internalId,omitempty"`
	FailedPathCount int64        `json:"failedPathCount,omitempty"`
	FailedPaths     []FailedPath `json:"failedPaths,omitempty"`
}

type MigrationGate

type MigrationGate struct {
	GateId           string            `json:"gateId,omitempty"`
	GatePath         string            `json:"gatePath,omitempty"`
	ActionStatus     *GateActionStatus `json:"actionStatus,omitempty"`
	DependantRegions int32             `json:"dependantRegions,omitempty"`
	TimeCreated      time.Time         `json:"timeCreated,omitempty"`
	Complete         bool              `json:"complete,omitempty"`
	LastUpdated      time.Time         `json:"lastUpdated,omitempty"`
}

type MigrationGateControllerApiService

type MigrationGateControllerApiService service

func (*MigrationGateControllerApiService) BulkCheckClosedGates

func (a *MigrationGateControllerApiService) BulkCheckClosedGates(ctx context.Context, body MigrationGateIds) ([]string, *http.Response, error)

MigrationGateControllerApiService Bulk check for closed Gates by their ID's

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param body Gate IDs

@return []string

func (*MigrationGateControllerApiService) CheckClosedGates

func (a *MigrationGateControllerApiService) CheckClosedGates(ctx context.Context, gateIds []string) ([]string, *http.Response, error)

MigrationGateControllerApiService Check for closed Gates in bulk

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param gateIds Gate ID

@return []string

func (*MigrationGateControllerApiService) CloseMigrationGate

func (a *MigrationGateControllerApiService) CloseMigrationGate(ctx context.Context, gateId string) (*http.Response, error)

MigrationGateControllerApiService Close a Gate by its ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param gateId Gate ID

func (*MigrationGateControllerApiService) CreateMigrationGate

func (a *MigrationGateControllerApiService) CreateMigrationGate(ctx context.Context, path string, sourceFilesystemId string, targetFilesystemId string, gateId string) (MigrationGate, *http.Response, error)

MigrationGateControllerApiService Request a gate on a given migration by path

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param path Path of the Migration gate
  • @param sourceFilesystemId ID of the source Filesystem
  • @param targetFilesystemId ID of the target Filesystem
  • @param gateId Gate ID

@return MigrationGate

func (*MigrationGateControllerApiService) DeleteAllMigrationGates

func (a *MigrationGateControllerApiService) DeleteAllMigrationGates(ctx context.Context) (*http.Response, error)

MigrationGateControllerApiService Delete all Migration Gates

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*MigrationGateControllerApiService) DeleteBulkMigrationGates

func (a *MigrationGateControllerApiService) DeleteBulkMigrationGates(ctx context.Context, body MigrationGateIds) (*http.Response, error)

MigrationGateControllerApiService Bulk delete migration gates by their ID's

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param body Gate IDs

func (*MigrationGateControllerApiService) DeleteMigrationGates

func (a *MigrationGateControllerApiService) DeleteMigrationGates(ctx context.Context, gateIds []string) (*http.Response, error)

MigrationGateControllerApiService Delete a Gate by its ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param gateIds Gate IDs

func (*MigrationGateControllerApiService) GetBulkMigrationGates

MigrationGateControllerApiService Check status of a number of gates by their ID's

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param body Gate IDs

@return []MigrationGate

func (*MigrationGateControllerApiService) GetMigrationGates

func (a *MigrationGateControllerApiService) GetMigrationGates(ctx context.Context, gateIds []string) ([]MigrationGate, *http.Response, error)

MigrationGateControllerApiService Check status of a gate by its ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param gateIds Gate ID

@return []MigrationGate

type MigrationGateIds

type MigrationGateIds struct {
	GateIds []string `json:"gateIds,omitempty"`
}

type MigrationInfo

type MigrationInfo struct {
	InternalId     string             `json:"internalId,omitempty"`
	PathRetryCount int64              `json:"pathRetryCount,omitempty"`
	Id             string             `json:"id,omitempty"`
	Path           string             `json:"path,omitempty"`
	Progress       *MigrationProgress `json:"progress,omitempty"`
}

type MigrationInfoList

type MigrationInfoList struct {
	Migrations []MigrationInfo `json:"migrations,omitempty"`
	Count      int32           `json:"count,omitempty"`
}

type MigrationMappingCheckResult

type MigrationMappingCheckResult struct {
	Mappings                []PathMapping `json:"mappings,omitempty"`
	ConflictingMigrationIds []string      `json:"conflictingMigrationIds,omitempty"`
}

type MigrationPatch

type MigrationPatch struct {
	DelayedDeletionPeriod  int32              `json:"delayedDeletionPeriod,omitempty"`
	RecurringPeriodSeconds int32              `json:"recurringPeriodSeconds,omitempty"`
	MigrationPriority      *MigrationPriority `json:"migrationPriority,omitempty"`
}

type MigrationPathStatus

type MigrationPathStatus struct {
	// Migration path is under
	MigrationId string `json:"migrationId,omitempty"`
	// Source path
	SourcePath string `json:"sourcePath,omitempty"`
	// Target path after being mapped
	TargetPath string `json:"targetPath,omitempty"`
	// Path mapping applied to path - null if none
	PathMappingId string `json:"pathMappingId,omitempty"`
	// Exclusion applied to path - null if none
	ExclusionId string `json:"exclusionId,omitempty"`
	// If path is in a pending region
	InPendingRegion bool `json:"inPendingRegion,omitempty"`
	Scheduled       bool `json:"scheduled,omitempty"`
	// Number of scheduled actions on path
	ActionCount int32 `json:"actionCount,omitempty"`
}

Status of a path

type MigrationPathStatusControllerApiService

type MigrationPathStatusControllerApiService service

func (*MigrationPathStatusControllerApiService) GetPathStatus

MigrationPathStatusControllerApiService Displays information on a path in a current migration.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param path Path on source filesystem.
  • @param sourceId

@return MigrationPathStatus

type MigrationPriority

type MigrationPriority string
const (
	HIGH_MigrationPriority   MigrationPriority = "HIGH"
	NORMAL_MigrationPriority MigrationPriority = "NORMAL"
	LOW_MigrationPriority    MigrationPriority = "LOW"
)

List of MigrationPriority

type MigrationProgress

type MigrationProgress struct {
	TotalBytes                                       int64              `json:"totalBytes,omitempty"`
	ExcludedBytes                                    int64              `json:"excludedBytes,omitempty"`
	MigratedBytes                                    int64              `json:"migratedBytes,omitempty"`
	MigrationClientBytesBinaryUnitValue              string             `json:"migrationClientBytesBinaryUnitValue,omitempty"`
	MigrationExcludedReadableBinaryValue             string             `json:"migrationExcludedReadableBinaryValue,omitempty"`
	MigratedPercentage                               int32              `json:"migratedPercentage,omitempty"`
	MigrationClientBytesBinaryUnits                  string             `json:"migrationClientBytesBinaryUnits,omitempty"`
	MigrationTotalTransferredReadableBinaryUnits     string             `json:"migrationTotalTransferredReadableBinaryUnits,omitempty"`
	MigrationTotalTransferredReadableBinaryUnitValue string             `json:"migrationTotalTransferredReadableBinaryUnitValue,omitempty"`
	MigrationTotalReadableBinaryUnits                string             `json:"migrationTotalReadableBinaryUnits,omitempty"`
	MigrationTotalBinaryUnitValue                    string             `json:"migrationTotalBinaryUnitValue,omitempty"`
	MigrationMigratedReadableBinaryUnits             string             `json:"migrationMigratedReadableBinaryUnits,omitempty"`
	MigrationTotalTransferredProgressBinaryValue     string             `json:"migrationTotalTransferredProgressBinaryValue,omitempty"`
	MigrationTransferredProgressBinaryValue          string             `json:"migrationTransferredProgressBinaryValue,omitempty"`
	MigrationExcludedBinaryUnitValue                 string             `json:"migrationExcludedBinaryUnitValue,omitempty"`
	TotalMigratedBytes                               int64              `json:"totalMigratedBytes,omitempty"`
	TotalMigratedBytesBinaryUnitValue                string             `json:"totalMigratedBytesBinaryUnitValue,omitempty"`
	EtaEstimate                                      *MigrationDuration `json:"etaEstimate,omitempty"`
	DataMigratedDueToScan                            int64              `json:"dataMigratedDueToScan,omitempty"`
	DataMigratedDueToScanBinaryUnit                  string             `json:"dataMigratedDueToScanBinaryUnit,omitempty"`
	DataMigratedDueToScanReadableValue               string             `json:"dataMigratedDueToScanReadableValue,omitempty"`
	OverallProgressSentValue                         int64              `json:"overallProgressSentValue,omitempty"`
	OverallProgressSentBinaryUnit                    string             `json:"overallProgressSentBinaryUnit,omitempty"`
	OverallProgressSentReadableValue                 string             `json:"overallProgressSentReadableValue,omitempty"`
	MigrationTotalScannedReadableBinaryUnits         string             `json:"migrationTotalScannedReadableBinaryUnits,omitempty"`
	MigrationTotalScannedProgressBinaryValue         string             `json:"migrationTotalScannedProgressBinaryValue,omitempty"`
	MigrationTotalScannedReadableBinaryUnitValue     string             `json:"migrationTotalScannedReadableBinaryUnitValue,omitempty"`
	TotalScannedBytes                                int64              `json:"totalScannedBytes,omitempty"`
	TotalScannedBytesBinaryUnitValue                 string             `json:"totalScannedBytesBinaryUnitValue,omitempty"`
	Duration                                         *MigrationDuration `json:"duration,omitempty"`
}

type MigrationRecord

type MigrationRecord struct {
	MigrationId    string          `json:"migrationId,omitempty"`
	TimeStamp      int64           `json:"timeStamp,omitempty"`
	MigrationStats *MigrationStats `json:"migrationStats,omitempty"`
}

type MigrationState

type MigrationState string
const (
	NONSCHEDULED_MigrationState                MigrationState = "NONSCHEDULED"
	SCHEDULED_MigrationState                   MigrationState = "SCHEDULED"
	RUNNING_MigrationState                     MigrationState = "RUNNING"
	LIVE_MigrationState                        MigrationState = "LIVE"
	PAUSED_MigrationState                      MigrationState = "PAUSED"
	STOPPED_MigrationState                     MigrationState = "STOPPED"
	COMPLETED_MigrationState                   MigrationState = "COMPLETED"
	RECURRENCE_SCHEDULED_MigrationState        MigrationState = "RECURRENCE_SCHEDULED"
	WAITING_FOR_NEXT_RECURRENCE_MigrationState MigrationState = "WAITING_FOR_NEXT_RECURRENCE"
	STOPPING_MigrationState                    MigrationState = "STOPPING"
)

List of MigrationState

type MigrationStats

type MigrationStats struct {
	FilesMigratedScan                 int64            `json:"filesMigratedScan,omitempty"`
	DirsMigratedScan                  int64            `json:"dirsMigratedScan,omitempty"`
	RawBytesMigratedScan              int64            `json:"rawBytesMigratedScan,omitempty"`
	SuccessfulBytesMigratedScan       int64            `json:"successfulBytesMigratedScan,omitempty"`
	FilesMigratedClient               int64            `json:"filesMigratedClient,omitempty"`
	DirsMigratedClient                int64            `json:"dirsMigratedClient,omitempty"`
	RawBytesMigratedClient            int64            `json:"rawBytesMigratedClient,omitempty"`
	SuccessfulBytesMigratedClient     int64            `json:"successfulBytesMigratedClient,omitempty"`
	FilesMigratedClientScan           int64            `json:"filesMigratedClientScan,omitempty"`
	DirsMigratedClientScan            int64            `json:"dirsMigratedClientScan,omitempty"`
	RawBytesMigratedClientScan        int64            `json:"rawBytesMigratedClientScan,omitempty"`
	SuccessfulBytesMigratedClientScan int64            `json:"successfulBytesMigratedClientScan,omitempty"`
	BytesExcluded                     int64            `json:"bytesExcluded,omitempty"`
	FilesExcluded                     int64            `json:"filesExcluded,omitempty"`
	DirsExcluded                      int64            `json:"dirsExcluded,omitempty"`
	EventsExcluded                    int64            `json:"eventsExcluded,omitempty"`
	FilesScanned                      int64            `json:"filesScanned,omitempty"`
	DirsScanned                       int64            `json:"dirsScanned,omitempty"`
	FilesRescanned                    int64            `json:"filesRescanned,omitempty"`
	DirsRescanned                     int64            `json:"dirsRescanned,omitempty"`
	FileCountBySize                   map[string]int64 `json:"fileCountBySize,omitempty"`
	SuccessfulBytesMigrated           int64            `json:"successfulBytesMigrated,omitempty"`
	RawBytesMigrated                  int64            `json:"rawBytesMigrated,omitempty"`
	FileSystemAction                  int64            `json:"fileSystemAction,omitempty"`
	FileSystemActionsScan             int64            `json:"fileSystemActionsScan,omitempty"`
	DirsMigrated                      int64            `json:"dirsMigrated,omitempty"`
	FilesMigrated                     int64            `json:"filesMigrated,omitempty"`
	IncomingTransportBytes            int64            `json:"incomingTransportBytes,omitempty"`
	OutgoingTransportBytes            int64            `json:"outgoingTransportBytes,omitempty"`
}

type MigrationsSummary

type MigrationsSummary struct {
	OverallCount             int32              `json:"overallCount,omitempty"`
	Running                  *MigrationInfoList `json:"running,omitempty"`
	Ready                    *MigrationInfoList `json:"ready,omitempty"`
	Stopped                  *MigrationInfoList `json:"stopped,omitempty"`
	Live                     *MigrationInfoList `json:"live,omitempty"`
	MigrationStats           []MigrationRecord  `json:"migrationStats,omitempty"`
	Completed                *MigrationInfoList `json:"completed,omitempty"`
	WaitingForNextRecurrence *MigrationInfoList `json:"waitingForNextRecurrence,omitempty"`
	RecurrenceScheduled      *MigrationInfoList `json:"recurrenceScheduled,omitempty"`
}

type MultipartCreateFileBody

type MultipartCreateFileBody struct {
	// Path to the file
	Path string `json:"path"`
	// File content
	FileBody **os.File `json:"fileBody"`
}

type MultipartGcsWithJsonKeyBody

type MultipartGcsWithJsonKeyBody struct {
	FsProperties *GcsFilesystemProperties `json:"fsProperties"`
	// JSON KeyFile
	File **os.File `json:"file,omitempty"`
}

type MultipartGcsWithP12KeyFileBody

type MultipartGcsWithP12KeyFileBody struct {
	FsProperties *GcsFilesystemProperties `json:"fsProperties"`
	// P12 KeyFile
	File **os.File `json:"file"`
}

type NetworkConnection

type NetworkConnection struct {
	Sl               int32  `json:"sl,omitempty"`
	LocalAddressIP   string `json:"localAddressIP,omitempty"`
	LocalAddressPort int32  `json:"localAddressPort,omitempty"`
	RemAddressIP     string `json:"remAddressIP,omitempty"`
	RemAddressPort   int32  `json:"remAddressPort,omitempty"`
	St               int32  `json:"st,omitempty"`
	TxQueue          int32  `json:"txQueue,omitempty"`
	RxQueue          int32  `json:"rxQueue,omitempty"`
	Retrnsmt         int32  `json:"retrnsmt,omitempty"`
	Uid              int32  `json:"uid,omitempty"`
	Inode            int64  `json:"inode,omitempty"`
}

type NetworkStatus

type NetworkStatus struct {
	TimeStamp        int64                 `json:"timeStamp,omitempty"`
	Type_            string                `json:"type"`
	Uid              int64                 `json:"uid,omitempty"`
	Connections      []NetworkConnection   `json:"connections,omitempty"`
	ConnectionTotals map[string]RxTxTotals `json:"connectionTotals,omitempty"`
	CountTcpStates   map[string]int32      `json:"countTcpStates,omitempty"`
}

type Notification

type Notification struct {
	Level            *NotificationLevel     `json:"level,omitempty"`
	Type_            string                 `json:"type,omitempty"`
	Message          string                 `json:"message,omitempty"`
	Id               string                 `json:"id,omitempty"`
	TimeStamp        int64                  `json:"timeStamp,omitempty"`
	Code             int32                  `json:"code,omitempty"`
	Resolved         bool                   `json:"resolved,omitempty"`
	UpdatedTimeStamp int64                  `json:"updatedTimeStamp,omitempty"`
	Payload          map[string]interface{} `json:"payload,omitempty"`
	DateUpdated      time.Time              `json:"dateUpdated,omitempty"`
	DateCreated      time.Time              `json:"dateCreated,omitempty"`
}

type NotificationControllerApiFetchNotificationsOpts

type NotificationControllerApiFetchNotificationsOpts struct {
	Count           optional.Int32
	Since           optional.Time
	Type_           optional.String
	ExcludeResolved optional.Bool
	Level           optional.Interface
}

type NotificationControllerApiService

type NotificationControllerApiService service

func (*NotificationControllerApiService) Atom

func (a *NotificationControllerApiService) Atom(ctx context.Context) (interface{}, *http.Response, error)

NotificationControllerApiService Get Atom feed for Notifications

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return interface{}

func (*NotificationControllerApiService) FetchNotification

func (a *NotificationControllerApiService) FetchNotification(ctx context.Context, notificationId string) (Notification, *http.Response, error)

NotificationControllerApiService Get a Notification

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param notificationId Identifier for Notification

@return Notification

func (*NotificationControllerApiService) FetchNotifications

type NotificationLevel

type NotificationLevel string
const (
	INFO_NotificationLevel   NotificationLevel = "INFO"
	WARN_NotificationLevel   NotificationLevel = "WARN"
	ERROR__NotificationLevel NotificationLevel = "ERROR"
)

List of NotificationLevel

type NotificationNotFound

type NotificationNotFound struct {
	Status           *HttpStatus `json:"status,omitempty"`
	ErrorCode        *ErrorCode  `json:"errorCode,omitempty"`
	Message          string      `json:"message,omitempty"`
	LocalizedMessage string      `json:"localizedMessage,omitempty"`
}

type OldestIncompleteWorkItem

type OldestIncompleteWorkItem struct {
	// Migration id
	MigrationId string `json:"migrationId,omitempty"`
	// Type of item
	ItemType  string      `json:"itemType,omitempty"`
	Operation *ActionType `json:"operation,omitempty"`
	// Path of item as provided by the source
	Path string `json:"path,omitempty"`
	// Destination path (if rename)
	NewPath string `json:"newPath,omitempty"`
	// Timestamp of item provided by source filesystem
	SourceEventCreationTimestamp int64 `json:"sourceEventCreationTimestamp,omitempty"`
	// Human readable date of item provided by source filesystem
	SourceEventCreationDate time.Time `json:"sourceEventCreationDate,omitempty"`
	// Timestamp of action being created in LDM
	LdmActionCreationTimeStamp int64 `json:"ldmActionCreationTimeStamp,omitempty"`
	// Human readable date of action being created in LDM
	LdmActionCreationDate time.Time `json:"ldmActionCreationDate,omitempty"`
}

oldest incomplete work item of a migration

type OverallDataAgentStatsHistory

type OverallDataAgentStatsHistory struct {
	DataAgentStatsRecordEntity []DataAgentStatsHistory `json:"dataAgentStatsRecordEntity,omitempty"`
}

type PathMapping

type PathMapping struct {
	Id               string `json:"id,omitempty"`
	Description      string `json:"description,omitempty"`
	SourceFileSystem string `json:"sourceFileSystem,omitempty"`
	SourcePath       string `json:"sourcePath,omitempty"`
	TargetFileSystem string `json:"targetFileSystem,omitempty"`
	TargetPath       string `json:"targetPath,omitempty"`
}

type PathMappingControllerApiCreateMappingOpts

type PathMappingControllerApiCreateMappingOpts struct {
	PathMappingId optional.String
	Description   optional.String
}

type PathMappingControllerApiFetchAllOpts

type PathMappingControllerApiFetchAllOpts struct {
	SourceFileSystemName optional.String
	TargetFileSystemName optional.String
}

type PathMappingControllerApiService

type PathMappingControllerApiService service

func (*PathMappingControllerApiService) CreateMapping

func (a *PathMappingControllerApiService) CreateMapping(ctx context.Context, sourceFileSystem string, sourcePath string, targetFileSystem string, targetPath string, localVarOptionals *PathMappingControllerApiCreateMappingOpts) (PathMapping, *http.Response, error)

func (*PathMappingControllerApiService) Delete

PathMappingControllerApiService Delete a Mapping

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param id Identifier for mapping

func (*PathMappingControllerApiService) FetchAll

func (*PathMappingControllerApiService) FetchMapping

PathMappingControllerApiService Fetch a Mapping

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param id Identifier for mapping

@return PathMapping

type PathMappingNotFoundException

type PathMappingNotFoundException struct {
	Status           *HttpStatus `json:"status,omitempty"`
	ErrorCode        *ErrorCode  `json:"errorCode,omitempty"`
	Message          string      `json:"message,omitempty"`
	LocalizedMessage string      `json:"localizedMessage,omitempty"`
}

type PendingRegion

type PendingRegion struct {
	PendingRegionId int64     `json:"pendingRegionId,omitempty"`
	Path            string    `json:"path,omitempty"`
	ActionPolicy    string    `json:"actionPolicy,omitempty"`
	DateCreated     time.Time `json:"dateCreated,omitempty"`
}

type Pressure

type Pressure struct {
	Type_              string  `json:"type,omitempty"`
	Sample             string  `json:"sample,omitempty"`
	TenSecond          float64 `json:"tenSecond,omitempty"`
	ThirtySecond       float64 `json:"thirtySecond,omitempty"`
	SixtySecond        float64 `json:"sixtySecond,omitempty"`
	ThreeHundredSecond float64 `json:"threeHundredSecond,omitempty"`
}

type PreviewFeatureControllerApiService

type PreviewFeatureControllerApiService service

func (*PreviewFeatureControllerApiService) GetPreviewFeatureStatus

func (a *PreviewFeatureControllerApiService) GetPreviewFeatureStatus(ctx context.Context) (PreviewInfo, *http.Response, error)

PreviewFeatureControllerApiService Get all preview features

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return PreviewInfo

type PreviewInfo

type PreviewInfo struct {
	Previewverifications string `json:"preview/verifications,omitempty"`
	Previewbackups       string `json:"preview/backups,omitempty"`
}

type RecurringMigrationIteration

type RecurringMigrationIteration struct {
	StartTime         time.Time `json:"startTime,omitempty"`
	CompleteTime      time.Time `json:"completeTime,omitempty"`
	Iteration         int32     `json:"iteration,omitempty"`
	DurationInSeconds int32     `json:"durationInSeconds,omitempty"`
}

type RecurringMigrationTracker

type RecurringMigrationTracker struct {
	Iterations                 []RecurringMigrationIteration `json:"iterations,omitempty"`
	RecurringCount             int32                         `json:"recurringCount,omitempty"`
	ScansInLastTwentyFourHours int32                         `json:"scansInLastTwentyFourHours,omitempty"`
	ScansInLastSevenDays       int32                         `json:"scansInLastSevenDays,omitempty"`
	AvgDurationInSeconds       int32                         `json:"avgDurationInSeconds,omitempty"`
}

type RegexExclusion

type RegexExclusion struct {
	Id                string            `json:"id,omitempty"`
	Description       string            `json:"description,omitempty"`
	FsRestriction     bool              `json:"fsRestriction,omitempty"`
	SourceFsExclusion bool              `json:"sourceFsExclusion,omitempty"`
	GlobalExclusion   bool              `json:"globalExclusion,omitempty"`
	DefaultExclusion  bool              `json:"defaultExclusion,omitempty"`
	Type_             string            `json:"type"`
	PatternType       *RegexPatternType `json:"patternType,omitempty"`
	Regex             string            `json:"regex,omitempty"`
}

type RegexPatternType

type RegexPatternType string
const (
	JAVA_PCRE_RegexPatternType RegexPatternType = "JAVA_PCRE"
	AUTOMATA_RegexPatternType  RegexPatternType = "AUTOMATA"
	GLOB_RegexPatternType      RegexPatternType = "GLOB"
)

List of RegexPatternType

type RequeuingAction

type RequeuingAction struct {
	MigrationId           string      `json:"migrationId,omitempty"`
	Path                  []string    `json:"path,omitempty"`
	FirstRequeueTimestamp int64       `json:"firstRequeueTimestamp,omitempty"`
	LastRequeueTimestamp  int64       `json:"lastRequeueTimestamp,omitempty"`
	ActionId              int64       `json:"actionId,omitempty"`
	Action                *ActionType `json:"action,omitempty"`
	NumberOfRequeues      int64       `json:"numberOfRequeues,omitempty"`
	NSecondsRequeuing     int64       `json:"nSecondsRequeuing,omitempty"`
	FailureMessage        string      `json:"failureMessage,omitempty"`
}

type RequeuingActionsControllerApiGetAllRequeuingActionsOpts

type RequeuingActionsControllerApiGetAllRequeuingActionsOpts struct {
	Limit optional.Int32
}

type RequeuingActionsControllerApiGetMigrationRequeuingActionsOpts

type RequeuingActionsControllerApiGetMigrationRequeuingActionsOpts struct {
	Limit optional.Int32
}

type RequeuingActionsControllerApiService

type RequeuingActionsControllerApiService service

func (*RequeuingActionsControllerApiService) CancelRequeuingAction

func (a *RequeuingActionsControllerApiService) CancelRequeuingAction(ctx context.Context, migrationId string, actionId int32) (*http.Response, error)

RequeuingActionsControllerApiService Remove requeue action from migration

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object
  • @param actionId Unique identifier of the action object

func (*RequeuingActionsControllerApiService) GetAllRequeuingActions

func (*RequeuingActionsControllerApiService) GetAllRequeuingActionsStats

RequeuingActionsControllerApiService Get all requeuing actions stats

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return RequeuingActionsStats

func (*RequeuingActionsControllerApiService) GetMigrationRequeuingActions

func (*RequeuingActionsControllerApiService) GetMigrationRequeuingActionsStats

func (a *RequeuingActionsControllerApiService) GetMigrationRequeuingActionsStats(ctx context.Context, migrationId string) (RequeuingActionsStats, *http.Response, error)

RequeuingActionsControllerApiService Get all requeuing actions stats for specific migration

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return RequeuingActionsStats

func (*RequeuingActionsControllerApiService) GetRequeuingAction

func (a *RequeuingActionsControllerApiService) GetRequeuingAction(ctx context.Context, migrationId string, actionId int32) (RequeuingAction, *http.Response, error)

RequeuingActionsControllerApiService Get requeue action by migration ID and action ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object
  • @param actionId Unique identifier of the action object

@return RequeuingAction

type RequeuingActionsStats

type RequeuingActionsStats struct {
	RequeueCount            int64            `json:"requeueCount,omitempty"`
	RequeueCountByMigration map[string]int64 `json:"requeueCountByMigration,omitempty"`
}

type RxTxTotals

type RxTxTotals struct {
	TotalRxQueue int64 `json:"totalRxQueue,omitempty"`
	TotalTxQueue int64 `json:"totalTxQueue,omitempty"`
	Retrnsmt     int64 `json:"retrnsmt,omitempty"`
}

type S3aFilesystemProperties

type S3aFilesystemProperties struct {
	// Access key
	AccessKey string `json:"accessKey,omitempty"`
	// Secret key
	SecretKey string `json:"secretKey,omitempty"`
	// Credentials Provider
	CredentialsProvider string `json:"credentialsProvider,omitempty"`
	// aws profile
	AwsProfile string `json:"awsProfile,omitempty"`
	// path to credentials file with profiles
	AwsCredentialsConfigFile string `json:"awsCredentialsConfigFile,omitempty"`
	// Bucket Name
	BucketName string `json:"bucketName,omitempty"`
	// s3 endpoint
	Endpoint string `json:"endpoint,omitempty"`
	// Additional filesystem properties
	AdditionalProperties map[string]string `json:"additionalProperties,omitempty"`
	// SQS queue used when using s3 as a source
	SqsQueue string `json:"sqsQueue,omitempty"`
	// Indicates an s3a compatibility filesystem type
	S3type string `json:"s3type,omitempty"`
	// Kafka server, host:port
	BootstrapServers string `json:"bootstrapServers,omitempty"`
	// Kafka's topic where s3 object change notifications are provided
	Topic string `json:"topic,omitempty"`
	// sqs endpoint
	SqsEndpoint string `json:"sqsEndpoint,omitempty"`
	// ldm will cleanup sqs queue after when the filesystem is deleted
	CleanUpSqsQueue bool `json:"cleanUpSqsQueue,omitempty"`
}

S3a filesystem properties

type S3aSourceFileSystemControllerApiAddSourceS3aFileSystemOpts

type S3aSourceFileSystemControllerApiAddSourceS3aFileSystemOpts struct {
	PropertiesFiles optional.Interface
	ScanOnly        optional.Bool
}

type S3aSourceFileSystemControllerApiService

type S3aSourceFileSystemControllerApiService service

func (*S3aSourceFileSystemControllerApiService) AddSourceS3aFileSystem

func (*S3aSourceFileSystemControllerApiService) UpdateSourceS3aFileSystem

type S3aSourceFileSystemControllerApiUpdateSourceS3aFileSystemOpts

type S3aSourceFileSystemControllerApiUpdateSourceS3aFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type S3aTargetFileSystemControllerApiAddTargetS3aFileSystemOpts

type S3aTargetFileSystemControllerApiAddTargetS3aFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type S3aTargetFileSystemControllerApiService

type S3aTargetFileSystemControllerApiService service

func (*S3aTargetFileSystemControllerApiService) AddTargetS3aFileSystem

func (*S3aTargetFileSystemControllerApiService) UpdateTargetS3aFileSystem

type S3aTargetFileSystemControllerApiUpdateTargetS3aFileSystemOpts

type S3aTargetFileSystemControllerApiUpdateTargetS3aFileSystemOpts struct {
	PropertiesFiles optional.Interface
}

type ScannerContentMatrix

type ScannerContentMatrix struct {
	ByteCount      int64 `json:"byteCount,omitempty"`
	FileCount      int64 `json:"fileCount,omitempty"`
	DirectoryCount int64 `json:"directoryCount,omitempty"`
}

type ScannerContentSummary

type ScannerContentSummary struct {
	ProgressSummary *ScannerProgressMatrix `json:"progressSummary,omitempty"`
	ContentSummary  *ScannerContentMatrix  `json:"contentSummary,omitempty"`
}

type ScannerProgressMatrix

type ScannerProgressMatrix struct {
	FilesScanned           int64     `json:"filesScanned,omitempty"`
	DirectoriesScanned     int64     `json:"directoriesScanned,omitempty"`
	BytesScanned           int64     `json:"bytesScanned,omitempty"`
	FilesExcluded          int64     `json:"filesExcluded,omitempty"`
	DirsExcluded           int64     `json:"dirsExcluded,omitempty"`
	BytesExcluded          int64     `json:"bytesExcluded,omitempty"`
	BaseScanCompletionTime time.Time `json:"baseScanCompletionTime,omitempty"`
}

type SmtpAuth

type SmtpAuth struct {
	// Authentication is enabled
	AuthEnabled bool `json:"authEnabled"`
	// Login
	Login string `json:"login,omitempty"`
	// Password
	Password string `json:"password,omitempty"`
}

Authentication credentials for connection to SMTP server

type SmtpConfiguration

type SmtpConfiguration struct {
	// Host of the SMTP server
	Host string `json:"host,omitempty"`
	// Port of the SMTP server
	Port     int32             `json:"port,omitempty"`
	Security *SmtpSecurityType `json:"security,omitempty"`
	// Email that will be used by notification sender
	Email string    `json:"email,omitempty"`
	Auth  *SmtpAuth `json:"auth,omitempty"`
	// Prefix to be added to the e-mail subject
	SubjectPrefix string `json:"subjectPrefix,omitempty"`
}

Configuration properties for connection to SMTP server

type SmtpSecurityType

type SmtpSecurityType string

SmtpSecurityType : Security type of SMTP

const (
	SSL_SmtpSecurityType               SmtpSecurityType = "SSL"
	TLS_SmtpSecurityType               SmtpSecurityType = "TLS"
	STARTTLS_ENABLED_SmtpSecurityType  SmtpSecurityType = "STARTTLS_ENABLED"
	STARTTLS_REQUIRED_SmtpSecurityType SmtpSecurityType = "STARTTLS_REQUIRED"
	NONE_SmtpSecurityType              SmtpSecurityType = "NONE"
)

List of SmtpSecurityType

type SourceCleanupControllerApiService

type SourceCleanupControllerApiService service

func (*SourceCleanupControllerApiService) DeleteSourceCleanupReport

func (a *SourceCleanupControllerApiService) DeleteSourceCleanupReport(ctx context.Context, migrationId string, reportName string) (*http.Response, error)

SourceCleanupControllerApiService Delete source cleanup report(s) for a given migration ID and report name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the Migration object
  • @param reportName filename of the report to be returned

func (*SourceCleanupControllerApiService) GetOrphanedCleanupReportsList

SourceCleanupControllerApiService Get a list of the metadata for all orphaned deletion reports

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []SourceCleanupReportFileMetadata

func (*SourceCleanupControllerApiService) GetSourceCleanupReport

func (a *SourceCleanupControllerApiService) GetSourceCleanupReport(ctx context.Context, migrationId string, reportName string) (*os.File, *http.Response, error)

SourceCleanupControllerApiService Get a source cleanup report for a given migration ID and report name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the Migration object
  • @param reportName filename of the report to be returned

@return *os.File

func (*SourceCleanupControllerApiService) GetSourceCleanupReportsList

func (a *SourceCleanupControllerApiService) GetSourceCleanupReportsList(ctx context.Context, migrationId string) ([]SourceCleanupReportFileMetadata, *http.Response, error)

SourceCleanupControllerApiService Get the metadata of the available source cleanup reports for the given Migration

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the Migration object

@return []SourceCleanupReportFileMetadata

func (*SourceCleanupControllerApiService) PauseDelayedDeletionCacheReader

func (a *SourceCleanupControllerApiService) PauseDelayedDeletionCacheReader(ctx context.Context) (*http.Response, error)

SourceCleanupControllerApiService Pause the Delayed Deletion Cache Reader from deleting files

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*SourceCleanupControllerApiService) ResumeDelayedDeletionCacheReader

func (a *SourceCleanupControllerApiService) ResumeDelayedDeletionCacheReader(ctx context.Context) (*http.Response, error)

SourceCleanupControllerApiService Resume the Delayed Deletion Cache Reader

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

type SourceCleanupQueuedPath

type SourceCleanupQueuedPath struct {
	Path      string `json:"path,omitempty"`
	TimeStamp int64  `json:"timeStamp,omitempty"`
}

type SourceCleanupReportFileDescriptor

type SourceCleanupReportFileDescriptor struct {
	Name     string                   `json:"name,omitempty"`
	Type_    *SourceCleanupReportType `json:"type,omitempty"`
	MimeType string                   `json:"mimeType,omitempty"`
}

type SourceCleanupReportFileMetadata

type SourceCleanupReportFileMetadata struct {
	Descriptor      *SourceCleanupReportFileDescriptor `json:"descriptor,omitempty"`
	Size            int64                              `json:"size,omitempty"`
	MigrationId     string                             `json:"migrationId,omitempty"`
	MigrationExists bool                               `json:"migrationExists,omitempty"`
	Checksum        int64                              `json:"checksum,omitempty"`
	MigrationName   string                             `json:"migrationName,omitempty"`
}

type SourceCleanupReportType

type SourceCleanupReportType string
const (
	PARTIAL_SourceCleanupReportType SourceCleanupReportType = "PARTIAL"
	FULL_SourceCleanupReportType    SourceCleanupReportType = "FULL"
)

List of SourceCleanupReportType

type SourceCleanupTracker

type SourceCleanupTracker struct {
	Count         int32     `json:"count,omitempty"`
	InProgress    bool      `json:"inProgress,omitempty"`
	LastStartTime time.Time `json:"lastStartTime,omitempty"`
}

type SourceFileSystemControllerApiClearSourceFileSystemsOpts

type SourceFileSystemControllerApiClearSourceFileSystemsOpts struct {
	DeleteListener optional.Bool
}

type SourceFileSystemControllerApiDeleteSourceFileSystemOpts

type SourceFileSystemControllerApiDeleteSourceFileSystemOpts struct {
	DeleteListener optional.Bool
}

type SourceFileSystemControllerApiGetSourceFileSystemOpts

type SourceFileSystemControllerApiGetSourceFileSystemOpts struct {
	Verbose optional.Bool
}

type SourceFileSystemControllerApiListSourceFileSystemsOpts

type SourceFileSystemControllerApiListSourceFileSystemsOpts struct {
	Verbose optional.Bool
}

type SourceFileSystemControllerApiService

type SourceFileSystemControllerApiService service

func (*SourceFileSystemControllerApiService) ClearSourceFileSystems

func (*SourceFileSystemControllerApiService) DeleteSourceFileSystem

func (*SourceFileSystemControllerApiService) GetSourceAutoDiscoverMessage

func (a *SourceFileSystemControllerApiService) GetSourceAutoDiscoverMessage(ctx context.Context) (string, *http.Response, error)

SourceFileSystemControllerApiService Get auto-discover file system message

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*SourceFileSystemControllerApiService) GetSourceAutoDiscoverStatus

SourceFileSystemControllerApiService Get auto-discover file system status object

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return AutoDiscoverFsStatus

func (*SourceFileSystemControllerApiService) GetSourceFileSystem

func (*SourceFileSystemControllerApiService) ListSourceFileSystems

type StatisticsControllerApiFetchFileSizeDistributionActiveOpts

type StatisticsControllerApiFetchFileSizeDistributionActiveOpts struct {
	Range_      optional.Int32
	MigrationId optional.String
}

type StatisticsControllerApiFetchFileSizeDistributionOpts

type StatisticsControllerApiFetchFileSizeDistributionOpts struct {
	Range_      optional.Int32
	MigrationId optional.String
}

type StatisticsControllerApiFetchFileTransferRatesDistributionActiveOpts

type StatisticsControllerApiFetchFileTransferRatesDistributionActiveOpts struct {
	Range_      optional.Int32
	MigrationId optional.String
}

type StatisticsControllerApiFetchFileTransferRatesDistributionOpts

type StatisticsControllerApiFetchFileTransferRatesDistributionOpts struct {
	Range_      optional.Int32
	MigrationId optional.String
}

type StatisticsControllerApiService

type StatisticsControllerApiService service

func (*StatisticsControllerApiService) FetchAllCurrentMigrationStats

func (a *StatisticsControllerApiService) FetchAllCurrentMigrationStats(ctx context.Context) ([]MigrationRecord, *http.Response, error)

StatisticsControllerApiService Get current Stats for all migrations

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []MigrationRecord

func (*StatisticsControllerApiService) FetchCurrentMigrationStats

func (a *StatisticsControllerApiService) FetchCurrentMigrationStats(ctx context.Context, migrationId string) (MigrationRecord, *http.Response, error)

StatisticsControllerApiService Get current Stats for given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return MigrationRecord

func (*StatisticsControllerApiService) FetchDiagnostics

StatisticsControllerApiService Get File Trackers

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []FileTracker

func (*StatisticsControllerApiService) FetchDiagnosticsActive

func (a *StatisticsControllerApiService) FetchDiagnosticsActive(ctx context.Context) ([]FileTracker, *http.Response, error)

StatisticsControllerApiService Get File Trackers for active transfers

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []FileTracker

func (*StatisticsControllerApiService) FetchDiagnosticsActiveId

func (a *StatisticsControllerApiService) FetchDiagnosticsActiveId(ctx context.Context, progressId int64) (FileTracker, *http.Response, error)

StatisticsControllerApiService Get File Tracker for an active transfer

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param progressId Identifier for File Tracker

@return FileTracker

func (*StatisticsControllerApiService) FetchDiagnosticsActiveIdBuckets

func (a *StatisticsControllerApiService) FetchDiagnosticsActiveIdBuckets(ctx context.Context, progressId int64) ([]FileTrackerBucket, *http.Response, error)

StatisticsControllerApiService Get File Tracker Bytes per Second Buckets

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param progressId Identifier for File Tracker

@return []FileTrackerBucket

func (*StatisticsControllerApiService) FetchDiagnosticsComplete

func (a *StatisticsControllerApiService) FetchDiagnosticsComplete(ctx context.Context) ([]FileTracker, *http.Response, error)

StatisticsControllerApiService Get File Trackers for Completed Transfers.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []FileTracker

func (*StatisticsControllerApiService) FetchFileSizeDistribution

func (*StatisticsControllerApiService) FetchFileSizeDistributionActive

func (*StatisticsControllerApiService) FetchFileTransferRatesDistribution

func (*StatisticsControllerApiService) FetchFileTransferRatesDistributionActive

func (*StatisticsControllerApiService) FetchMigrationInfo

func (a *StatisticsControllerApiService) FetchMigrationInfo(ctx context.Context, migrationId string) (MigrationInfo, *http.Response, error)

StatisticsControllerApiService Get stats information for the given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return MigrationInfo

func (*StatisticsControllerApiService) FetchMigrationStats

func (a *StatisticsControllerApiService) FetchMigrationStats(ctx context.Context, migrationId string) ([]MigrationRecord, *http.Response, error)

StatisticsControllerApiService Get Stats over time for given migration ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param migrationId Unique identifier of the migration object

@return []MigrationRecord

func (*StatisticsControllerApiService) FetchMigrationSummary

StatisticsControllerApiService Get migrations summary

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return MigrationsSummary

func (*StatisticsControllerApiService) FetchThroughputInLastSecs

func (a *StatisticsControllerApiService) FetchThroughputInLastSecs(ctx context.Context, nSecs int32) (ThroughputBucket, *http.Response, error)

StatisticsControllerApiService Get throughput stats for all migrations during last N seconds

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param nSecs Number of seconds to check

@return ThroughputBucket

func (*StatisticsControllerApiService) FetchThroughputSummary

StatisticsControllerApiService Get throughput summary

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return ThroughputSummary

func (*StatisticsControllerApiService) FetchTotalRollingStats

StatisticsControllerApiService Get rolling stats over time for all migrations

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []AllMigrationsRollingStats

func (*StatisticsControllerApiService) FetchTotalStats

StatisticsControllerApiService Get cumulative total stats for all migrations

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return MigrationStats

func (*StatisticsControllerApiService) LastExcludedEvents

StatisticsControllerApiService Get most recent 1000 excluded events.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []EnrichedMigratorEvent

type TargetFileSystemControllerApiGetFileSystemOpts

type TargetFileSystemControllerApiGetFileSystemOpts struct {
	Verbose optional.Bool
}

type TargetFileSystemControllerApiListTargetFileSystemsOpts

type TargetFileSystemControllerApiListTargetFileSystemsOpts struct {
	Verbose optional.Bool
}

type TargetFileSystemControllerApiService

type TargetFileSystemControllerApiService service

func (*TargetFileSystemControllerApiService) ClearTargetFileSystems

func (a *TargetFileSystemControllerApiService) ClearTargetFileSystems(ctx context.Context) (*http.Response, error)

TargetFileSystemControllerApiService Delete all target file systems. NOTE this endpoint is currently for test purposes only.

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*TargetFileSystemControllerApiService) DeleteTargetFileSystem

func (a *TargetFileSystemControllerApiService) DeleteTargetFileSystem(ctx context.Context, targetId string) (*http.Response, error)

TargetFileSystemControllerApiService Delete target file system for given ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param targetId Unique identifier of the target file system Object

func (*TargetFileSystemControllerApiService) GetAvailableFileSystems

func (a *TargetFileSystemControllerApiService) GetAvailableFileSystems(ctx context.Context) ([]FsType, *http.Response, error)

TargetFileSystemControllerApiService List all available file systems

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []FsType

func (*TargetFileSystemControllerApiService) GetFileSystem

func (*TargetFileSystemControllerApiService) ListTargetFileSystems

type ThreadDumpDiagnostic

type ThreadDumpDiagnostic struct {
	TimeStamp          int64         `json:"timeStamp,omitempty"`
	Type_              string        `json:"type"`
	Threads            []ThreadInfo  `json:"threads,omitempty"`
	TimeToCollect      int64         `json:"timeToCollect,omitempty"`
	ThreadStateSummary *ThreadStates `json:"threadStateSummary,omitempty"`
}

type ThreadInfo

type ThreadInfo struct {
	ThreadName    string                 `json:"threadName,omitempty"`
	ThreadId      int64                  `json:"threadId,omitempty"`
	BlockedTime   int64                  `json:"blockedTime,omitempty"`
	BlockedCount  int64                  `json:"blockedCount,omitempty"`
	WaitedTime    int64                  `json:"waitedTime,omitempty"`
	WaitedCount   int64                  `json:"waitedCount,omitempty"`
	LockName      string                 `json:"lockName,omitempty"`
	LockOwnerId   int64                  `json:"lockOwnerId,omitempty"`
	LockOwnerName string                 `json:"lockOwnerName,omitempty"`
	InNative      bool                   `json:"inNative,omitempty"`
	Suspended     bool                   `json:"suspended,omitempty"`
	ThreadState   string                 `json:"threadState,omitempty"`
	StackTrace    []ThreadInfoStackTrace `json:"stackTrace,omitempty"`
}

type ThreadInfoStackTrace

type ThreadInfoStackTrace struct {
	MethodName     string `json:"methodName,omitempty"`
	FileName       string `json:"fileName,omitempty"`
	LineNumber     int32  `json:"lineNumber,omitempty"`
	DeclaringClass string `json:"declaringClass,omitempty"`
	NativeMethod   bool   `json:"nativeMethod,omitempty"`
}

type ThreadStates

type ThreadStates struct {
	NEW_THREADS           int32 `json:"NEW_THREADS,omitempty"`
	RUNNABLE_THREADS      int32 `json:"RUNNABLE_THREADS,omitempty"`
	BLOCKED_THREADS       int32 `json:"BLOCKED_THREADS,omitempty"`
	WAITING_THREADS       int32 `json:"WAITING_THREADS,omitempty"`
	TIMED_WAITING_THREADS int32 `json:"TIMED_WAITING_THREADS,omitempty"`
	TERMINATED_THREADS    int32 `json:"TERMINATED_THREADS,omitempty"`
	TOTAL_THREADS         int32 `json:"TOTAL_THREADS,omitempty"`
}

type ThreadsControllerApiService

type ThreadsControllerApiService service

func (*ThreadsControllerApiService) FetchThreadDump

func (a *ThreadsControllerApiService) FetchThreadDump(ctx context.Context) (string, *http.Response, error)

ThreadsControllerApiService Get Thread Dump

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return string

func (*ThreadsControllerApiService) FetchThreadStates

ThreadsControllerApiService Get Thread State Summary

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return ThreadStates

type ThroughputBucket

type ThroughputBucket struct {
	PeakBytes        int64            `json:"peakBytes,omitempty"`
	PeakFiles        int64            `json:"peakFiles,omitempty"`
	TotalBytes       int64            `json:"totalBytes,omitempty"`
	TotalFiles       int64            `json:"totalFiles,omitempty"`
	PeakFilesBySize  map[string]int64 `json:"peakFilesBySize,omitempty"`
	TotalFilesBySize map[string]int64 `json:"totalFilesBySize,omitempty"`
	ExcludedBytes    int64            `json:"excludedBytes,omitempty"`
	ExcludedFiles    int64            `json:"excludedFiles,omitempty"`
	ExcludedDirs     int64            `json:"excludedDirs,omitempty"`
	ExcludedEvents   int64            `json:"excludedEvents,omitempty"`
	RescannedFiles   int64            `json:"rescannedFiles,omitempty"`
	RescannedDirs    int64            `json:"rescannedDirs,omitempty"`
	ScannedFiles     int64            `json:"scannedFiles,omitempty"`
	ScannedDirs      int64            `json:"scannedDirs,omitempty"`
}

type ThroughputDiagnostic

type ThroughputDiagnostic struct {
	TimeStamp         int64  `json:"timeStamp,omitempty"`
	Type_             string `json:"type"`
	Period            int64  `json:"period,omitempty"`
	BytesMigrated     int64  `json:"bytesMigrated,omitempty"`
	FilesMigrated     int64  `json:"filesMigrated,omitempty"`
	PeakBytesMigrated int64  `json:"peakBytesMigrated,omitempty"`
	PeakFilesMigrated int64  `json:"peakFilesMigrated,omitempty"`
}

type ThroughputSummary

type ThroughputSummary struct {
	Last10Secs   *ThroughputBucket `json:"last10Secs,omitempty"`
	Last60Secs   *ThroughputBucket `json:"last60Secs,omitempty"`
	Last300Secs  *ThroughputBucket `json:"last300Secs,omitempty"`
	Last1800Secs *ThroughputBucket `json:"last1800Secs,omitempty"`
}

type TimeLicense

type TimeLicense struct {
	Warning            string `json:"warning,omitempty"`
	LicenseType        string `json:"licenseType,omitempty"`
	InvalidReason      string `json:"invalidReason,omitempty"`
	IsValid            bool   `json:"isValid,omitempty"`
	LicenseStatus      string `json:"licenseStatus,omitempty"`
	Type_              string `json:"type"`
	ExpiredReason      string `json:"expiredReason,omitempty"`
	LastTimeChecked    int64  `json:"lastTimeChecked,omitempty"`
	ExpireTime         int64  `json:"expireTime,omitempty"`
	GracePeriodDays    int64  `json:"gracePeriodDays,omitempty"`
	GracePeriodEndTime int64  `json:"gracePeriodEndTime,omitempty"`
}

type TrialLicense

type TrialLicense struct {
	Warning       string `json:"warning,omitempty"`
	LicenseType   string `json:"licenseType,omitempty"`
	InvalidReason string `json:"invalidReason,omitempty"`
	IsValid       bool   `json:"isValid,omitempty"`
	LicenseStatus string `json:"licenseStatus,omitempty"`
	Type_         string `json:"type"`
	ExpiredReason string `json:"expiredReason,omitempty"`
	TrialPeriod   int64  `json:"trialPeriod,omitempty"`
	InstallTime   int64  `json:"installTime,omitempty"`
	ExpireTime    int64  `json:"expireTime,omitempty"`
	Trial         bool   `json:"trial,omitempty"`
}

type Verification

type Verification struct {
	Id                                   string              `json:"id,omitempty"`
	MigrationId                          string              `json:"migrationId,omitempty"`
	MigrationInternalId                  string              `json:"migrationInternalId,omitempty"`
	Status                               *VerificationStatus `json:"status,omitempty"`
	CreatedTimestamp                     int64               `json:"createdTimestamp,omitempty"`
	StartedTimestamp                     int64               `json:"startedTimestamp,omitempty"`
	FinishedTimestamp                    int64               `json:"finishedTimestamp,omitempty"`
	CreatedAt                            time.Time           `json:"createdAt,omitempty"`
	StartedAt                            time.Time           `json:"startedAt,omitempty"`
	FinishedAt                           time.Time           `json:"finishedAt,omitempty"`
	Paths                                []string            `json:"paths,omitempty"`
	IgnoreAfterTimestamp                 int64               `json:"ignoreAfterTimestamp,omitempty"`
	OriginalPaths                        []string            `json:"originalPaths,omitempty"`
	VerificationDepth                    int32               `json:"verificationDepth,omitempty"`
	FilesOnSource                        int64               `json:"filesOnSource,omitempty"`
	DirectoriesOnSource                  int64               `json:"directoriesOnSource,omitempty"`
	BytesOnSource                        int64               `json:"bytesOnSource,omitempty"`
	FilesExcluded                        int64               `json:"filesExcluded,omitempty"`
	FilesExcludedExistsOnTarget          int64               `json:"filesExcludedExistsOnTarget,omitempty"`
	FilesExcludedNotExistsOnTarget       int64               `json:"filesExcludedNotExistsOnTarget,omitempty"`
	DataExcluded                         int64               `json:"dataExcluded,omitempty"`
	BytesExcluded                        int64               `json:"bytesExcluded,omitempty"`
	BytesExcludedExistsOnTarget          int64               `json:"bytesExcludedExistsOnTarget,omitempty"`
	BytesExcludedNotExistsOnTarget       int64               `json:"bytesExcludedNotExistsOnTarget,omitempty"`
	DirectoriesExcluded                  int64               `json:"directoriesExcluded,omitempty"`
	DirectoriesExcludedExistsOnTarget    int64               `json:"directoriesExcludedExistsOnTarget,omitempty"`
	DirectoriesExcludedNotExistsOnTarget int64               `json:"directoriesExcludedNotExistsOnTarget,omitempty"`
	FilesOnTarget                        int64               `json:"filesOnTarget,omitempty"`
	DirectoriesOnTarget                  int64               `json:"directoriesOnTarget,omitempty"`
	BytesOnTarget                        int64               `json:"bytesOnTarget,omitempty"`
	FilesMissingOnTarget                 int64               `json:"filesMissingOnTarget,omitempty"`
	DirectoriesMissingOnTarget           int64               `json:"directoriesMissingOnTarget,omitempty"`
	FilesMissingOnSource                 int64               `json:"filesMissingOnSource,omitempty"`
	DirectoriesMissingOnSource           int64               `json:"directoriesMissingOnSource,omitempty"`
	FileSizeMismatches                   int64               `json:"fileSizeMismatches,omitempty"`
	TotalDiscrepancies                   int64               `json:"totalDiscrepancies,omitempty"`
}

type VerificationConfiguration

type VerificationConfiguration struct {
	MigrationId          string   `json:"migrationId,omitempty"`
	IgnoreAfterTimestamp int64    `json:"ignoreAfterTimestamp,omitempty"`
	OriginalPaths        []string `json:"originalPaths,omitempty"`
	VerificationDepth    int32    `json:"verificationDepth,omitempty"`
}

type VerificationControllerApiFetchAllFilteredVerificationsOpts

type VerificationControllerApiFetchAllFilteredVerificationsOpts struct {
	MigrationIds optional.Interface
	States       optional.Interface
}

type VerificationControllerApiFetchAllVerificationsOpts

type VerificationControllerApiFetchAllVerificationsOpts struct {
	MigrationId optional.String
}

type VerificationControllerApiGetVerificationReportOpts

type VerificationControllerApiGetVerificationReportOpts struct {
	ReportId optional.String
}

type VerificationControllerApiService

type VerificationControllerApiService service

func (*VerificationControllerApiService) CancelVerification

func (a *VerificationControllerApiService) CancelVerification(ctx context.Context, verificationId string) (*http.Response, error)

VerificationControllerApiService Cancel verification with given ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param verificationId Unique identifier of the verification Object

func (*VerificationControllerApiService) DeleteVerification

func (a *VerificationControllerApiService) DeleteVerification(ctx context.Context, verificationId string) (*http.Response, error)

VerificationControllerApiService Delete verification with given ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param verificationId Unique identifier of the verification Object

func (*VerificationControllerApiService) FetchAllFilteredVerifications

func (*VerificationControllerApiService) FetchAllVerifications

func (*VerificationControllerApiService) GetVerification

func (a *VerificationControllerApiService) GetVerification(ctx context.Context, verificationId string) (Verification, *http.Response, error)

VerificationControllerApiService Get verification for given ID

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param verificationId Unique identifier of the verification Object

@return Verification

func (*VerificationControllerApiService) GetVerificationReport

func (a *VerificationControllerApiService) GetVerificationReport(ctx context.Context, verificationId string, localVarOptionals *VerificationControllerApiGetVerificationReportOpts) (*os.File, *http.Response, error)

func (*VerificationControllerApiService) GetVerificationReportsList

func (a *VerificationControllerApiService) GetVerificationReportsList(ctx context.Context, verificationId string) ([]VerificationReportFileMetadata, *http.Response, error)

VerificationControllerApiService Get the metadata for the available reports for the given verification

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param verificationId Unique identifier of the verification Object

@return []VerificationReportFileMetadata

func (*VerificationControllerApiService) TriggerVerification

type VerificationControllerApiTriggerVerificationOpts

type VerificationControllerApiTriggerVerificationOpts struct {
	Body optional.Interface
}

type VerificationReportFileDescriptor

type VerificationReportFileDescriptor struct {
	Name       string                  `json:"name,omitempty"`
	Type_      *VerificationReportType `json:"type,omitempty"`
	FileSuffix string                  `json:"fileSuffix,omitempty"`
}

type VerificationReportFileMetadata

type VerificationReportFileMetadata struct {
	Descriptor *VerificationReportFileDescriptor `json:"descriptor,omitempty"`
	Size       int64                             `json:"size,omitempty"`
	Created    int64                             `json:"created,omitempty"`
	Checksum   int64                             `json:"checksum,omitempty"`
}

type VerificationReportType

type VerificationReportType string
const (
	FULL_VerificationReportType               VerificationReportType = "FULL"
	DISCREPANCIES_CSV_VerificationReportType  VerificationReportType = "DISCREPANCIES_CSV"
	DISCREPANCIES_JSON_VerificationReportType VerificationReportType = "DISCREPANCIES_JSON"
	SUMMARY_VerificationReportType            VerificationReportType = "SUMMARY"
	ALL_VerificationReportType                VerificationReportType = "ALL"
)

List of VerificationReportType

type VerificationStatus

type VerificationStatus string
const (
	QUEUED_VerificationStatus      VerificationStatus = "QUEUED"
	IN_PROGRESS_VerificationStatus VerificationStatus = "IN_PROGRESS"
	COMPLETE_VerificationStatus    VerificationStatus = "COMPLETE"
	CANCELLED_VerificationStatus   VerificationStatus = "CANCELLED"
)

List of VerificationStatus

Source Files

Jump to

Keyboard shortcuts

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