Index: generated/googleapis/lib/storagetransfer/v1.dart |
diff --git a/generated/googleapis/lib/storagetransfer/v1.dart b/generated/googleapis/lib/storagetransfer/v1.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..eb1f261014be3e55e209e431ae663425d59a8eb5 |
--- /dev/null |
+++ b/generated/googleapis/lib/storagetransfer/v1.dart |
@@ -0,0 +1,1929 @@ |
+// This is a generated file (see the discoveryapis_generator project). |
+ |
+library googleapis.storagetransfer.v1; |
+ |
+import 'dart:core' as core; |
+import 'dart:async' as async; |
+import 'dart:convert' as convert; |
+ |
+import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; |
+import 'package:http/http.dart' as http; |
+ |
+export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show |
+ ApiRequestError, DetailedApiRequestError; |
+ |
+const core.String USER_AGENT = 'dart-api-client storagetransfer/v1'; |
+ |
+/** |
+ * Transfers data from external data sources to a Google Cloud Storage bucket or |
+ * between Google Cloud Storage buckets. |
+ */ |
+class StoragetransferApi { |
+ /** View and manage your data across Google Cloud Platform services */ |
+ static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform"; |
+ |
+ |
+ final commons.ApiRequester _requester; |
+ |
+ GoogleServiceAccountsResourceApi get googleServiceAccounts => new GoogleServiceAccountsResourceApi(_requester); |
+ TransferJobsResourceApi get transferJobs => new TransferJobsResourceApi(_requester); |
+ TransferOperationsResourceApi get transferOperations => new TransferOperationsResourceApi(_requester); |
+ V1ResourceApi get v1 => new V1ResourceApi(_requester); |
+ |
+ StoragetransferApi(http.Client client, {core.String rootUrl: "https://storagetransfer.googleapis.com/", core.String servicePath: ""}) : |
+ _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT); |
+} |
+ |
+ |
+class GoogleServiceAccountsResourceApi { |
+ final commons.ApiRequester _requester; |
+ |
+ GoogleServiceAccountsResourceApi(commons.ApiRequester client) : |
+ _requester = client; |
+ |
+ /** |
+ * Returns the Google service account that is used by Storage Transfer Service |
+ * to access buckets in the project where transfers run or in other projects. |
+ * Each Google service account is associated with one Google Developers |
+ * Console project. Users should add this service account to the Google Cloud |
+ * Storage bucket ACLs to grant access to Storage Transfer Service. This |
+ * service account is created and owned by Storage Transfer Service and can |
+ * only be used by Storage Transfer Service. |
+ * |
+ * Request parameters: |
+ * |
+ * [projectId] - The ID of the Google Developers Console project that the |
+ * Google service account is associated with. Required. |
+ * |
+ * Completes with a [GoogleServiceAccount]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<GoogleServiceAccount> get(core.String projectId) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (projectId == null) { |
+ throw new core.ArgumentError("Parameter projectId is required."); |
+ } |
+ |
+ _url = 'v1/googleServiceAccounts/' + commons.Escaper.ecapeVariable('$projectId'); |
+ |
+ var _response = _requester.request(_url, |
+ "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new GoogleServiceAccount.fromJson(data)); |
+ } |
+ |
+} |
+ |
+ |
+class TransferJobsResourceApi { |
+ final commons.ApiRequester _requester; |
+ |
+ TransferJobsResourceApi(commons.ApiRequester client) : |
+ _requester = client; |
+ |
+ /** |
+ * Creates a transfer job that runs periodically. |
+ * |
+ * [request] - The metadata request object. |
+ * |
+ * Request parameters: |
+ * |
+ * Completes with a [TransferJob]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<TransferJob> create(TransferJob request) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (request != null) { |
+ _body = convert.JSON.encode((request).toJson()); |
+ } |
+ |
+ _url = 'v1/transferJobs'; |
+ |
+ var _response = _requester.request(_url, |
+ "POST", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new TransferJob.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Gets a transfer job. |
+ * |
+ * Request parameters: |
+ * |
+ * [jobName] - The job to get. Required. |
+ * Value must have pattern "^transferJobs/.*$". |
+ * |
+ * [projectId] - The ID of the Google Developers Console project that owns the |
+ * job. Required. |
+ * |
+ * Completes with a [TransferJob]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<TransferJob> get(core.String jobName, {core.String projectId}) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (jobName == null) { |
+ throw new core.ArgumentError("Parameter jobName is required."); |
+ } |
+ if (projectId != null) { |
+ _queryParams["projectId"] = [projectId]; |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$jobName'); |
+ |
+ var _response = _requester.request(_url, |
+ "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new TransferJob.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Lists transfer jobs. |
+ * |
+ * Request parameters: |
+ * |
+ * [filter] - A list of query parameters specified as JSON text in the form of |
+ * {"`project_id`":"my_project_id", "`job_names`":["jobid1","jobid2",...], |
+ * "`job_statuses`":["status1","status2",...]}. Since `job_names` and |
+ * `job_statuses` support multiple values, their values must be specified with |
+ * array notation. `project_id` is required. `job_names` and `job_statuses` |
+ * are optional. The valid values for `job_statuses` are case-insensitive: |
+ * `ENABLED`, `DISABLED`, and `DELETED`. |
+ * |
+ * [pageSize] - The list page size. The max allowed value is 256. |
+ * |
+ * [pageToken] - The list page token. |
+ * |
+ * Completes with a [ListTransferJobsResponse]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<ListTransferJobsResponse> list({core.String filter, core.int pageSize, core.String pageToken}) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (filter != null) { |
+ _queryParams["filter"] = [filter]; |
+ } |
+ if (pageSize != null) { |
+ _queryParams["pageSize"] = ["${pageSize}"]; |
+ } |
+ if (pageToken != null) { |
+ _queryParams["pageToken"] = [pageToken]; |
+ } |
+ |
+ _url = 'v1/transferJobs'; |
+ |
+ var _response = _requester.request(_url, |
+ "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new ListTransferJobsResponse.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Updates a transfer job. Updating a job's transfer spec does not affect |
+ * transfer operations that are running already. Updating the scheduling of a |
+ * job is not allowed. |
+ * |
+ * [request] - The metadata request object. |
+ * |
+ * Request parameters: |
+ * |
+ * [jobName] - The name of job to update. Required. |
+ * Value must have pattern "^transferJobs/.*$". |
+ * |
+ * Completes with a [TransferJob]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<TransferJob> patch(UpdateTransferJobRequest request, core.String jobName) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (request != null) { |
+ _body = convert.JSON.encode((request).toJson()); |
+ } |
+ if (jobName == null) { |
+ throw new core.ArgumentError("Parameter jobName is required."); |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$jobName'); |
+ |
+ var _response = _requester.request(_url, |
+ "PATCH", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new TransferJob.fromJson(data)); |
+ } |
+ |
+} |
+ |
+ |
+class TransferOperationsResourceApi { |
+ final commons.ApiRequester _requester; |
+ |
+ TransferOperationsResourceApi(commons.ApiRequester client) : |
+ _requester = client; |
+ |
+ /** |
+ * Cancels a transfer. Use the get method to check whether the cancellation |
+ * succeeded or whether the operation completed despite cancellation. |
+ * |
+ * Request parameters: |
+ * |
+ * [name] - The name of the operation resource to be cancelled. |
+ * Value must have pattern "^transferOperations/.*$". |
+ * |
+ * Completes with a [Empty]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<Empty> cancel(core.String name) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (name == null) { |
+ throw new core.ArgumentError("Parameter name is required."); |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':cancel'; |
+ |
+ var _response = _requester.request(_url, |
+ "POST", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new Empty.fromJson(data)); |
+ } |
+ |
+ /** |
+ * This method is not supported and the server returns `UNIMPLEMENTED`. |
+ * |
+ * Request parameters: |
+ * |
+ * [name] - The name of the operation resource to be deleted. |
+ * Value must have pattern "^transferOperations/.*$". |
+ * |
+ * Completes with a [Empty]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<Empty> delete(core.String name) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (name == null) { |
+ throw new core.ArgumentError("Parameter name is required."); |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
+ |
+ var _response = _requester.request(_url, |
+ "DELETE", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new Empty.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Gets the latest state of a long-running operation. Clients can use this |
+ * method to poll the operation result at intervals as recommended by the API |
+ * service. |
+ * |
+ * Request parameters: |
+ * |
+ * [name] - The name of the operation resource. |
+ * Value must have pattern "^transferOperations/.*$". |
+ * |
+ * Completes with a [Operation]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<Operation> get(core.String name) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (name == null) { |
+ throw new core.ArgumentError("Parameter name is required."); |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
+ |
+ var _response = _requester.request(_url, |
+ "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new Operation.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Lists operations that match the specified filter in the request. If the |
+ * server doesn't support this method, it returns `UNIMPLEMENTED`. NOTE: the |
+ * `name` binding below allows API services to override the binding to use |
+ * different resource name schemes, such as `users / * /operations`. |
+ * |
+ * Request parameters: |
+ * |
+ * [name] - The value `transferOperations`. |
+ * Value must have pattern "^transferOperations$". |
+ * |
+ * [filter] - The standard list filter. |
+ * |
+ * [pageSize] - The standard list page size. |
+ * |
+ * [pageToken] - The standard list page token. |
+ * |
+ * Completes with a [ListOperationsResponse]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<ListOperationsResponse> list(core.String name, {core.String filter, core.int pageSize, core.String pageToken}) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (name == null) { |
+ throw new core.ArgumentError("Parameter name is required."); |
+ } |
+ if (filter != null) { |
+ _queryParams["filter"] = [filter]; |
+ } |
+ if (pageSize != null) { |
+ _queryParams["pageSize"] = ["${pageSize}"]; |
+ } |
+ if (pageToken != null) { |
+ _queryParams["pageToken"] = [pageToken]; |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
+ |
+ var _response = _requester.request(_url, |
+ "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new ListOperationsResponse.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Pauses a transfer operation. |
+ * |
+ * [request] - The metadata request object. |
+ * |
+ * Request parameters: |
+ * |
+ * [name] - The name of the transfer operation. Required. |
+ * Value must have pattern "^transferOperations/.*$". |
+ * |
+ * Completes with a [Empty]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<Empty> pause(PauseTransferOperationRequest request, core.String name) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (request != null) { |
+ _body = convert.JSON.encode((request).toJson()); |
+ } |
+ if (name == null) { |
+ throw new core.ArgumentError("Parameter name is required."); |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':pause'; |
+ |
+ var _response = _requester.request(_url, |
+ "POST", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new Empty.fromJson(data)); |
+ } |
+ |
+ /** |
+ * Resumes a transfer operation that is paused. |
+ * |
+ * [request] - The metadata request object. |
+ * |
+ * Request parameters: |
+ * |
+ * [name] - The name of the transfer operation. Required. |
+ * Value must have pattern "^transferOperations/.*$". |
+ * |
+ * Completes with a [Empty]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<Empty> resume(ResumeTransferOperationRequest request, core.String name) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (request != null) { |
+ _body = convert.JSON.encode((request).toJson()); |
+ } |
+ if (name == null) { |
+ throw new core.ArgumentError("Parameter name is required."); |
+ } |
+ |
+ _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':resume'; |
+ |
+ var _response = _requester.request(_url, |
+ "POST", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new Empty.fromJson(data)); |
+ } |
+ |
+} |
+ |
+ |
+class V1ResourceApi { |
+ final commons.ApiRequester _requester; |
+ |
+ V1ResourceApi(commons.ApiRequester client) : |
+ _requester = client; |
+ |
+ /** |
+ * Returns the Google service account that is used by Storage Transfer Service |
+ * to access buckets in the project where transfers run or in other projects. |
+ * Each Google service account is associated with one Google Developers |
+ * Console project. Users should add this service account to the Google Cloud |
+ * Storage bucket ACLs to grant access to Storage Transfer Service. This |
+ * service account is created and owned by Storage Transfer Service and can |
+ * only be used by Storage Transfer Service. |
+ * |
+ * Request parameters: |
+ * |
+ * [projectId] - The ID of the Google Developers Console project that the |
+ * Google service account is associated with. Required. |
+ * |
+ * Completes with a [GoogleServiceAccount]. |
+ * |
+ * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
+ * error. |
+ * |
+ * If the used [http.Client] completes with an error when making a REST call, |
+ * this method will complete with the same error. |
+ */ |
+ async.Future<GoogleServiceAccount> getGoogleServiceAccount({core.String projectId}) { |
+ var _url = null; |
+ var _queryParams = new core.Map(); |
+ var _uploadMedia = null; |
+ var _uploadOptions = null; |
+ var _downloadOptions = commons.DownloadOptions.Metadata; |
+ var _body = null; |
+ |
+ if (projectId != null) { |
+ _queryParams["projectId"] = [projectId]; |
+ } |
+ |
+ _url = 'v1:getGoogleServiceAccount'; |
+ |
+ var _response = _requester.request(_url, |
+ "GET", |
+ body: _body, |
+ queryParams: _queryParams, |
+ uploadOptions: _uploadOptions, |
+ uploadMedia: _uploadMedia, |
+ downloadOptions: _downloadOptions); |
+ return _response.then((data) => new GoogleServiceAccount.fromJson(data)); |
+ } |
+ |
+} |
+ |
+ |
+ |
+/** |
+ * AWS access key (see [AWS Security |
+ * Credentials](http://docs.aws.amazon.com/general/latest/gr/aws-security-credentials.html)). |
+ */ |
+class AwsAccessKey { |
+ /** AWS access key ID. Required. */ |
+ core.String accessKeyId; |
+ /** |
+ * AWS secret access key. This field is not returned in RPC responses. |
+ * Required. |
+ */ |
+ core.String secretAccessKey; |
+ |
+ AwsAccessKey(); |
+ |
+ AwsAccessKey.fromJson(core.Map _json) { |
+ if (_json.containsKey("accessKeyId")) { |
+ accessKeyId = _json["accessKeyId"]; |
+ } |
+ if (_json.containsKey("secretAccessKey")) { |
+ secretAccessKey = _json["secretAccessKey"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (accessKeyId != null) { |
+ _json["accessKeyId"] = accessKeyId; |
+ } |
+ if (secretAccessKey != null) { |
+ _json["secretAccessKey"] = secretAccessKey; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * An AwsS3Data can be a data source, but not a data sink. In an AwsS3Data, an |
+ * object's name is the S3 object's key name. |
+ */ |
+class AwsS3Data { |
+ /** |
+ * AWS access key used to sign the API requests to the AWS S3 bucket. |
+ * Permissions on the bucket must be granted to the access ID of the AWS |
+ * access key. Required. |
+ */ |
+ AwsAccessKey awsAccessKey; |
+ /** |
+ * S3 Bucket name (see [Creating a |
+ * bucket](http://docs.aws.amazon.com/AmazonS3/latest/dev/create-bucket-get-location-example.html)). |
+ * Required. |
+ */ |
+ core.String bucketName; |
+ |
+ AwsS3Data(); |
+ |
+ AwsS3Data.fromJson(core.Map _json) { |
+ if (_json.containsKey("awsAccessKey")) { |
+ awsAccessKey = new AwsAccessKey.fromJson(_json["awsAccessKey"]); |
+ } |
+ if (_json.containsKey("bucketName")) { |
+ bucketName = _json["bucketName"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (awsAccessKey != null) { |
+ _json["awsAccessKey"] = (awsAccessKey).toJson(); |
+ } |
+ if (bucketName != null) { |
+ _json["bucketName"] = bucketName; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * Represents a whole calendar date, e.g. date of birth. The time of day and |
+ * time zone are either specified elsewhere or are not significant. The date is |
+ * relative to the Proleptic Gregorian Calendar. The day may be 0 to represent a |
+ * year and month where the day is not significant, e.g. credit card expiration |
+ * date. The year may be 0 to represent a month and day independent of year, |
+ * e.g. anniversary date. Related types are |
+ * [google.type.TimeOfDay][google.type.TimeOfDay] and |
+ * `google.protobuf.Timestamp`. |
+ */ |
+class Date { |
+ /** |
+ * Day of month. Must be from 1 to 31 and valid for the year and month, or 0 |
+ * if specifying a year/month where the day is not sigificant. |
+ */ |
+ core.int day; |
+ /** Month of year of date. Must be from 1 to 12. */ |
+ core.int month; |
+ /** |
+ * Year of date. Must be from 1 to 9,999, or 0 if specifying a date without a |
+ * year. |
+ */ |
+ core.int year; |
+ |
+ Date(); |
+ |
+ Date.fromJson(core.Map _json) { |
+ if (_json.containsKey("day")) { |
+ day = _json["day"]; |
+ } |
+ if (_json.containsKey("month")) { |
+ month = _json["month"]; |
+ } |
+ if (_json.containsKey("year")) { |
+ year = _json["year"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (day != null) { |
+ _json["day"] = day; |
+ } |
+ if (month != null) { |
+ _json["month"] = month; |
+ } |
+ if (year != null) { |
+ _json["year"] = year; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * A generic empty message that you can re-use to avoid defining duplicated |
+ * empty messages in your APIs. A typical example is to use it as the request or |
+ * the response type of an API method. For instance: service Foo { rpc |
+ * Bar(google.protobuf.Empty) returns (google.protobuf.Empty); } The JSON |
+ * representation for `Empty` is empty JSON object `{}`. |
+ */ |
+class Empty { |
+ |
+ Empty(); |
+ |
+ Empty.fromJson(core.Map _json) { |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ return _json; |
+ } |
+} |
+ |
+/** An entry describing an error that has occurred. */ |
+class ErrorLogEntry { |
+ /** A list of messages that carry the error details. */ |
+ core.List<core.String> errorDetails; |
+ /** |
+ * A URL that refers to the target (a data source, a data sink, or an object) |
+ * with which the error is associated. Required. |
+ */ |
+ core.String url; |
+ |
+ ErrorLogEntry(); |
+ |
+ ErrorLogEntry.fromJson(core.Map _json) { |
+ if (_json.containsKey("errorDetails")) { |
+ errorDetails = _json["errorDetails"]; |
+ } |
+ if (_json.containsKey("url")) { |
+ url = _json["url"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (errorDetails != null) { |
+ _json["errorDetails"] = errorDetails; |
+ } |
+ if (url != null) { |
+ _json["url"] = url; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * A summary of errors by error code, plus a count and sample error log entries. |
+ */ |
+class ErrorSummary { |
+ /** |
+ * Required. |
+ * Possible string values are: |
+ * - "OK" : A OK. |
+ * - "CANCELLED" : A CANCELLED. |
+ * - "UNKNOWN" : A UNKNOWN. |
+ * - "INVALID_ARGUMENT" : A INVALID_ARGUMENT. |
+ * - "DEADLINE_EXCEEDED" : A DEADLINE_EXCEEDED. |
+ * - "NOT_FOUND" : A NOT_FOUND. |
+ * - "ALREADY_EXISTS" : A ALREADY_EXISTS. |
+ * - "PERMISSION_DENIED" : A PERMISSION_DENIED. |
+ * - "UNAUTHENTICATED" : A UNAUTHENTICATED. |
+ * - "RESOURCE_EXHAUSTED" : A RESOURCE_EXHAUSTED. |
+ * - "FAILED_PRECONDITION" : A FAILED_PRECONDITION. |
+ * - "ABORTED" : A ABORTED. |
+ * - "OUT_OF_RANGE" : A OUT_OF_RANGE. |
+ * - "UNIMPLEMENTED" : A UNIMPLEMENTED. |
+ * - "INTERNAL" : A INTERNAL. |
+ * - "UNAVAILABLE" : A UNAVAILABLE. |
+ * - "DATA_LOSS" : A DATA_LOSS. |
+ */ |
+ core.String errorCode; |
+ /** Count of this type of error. Required. */ |
+ core.String errorCount; |
+ /** Error samples. */ |
+ core.List<ErrorLogEntry> errorLogEntries; |
+ |
+ ErrorSummary(); |
+ |
+ ErrorSummary.fromJson(core.Map _json) { |
+ if (_json.containsKey("errorCode")) { |
+ errorCode = _json["errorCode"]; |
+ } |
+ if (_json.containsKey("errorCount")) { |
+ errorCount = _json["errorCount"]; |
+ } |
+ if (_json.containsKey("errorLogEntries")) { |
+ errorLogEntries = _json["errorLogEntries"].map((value) => new ErrorLogEntry.fromJson(value)).toList(); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (errorCode != null) { |
+ _json["errorCode"] = errorCode; |
+ } |
+ if (errorCount != null) { |
+ _json["errorCount"] = errorCount; |
+ } |
+ if (errorLogEntries != null) { |
+ _json["errorLogEntries"] = errorLogEntries.map((value) => (value).toJson()).toList(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * In a GcsData, an object's name is the Google Cloud Storage object's name and |
+ * its `lastModificationTime` refers to the object's updated time, which changes |
+ * when the content or the metadata of the object is updated. |
+ */ |
+class GcsData { |
+ /** |
+ * Google Cloud Storage bucket name (see [Bucket Name |
+ * Requirements](https://cloud.google.com/storage/docs/bucket-naming#requirements)). |
+ * Required. |
+ */ |
+ core.String bucketName; |
+ |
+ GcsData(); |
+ |
+ GcsData.fromJson(core.Map _json) { |
+ if (_json.containsKey("bucketName")) { |
+ bucketName = _json["bucketName"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (bucketName != null) { |
+ _json["bucketName"] = bucketName; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** Google service account */ |
+class GoogleServiceAccount { |
+ /** Required. */ |
+ core.String accountEmail; |
+ |
+ GoogleServiceAccount(); |
+ |
+ GoogleServiceAccount.fromJson(core.Map _json) { |
+ if (_json.containsKey("accountEmail")) { |
+ accountEmail = _json["accountEmail"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (accountEmail != null) { |
+ _json["accountEmail"] = accountEmail; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * An HttpData specifies a list of objects on the web to be transferred over |
+ * HTTP. The information of the objects to be transferred is contained in a file |
+ * referenced by a URL. The first line in the file must be "TsvHttpData-1.0", |
+ * which specifies the format of the file. Subsequent lines specify the |
+ * information of the list of objects, one object per list entry. Each entry has |
+ * the following tab-delimited fields: * HTTP URL * Length * MD5 - This field is |
+ * a base64-encoded MD5 hash of the object An HTTP URL that points to the object |
+ * to be transferred. It must be a valid URL with URL scheme HTTP or HTTPS. When |
+ * an object with URL `http(s)://hostname:port/` is transferred to the data |
+ * sink, the name of the object at the data sink is `/`. Length and MD5 provide |
+ * the size and the base64-encoded MD5 hash of the object. If Length does not |
+ * match the actual length of the object fetched, the object will not be |
+ * transferred. If MD5 does not match the MD5 computed from the transferred |
+ * bytes, the object transfer will fail. `lastModificationTime` is not available |
+ * in HttpData objects. The objects that the URL list points to must allow |
+ * public access. Storage Transfer Service obeys `robots.txt` rules and requires |
+ * the HTTP server to support Range requests and to return a Content-Length |
+ * header in each response. |
+ */ |
+class HttpData { |
+ /** |
+ * The URL that points to the file that stores the object list entries. This |
+ * file must allow public access. Currently, only URLs with HTTP and HTTPS |
+ * schemes are supported. Required. |
+ */ |
+ core.String listUrl; |
+ |
+ HttpData(); |
+ |
+ HttpData.fromJson(core.Map _json) { |
+ if (_json.containsKey("listUrl")) { |
+ listUrl = _json["listUrl"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (listUrl != null) { |
+ _json["listUrl"] = listUrl; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * The response message for |
+ * [Operations.ListOperations][google.longrunning.Operations.ListOperations]. |
+ */ |
+class ListOperationsResponse { |
+ /** The standard List next-page token. */ |
+ core.String nextPageToken; |
+ /** A list of operations that matches the specified filter in the request. */ |
+ core.List<Operation> operations; |
+ |
+ ListOperationsResponse(); |
+ |
+ ListOperationsResponse.fromJson(core.Map _json) { |
+ if (_json.containsKey("nextPageToken")) { |
+ nextPageToken = _json["nextPageToken"]; |
+ } |
+ if (_json.containsKey("operations")) { |
+ operations = _json["operations"].map((value) => new Operation.fromJson(value)).toList(); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (nextPageToken != null) { |
+ _json["nextPageToken"] = nextPageToken; |
+ } |
+ if (operations != null) { |
+ _json["operations"] = operations.map((value) => (value).toJson()).toList(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** Response from ListTransferJobs. */ |
+class ListTransferJobsResponse { |
+ /** The list next page token. */ |
+ core.String nextPageToken; |
+ /** A list of transfer jobs. */ |
+ core.List<TransferJob> transferJobs; |
+ |
+ ListTransferJobsResponse(); |
+ |
+ ListTransferJobsResponse.fromJson(core.Map _json) { |
+ if (_json.containsKey("nextPageToken")) { |
+ nextPageToken = _json["nextPageToken"]; |
+ } |
+ if (_json.containsKey("transferJobs")) { |
+ transferJobs = _json["transferJobs"].map((value) => new TransferJob.fromJson(value)).toList(); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (nextPageToken != null) { |
+ _json["nextPageToken"] = nextPageToken; |
+ } |
+ if (transferJobs != null) { |
+ _json["transferJobs"] = transferJobs.map((value) => (value).toJson()).toList(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** Conditions that determine which objects will be transferred. */ |
+class ObjectConditions { |
+ /** |
+ * `excludePrefixes` must follow the constraints described for |
+ * `includePrefixes`. The max size of `excludePrefixes` is 20. |
+ */ |
+ core.List<core.String> excludePrefixes; |
+ /** |
+ * If `includePrefixes` is specified, objects that satisfy the object |
+ * conditions must have names that start with one of the `includePrefixes` and |
+ * that do not start with any of the `excludePrefixes`. If `includePrefixes` |
+ * is not specified, all objects except those that have names starting with |
+ * one of the `excludePrefixes` must satisfy the object conditions. |
+ * Requirements: * Each include-prefix and exclude-prefix can contain any |
+ * sequence of Unicode characters, of max length 1024 bytes when UTF8-encoded, |
+ * and must not contain Carriage Return or Line Feed characters. Wildcard |
+ * matching and regular expression matching are not supported. * None of the |
+ * include-prefix or the exclude-prefix can be empty, if specified. * Each |
+ * include-prefix must include a distinct portion of the object namespace, |
+ * i.e. no include-prefix may be a prefix of another include-prefix. * Each |
+ * exclude-prefix must exclude a distinct portion of the bucket, i.e., no |
+ * exclude-prefix may be a prefix of another exclude-prefix`. * If |
+ * `includePrefixes` is specified, then each exclude-prefix must exclude paths |
+ * that were explicitly included by `includePrefixes`. * The max size of |
+ * `includePrefixes` is 20. |
+ */ |
+ core.List<core.String> includePrefixes; |
+ /** |
+ * `maxTimeElapsedSinceLastModification` is the complement to |
+ * `minTimeElapsedSinceLastModification`. |
+ */ |
+ core.String maxTimeElapsedSinceLastModification; |
+ /** |
+ * If unspecified, `minTimeElapsedSinceLastModification` takes a zero value |
+ * and `maxTimeElapsedSinceLastModification` takes the maximum possible value |
+ * of Duration. Objects that satisfy the object conditions must either have a |
+ * `lastModificationTime` greater or equal to `NOW` - |
+ * `maxTimeElapsedSinceLastModification` and less than `NOW` - |
+ * `minTimeElapsedSinceLastModification`, or not have a |
+ * `lastModificationTime`. |
+ */ |
+ core.String minTimeElapsedSinceLastModification; |
+ |
+ ObjectConditions(); |
+ |
+ ObjectConditions.fromJson(core.Map _json) { |
+ if (_json.containsKey("excludePrefixes")) { |
+ excludePrefixes = _json["excludePrefixes"]; |
+ } |
+ if (_json.containsKey("includePrefixes")) { |
+ includePrefixes = _json["includePrefixes"]; |
+ } |
+ if (_json.containsKey("maxTimeElapsedSinceLastModification")) { |
+ maxTimeElapsedSinceLastModification = _json["maxTimeElapsedSinceLastModification"]; |
+ } |
+ if (_json.containsKey("minTimeElapsedSinceLastModification")) { |
+ minTimeElapsedSinceLastModification = _json["minTimeElapsedSinceLastModification"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (excludePrefixes != null) { |
+ _json["excludePrefixes"] = excludePrefixes; |
+ } |
+ if (includePrefixes != null) { |
+ _json["includePrefixes"] = includePrefixes; |
+ } |
+ if (maxTimeElapsedSinceLastModification != null) { |
+ _json["maxTimeElapsedSinceLastModification"] = maxTimeElapsedSinceLastModification; |
+ } |
+ if (minTimeElapsedSinceLastModification != null) { |
+ _json["minTimeElapsedSinceLastModification"] = minTimeElapsedSinceLastModification; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * This resource represents a long-running operation that is the result of a |
+ * network API call. |
+ */ |
+class Operation { |
+ /** |
+ * If the value is `false`, it means the operation is still in progress. If |
+ * true, the operation is completed and the `result` is available. |
+ */ |
+ core.bool done; |
+ /** The error result of the operation in case of failure. */ |
+ Status error; |
+ /** |
+ * Represents the transfer operation object. |
+ * |
+ * The values for Object must be JSON objects. It can consist of `num`, |
+ * `String`, `bool` and `null` as well as `Map` and `List` values. |
+ */ |
+ core.Map<core.String, core.Object> metadata; |
+ /** |
+ * The server-assigned name, which is only unique within the same service that |
+ * originally returns it. If you use the default HTTP mapping above, the |
+ * `name` should have the format of `operations/some/unique/name`. |
+ */ |
+ core.String name; |
+ /** |
+ * The normal response of the operation in case of success. If the original |
+ * method returns no data on success, such as `Delete`, the response is |
+ * `google.protobuf.Empty`. If the original method is standard |
+ * `Get`/`Create`/`Update`, the response should be the resource. For other |
+ * methods, the response should have the type `XxxResponse`, where `Xxx` is |
+ * the original method name. For example, if the original method name is |
+ * `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`. |
+ * |
+ * The values for Object must be JSON objects. It can consist of `num`, |
+ * `String`, `bool` and `null` as well as `Map` and `List` values. |
+ */ |
+ core.Map<core.String, core.Object> response; |
+ |
+ Operation(); |
+ |
+ Operation.fromJson(core.Map _json) { |
+ if (_json.containsKey("done")) { |
+ done = _json["done"]; |
+ } |
+ if (_json.containsKey("error")) { |
+ error = new Status.fromJson(_json["error"]); |
+ } |
+ if (_json.containsKey("metadata")) { |
+ metadata = _json["metadata"]; |
+ } |
+ if (_json.containsKey("name")) { |
+ name = _json["name"]; |
+ } |
+ if (_json.containsKey("response")) { |
+ response = _json["response"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (done != null) { |
+ _json["done"] = done; |
+ } |
+ if (error != null) { |
+ _json["error"] = (error).toJson(); |
+ } |
+ if (metadata != null) { |
+ _json["metadata"] = metadata; |
+ } |
+ if (name != null) { |
+ _json["name"] = name; |
+ } |
+ if (response != null) { |
+ _json["response"] = response; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** Request passed to PauseTransferOperation. */ |
+class PauseTransferOperationRequest { |
+ |
+ PauseTransferOperationRequest(); |
+ |
+ PauseTransferOperationRequest.fromJson(core.Map _json) { |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ return _json; |
+ } |
+} |
+ |
+/** Request passed to ResumeTransferOperation. */ |
+class ResumeTransferOperationRequest { |
+ |
+ ResumeTransferOperationRequest(); |
+ |
+ ResumeTransferOperationRequest.fromJson(core.Map _json) { |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ return _json; |
+ } |
+} |
+ |
+/** Transfers can be scheduled to recur or to run just once. */ |
+class Schedule { |
+ /** |
+ * The last day the recurring transfer will be run. If `scheduleEndDate` is |
+ * the same as `scheduleStartDate`, the transfer will be executed only once. |
+ */ |
+ Date scheduleEndDate; |
+ /** The first day the recurring transfer is scheduled to run. Required. */ |
+ Date scheduleStartDate; |
+ /** |
+ * The time in UTC at which the transfer will be scheduled to start in a day. |
+ * Transfers may start later than this time. If not specified, transfers are |
+ * scheduled to start at midnight UTC. |
+ */ |
+ TimeOfDay startTimeOfDay; |
+ |
+ Schedule(); |
+ |
+ Schedule.fromJson(core.Map _json) { |
+ if (_json.containsKey("scheduleEndDate")) { |
+ scheduleEndDate = new Date.fromJson(_json["scheduleEndDate"]); |
+ } |
+ if (_json.containsKey("scheduleStartDate")) { |
+ scheduleStartDate = new Date.fromJson(_json["scheduleStartDate"]); |
+ } |
+ if (_json.containsKey("startTimeOfDay")) { |
+ startTimeOfDay = new TimeOfDay.fromJson(_json["startTimeOfDay"]); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (scheduleEndDate != null) { |
+ _json["scheduleEndDate"] = (scheduleEndDate).toJson(); |
+ } |
+ if (scheduleStartDate != null) { |
+ _json["scheduleStartDate"] = (scheduleStartDate).toJson(); |
+ } |
+ if (startTimeOfDay != null) { |
+ _json["startTimeOfDay"] = (startTimeOfDay).toJson(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * The `Status` type defines a logical error model that is suitable for |
+ * different programming environments, including REST APIs and RPC APIs. It is |
+ * used by [gRPC](https://github.com/grpc). The error model is designed to be: - |
+ * Simple to use and understand for most users - Flexible enough to meet |
+ * unexpected needs # Overview The `Status` message contains three pieces of |
+ * data: error code, error message, and error details. The error code should be |
+ * an enum value of [google.rpc.Code][google.rpc.Code], but it may accept |
+ * additional error codes if needed. The error message should be a |
+ * developer-facing English message that helps developers *understand* and |
+ * *resolve* the error. If a localized user-facing error message is needed, put |
+ * the localized message in the error details or localize it in the client. The |
+ * optional error details may contain arbitrary information about the error. |
+ * There is a predefined set of error detail types in the package `google.rpc` |
+ * which can be used for common error conditions. # Language mapping The |
+ * `Status` message is the logical representation of the error model, but it is |
+ * not necessarily the actual wire format. When the `Status` message is exposed |
+ * in different client libraries and different wire protocols, it can be mapped |
+ * differently. For example, it will likely be mapped to some exceptions in |
+ * Java, but more likely mapped to some error codes in C. # Other uses The error |
+ * model and the `Status` message can be used in a variety of environments, |
+ * either with or without APIs, to provide a consistent developer experience |
+ * across different environments. Example uses of this error model include: - |
+ * Partial errors. If a service needs to return partial errors to the client, it |
+ * may embed the `Status` in the normal response to indicate the partial errors. |
+ * - Workflow errors. A typical workflow has multiple steps. Each step may have |
+ * a `Status` message for error reporting purpose. - Batch operations. If a |
+ * client uses batch request and batch response, the `Status` message should be |
+ * used directly inside batch response, one for each error sub-response. - |
+ * Asynchronous operations. If an API call embeds asynchronous operation results |
+ * in its response, the status of those operations should be represented |
+ * directly using the `Status` message. - Logging. If some API errors are stored |
+ * in logs, the message `Status` could be used directly after any stripping |
+ * needed for security/privacy reasons. |
+ */ |
+class Status { |
+ /** |
+ * The status code, which should be an enum value of |
+ * [google.rpc.Code][google.rpc.Code]. |
+ */ |
+ core.int code; |
+ /** |
+ * A list of messages that carry the error details. There will be a common set |
+ * of message types for APIs to use. |
+ * |
+ * The values for Object must be JSON objects. It can consist of `num`, |
+ * `String`, `bool` and `null` as well as `Map` and `List` values. |
+ */ |
+ core.List<core.Map<core.String, core.Object>> details; |
+ /** |
+ * A developer-facing error message, which should be in English. Any |
+ * user-facing error message should be localized and sent in the |
+ * [google.rpc.Status.details][google.rpc.Status.details] field, or localized |
+ * by the client. |
+ */ |
+ core.String message; |
+ |
+ Status(); |
+ |
+ Status.fromJson(core.Map _json) { |
+ if (_json.containsKey("code")) { |
+ code = _json["code"]; |
+ } |
+ if (_json.containsKey("details")) { |
+ details = _json["details"]; |
+ } |
+ if (_json.containsKey("message")) { |
+ message = _json["message"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (code != null) { |
+ _json["code"] = code; |
+ } |
+ if (details != null) { |
+ _json["details"] = details; |
+ } |
+ if (message != null) { |
+ _json["message"] = message; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * Represents a time of day. The date and time zone are either not significant |
+ * or are specified elsewhere. An API may chose to allow leap seconds. Related |
+ * types are [google.type.Date][google.type.Date] and |
+ * `google.protobuf.Timestamp`. |
+ */ |
+class TimeOfDay { |
+ /** |
+ * Hours of day in 24 hour format. Should be from 0 to 23. An API may choose |
+ * to allow the value "24:00:00" for scenarios like business closing time. |
+ */ |
+ core.int hours; |
+ /** Minutes of hour of day. Must be from 0 to 59. */ |
+ core.int minutes; |
+ /** Fractions of seconds in nanoseconds. Must be from 0 to 999,999,999. */ |
+ core.int nanos; |
+ /** |
+ * Seconds of minutes of the time. Must normally be from 0 to 59. An API may |
+ * allow the value 60 if it allows leap-seconds. |
+ */ |
+ core.int seconds; |
+ |
+ TimeOfDay(); |
+ |
+ TimeOfDay.fromJson(core.Map _json) { |
+ if (_json.containsKey("hours")) { |
+ hours = _json["hours"]; |
+ } |
+ if (_json.containsKey("minutes")) { |
+ minutes = _json["minutes"]; |
+ } |
+ if (_json.containsKey("nanos")) { |
+ nanos = _json["nanos"]; |
+ } |
+ if (_json.containsKey("seconds")) { |
+ seconds = _json["seconds"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (hours != null) { |
+ _json["hours"] = hours; |
+ } |
+ if (minutes != null) { |
+ _json["minutes"] = minutes; |
+ } |
+ if (nanos != null) { |
+ _json["nanos"] = nanos; |
+ } |
+ if (seconds != null) { |
+ _json["seconds"] = seconds; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * A collection of counters that report the progress of a transfer operation. |
+ */ |
+class TransferCounters { |
+ /** Bytes that are copied to the data sink. */ |
+ core.String bytesCopiedToSink; |
+ /** Bytes that are deleted from the data sink. */ |
+ core.String bytesDeletedFromSink; |
+ /** Bytes that are deleted from the data source. */ |
+ core.String bytesDeletedFromSource; |
+ /** Bytes that failed to be deleted from the data sink. */ |
+ core.String bytesFailedToDeleteFromSink; |
+ /** |
+ * Bytes found in the data source that are scheduled to be transferred, which |
+ * will be copied, excluded based on conditions, or skipped due to failures. |
+ */ |
+ core.String bytesFoundFromSource; |
+ /** Bytes found only in the data sink that are scheduled to be deleted. */ |
+ core.String bytesFoundOnlyFromSink; |
+ /** Bytes in the data source that failed during the transfer. */ |
+ core.String bytesFromSourceFailed; |
+ /** |
+ * Bytes in the data source that are not transferred because they already |
+ * exist in the data sink. |
+ */ |
+ core.String bytesFromSourceSkippedBySync; |
+ /** Objects that are copied to the data sink. */ |
+ core.String objectsCopiedToSink; |
+ /** Objects that are deleted from the data sink. */ |
+ core.String objectsDeletedFromSink; |
+ /** Objects that are deleted from the data source. */ |
+ core.String objectsDeletedFromSource; |
+ /** Objects that failed to be deleted from the data sink. */ |
+ core.String objectsFailedToDeleteFromSink; |
+ /** |
+ * Objects found in the data source that are scheduled to be transferred, |
+ * which will be copied, excluded based on conditions, or skipped due to |
+ * failures. |
+ */ |
+ core.String objectsFoundFromSource; |
+ /** Objects found only in the data sink that are scheduled to be deleted. */ |
+ core.String objectsFoundOnlyFromSink; |
+ /** Objects in the data source that failed during the transfer. */ |
+ core.String objectsFromSourceFailed; |
+ /** |
+ * Objects in the data source that are not transferred because they already |
+ * exist in the data sink. |
+ */ |
+ core.String objectsFromSourceSkippedBySync; |
+ |
+ TransferCounters(); |
+ |
+ TransferCounters.fromJson(core.Map _json) { |
+ if (_json.containsKey("bytesCopiedToSink")) { |
+ bytesCopiedToSink = _json["bytesCopiedToSink"]; |
+ } |
+ if (_json.containsKey("bytesDeletedFromSink")) { |
+ bytesDeletedFromSink = _json["bytesDeletedFromSink"]; |
+ } |
+ if (_json.containsKey("bytesDeletedFromSource")) { |
+ bytesDeletedFromSource = _json["bytesDeletedFromSource"]; |
+ } |
+ if (_json.containsKey("bytesFailedToDeleteFromSink")) { |
+ bytesFailedToDeleteFromSink = _json["bytesFailedToDeleteFromSink"]; |
+ } |
+ if (_json.containsKey("bytesFoundFromSource")) { |
+ bytesFoundFromSource = _json["bytesFoundFromSource"]; |
+ } |
+ if (_json.containsKey("bytesFoundOnlyFromSink")) { |
+ bytesFoundOnlyFromSink = _json["bytesFoundOnlyFromSink"]; |
+ } |
+ if (_json.containsKey("bytesFromSourceFailed")) { |
+ bytesFromSourceFailed = _json["bytesFromSourceFailed"]; |
+ } |
+ if (_json.containsKey("bytesFromSourceSkippedBySync")) { |
+ bytesFromSourceSkippedBySync = _json["bytesFromSourceSkippedBySync"]; |
+ } |
+ if (_json.containsKey("objectsCopiedToSink")) { |
+ objectsCopiedToSink = _json["objectsCopiedToSink"]; |
+ } |
+ if (_json.containsKey("objectsDeletedFromSink")) { |
+ objectsDeletedFromSink = _json["objectsDeletedFromSink"]; |
+ } |
+ if (_json.containsKey("objectsDeletedFromSource")) { |
+ objectsDeletedFromSource = _json["objectsDeletedFromSource"]; |
+ } |
+ if (_json.containsKey("objectsFailedToDeleteFromSink")) { |
+ objectsFailedToDeleteFromSink = _json["objectsFailedToDeleteFromSink"]; |
+ } |
+ if (_json.containsKey("objectsFoundFromSource")) { |
+ objectsFoundFromSource = _json["objectsFoundFromSource"]; |
+ } |
+ if (_json.containsKey("objectsFoundOnlyFromSink")) { |
+ objectsFoundOnlyFromSink = _json["objectsFoundOnlyFromSink"]; |
+ } |
+ if (_json.containsKey("objectsFromSourceFailed")) { |
+ objectsFromSourceFailed = _json["objectsFromSourceFailed"]; |
+ } |
+ if (_json.containsKey("objectsFromSourceSkippedBySync")) { |
+ objectsFromSourceSkippedBySync = _json["objectsFromSourceSkippedBySync"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (bytesCopiedToSink != null) { |
+ _json["bytesCopiedToSink"] = bytesCopiedToSink; |
+ } |
+ if (bytesDeletedFromSink != null) { |
+ _json["bytesDeletedFromSink"] = bytesDeletedFromSink; |
+ } |
+ if (bytesDeletedFromSource != null) { |
+ _json["bytesDeletedFromSource"] = bytesDeletedFromSource; |
+ } |
+ if (bytesFailedToDeleteFromSink != null) { |
+ _json["bytesFailedToDeleteFromSink"] = bytesFailedToDeleteFromSink; |
+ } |
+ if (bytesFoundFromSource != null) { |
+ _json["bytesFoundFromSource"] = bytesFoundFromSource; |
+ } |
+ if (bytesFoundOnlyFromSink != null) { |
+ _json["bytesFoundOnlyFromSink"] = bytesFoundOnlyFromSink; |
+ } |
+ if (bytesFromSourceFailed != null) { |
+ _json["bytesFromSourceFailed"] = bytesFromSourceFailed; |
+ } |
+ if (bytesFromSourceSkippedBySync != null) { |
+ _json["bytesFromSourceSkippedBySync"] = bytesFromSourceSkippedBySync; |
+ } |
+ if (objectsCopiedToSink != null) { |
+ _json["objectsCopiedToSink"] = objectsCopiedToSink; |
+ } |
+ if (objectsDeletedFromSink != null) { |
+ _json["objectsDeletedFromSink"] = objectsDeletedFromSink; |
+ } |
+ if (objectsDeletedFromSource != null) { |
+ _json["objectsDeletedFromSource"] = objectsDeletedFromSource; |
+ } |
+ if (objectsFailedToDeleteFromSink != null) { |
+ _json["objectsFailedToDeleteFromSink"] = objectsFailedToDeleteFromSink; |
+ } |
+ if (objectsFoundFromSource != null) { |
+ _json["objectsFoundFromSource"] = objectsFoundFromSource; |
+ } |
+ if (objectsFoundOnlyFromSink != null) { |
+ _json["objectsFoundOnlyFromSink"] = objectsFoundOnlyFromSink; |
+ } |
+ if (objectsFromSourceFailed != null) { |
+ _json["objectsFromSourceFailed"] = objectsFromSourceFailed; |
+ } |
+ if (objectsFromSourceSkippedBySync != null) { |
+ _json["objectsFromSourceSkippedBySync"] = objectsFromSourceSkippedBySync; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * This resource represents the configuration of a transfer job that runs |
+ * periodically. |
+ */ |
+class TransferJob { |
+ /** This field cannot be changed by user requests. */ |
+ core.String creationTime; |
+ /** This field cannot be changed by user requests. */ |
+ core.String deletionTime; |
+ /** |
+ * A description provided by the user for the job. Its max length is 1024 |
+ * bytes when Unicode-encoded. |
+ */ |
+ core.String description; |
+ /** This field cannot be changed by user requests. */ |
+ core.String lastModificationTime; |
+ /** |
+ * A globally unique name assigned by Storage Transfer Service when the job is |
+ * created. This field should be left empty in requests to create a new |
+ * transfer job; otherwise, the requests result in an `INVALID_ARGUMENT` |
+ * error. |
+ */ |
+ core.String name; |
+ /** |
+ * The ID of the Google Developers Console project that owns the job. |
+ * Required. |
+ */ |
+ core.String projectId; |
+ /** Schedule specification. Required. */ |
+ Schedule schedule; |
+ /** |
+ * Status of the job. This value MUST be specified for |
+ * `CreateTransferJobRequests`. NOTE: The effect of the new job status takes |
+ * place during a subsequent job run. For example, if you change the job |
+ * status from `ENABLED` to `DISABLED`, and an operation spawned by the |
+ * transfer is running, the status change would not affect the current |
+ * operation. |
+ * Possible string values are: |
+ * - "STATUS_UNSPECIFIED" : A STATUS_UNSPECIFIED. |
+ * - "ENABLED" : A ENABLED. |
+ * - "DISABLED" : A DISABLED. |
+ * - "DELETED" : A DELETED. |
+ */ |
+ core.String status; |
+ /** Transfer specification. Required. */ |
+ TransferSpec transferSpec; |
+ |
+ TransferJob(); |
+ |
+ TransferJob.fromJson(core.Map _json) { |
+ if (_json.containsKey("creationTime")) { |
+ creationTime = _json["creationTime"]; |
+ } |
+ if (_json.containsKey("deletionTime")) { |
+ deletionTime = _json["deletionTime"]; |
+ } |
+ if (_json.containsKey("description")) { |
+ description = _json["description"]; |
+ } |
+ if (_json.containsKey("lastModificationTime")) { |
+ lastModificationTime = _json["lastModificationTime"]; |
+ } |
+ if (_json.containsKey("name")) { |
+ name = _json["name"]; |
+ } |
+ if (_json.containsKey("projectId")) { |
+ projectId = _json["projectId"]; |
+ } |
+ if (_json.containsKey("schedule")) { |
+ schedule = new Schedule.fromJson(_json["schedule"]); |
+ } |
+ if (_json.containsKey("status")) { |
+ status = _json["status"]; |
+ } |
+ if (_json.containsKey("transferSpec")) { |
+ transferSpec = new TransferSpec.fromJson(_json["transferSpec"]); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (creationTime != null) { |
+ _json["creationTime"] = creationTime; |
+ } |
+ if (deletionTime != null) { |
+ _json["deletionTime"] = deletionTime; |
+ } |
+ if (description != null) { |
+ _json["description"] = description; |
+ } |
+ if (lastModificationTime != null) { |
+ _json["lastModificationTime"] = lastModificationTime; |
+ } |
+ if (name != null) { |
+ _json["name"] = name; |
+ } |
+ if (projectId != null) { |
+ _json["projectId"] = projectId; |
+ } |
+ if (schedule != null) { |
+ _json["schedule"] = (schedule).toJson(); |
+ } |
+ if (status != null) { |
+ _json["status"] = status; |
+ } |
+ if (transferSpec != null) { |
+ _json["transferSpec"] = (transferSpec).toJson(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** A description of the execution of a transfer. */ |
+class TransferOperation { |
+ /** Information about the progress of the transfer operation. */ |
+ TransferCounters counters; |
+ /** End time of this transfer execution. */ |
+ core.String endTime; |
+ /** Summarizes errors encountered with sample error log entries. */ |
+ core.List<ErrorSummary> errorBreakdowns; |
+ /** A globally unique ID assigned by the system. */ |
+ core.String name; |
+ /** |
+ * The ID of the Google Developers Console project that owns the operation. |
+ * Required. |
+ */ |
+ core.String projectId; |
+ /** Start time of this transfer execution. */ |
+ core.String startTime; |
+ /** |
+ * Status of the transfer operation. |
+ * Possible string values are: |
+ * - "STATUS_UNSPECIFIED" : A STATUS_UNSPECIFIED. |
+ * - "IN_PROGRESS" : A IN_PROGRESS. |
+ * - "PAUSED" : A PAUSED. |
+ * - "SUCCESS" : A SUCCESS. |
+ * - "FAILED" : A FAILED. |
+ * - "ABORTED" : A ABORTED. |
+ */ |
+ core.String status; |
+ /** The name of the transfer job that triggers this transfer operation. */ |
+ core.String transferJobName; |
+ /** Transfer specification. Required. */ |
+ TransferSpec transferSpec; |
+ |
+ TransferOperation(); |
+ |
+ TransferOperation.fromJson(core.Map _json) { |
+ if (_json.containsKey("counters")) { |
+ counters = new TransferCounters.fromJson(_json["counters"]); |
+ } |
+ if (_json.containsKey("endTime")) { |
+ endTime = _json["endTime"]; |
+ } |
+ if (_json.containsKey("errorBreakdowns")) { |
+ errorBreakdowns = _json["errorBreakdowns"].map((value) => new ErrorSummary.fromJson(value)).toList(); |
+ } |
+ if (_json.containsKey("name")) { |
+ name = _json["name"]; |
+ } |
+ if (_json.containsKey("projectId")) { |
+ projectId = _json["projectId"]; |
+ } |
+ if (_json.containsKey("startTime")) { |
+ startTime = _json["startTime"]; |
+ } |
+ if (_json.containsKey("status")) { |
+ status = _json["status"]; |
+ } |
+ if (_json.containsKey("transferJobName")) { |
+ transferJobName = _json["transferJobName"]; |
+ } |
+ if (_json.containsKey("transferSpec")) { |
+ transferSpec = new TransferSpec.fromJson(_json["transferSpec"]); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (counters != null) { |
+ _json["counters"] = (counters).toJson(); |
+ } |
+ if (endTime != null) { |
+ _json["endTime"] = endTime; |
+ } |
+ if (errorBreakdowns != null) { |
+ _json["errorBreakdowns"] = errorBreakdowns.map((value) => (value).toJson()).toList(); |
+ } |
+ if (name != null) { |
+ _json["name"] = name; |
+ } |
+ if (projectId != null) { |
+ _json["projectId"] = projectId; |
+ } |
+ if (startTime != null) { |
+ _json["startTime"] = startTime; |
+ } |
+ if (status != null) { |
+ _json["status"] = status; |
+ } |
+ if (transferJobName != null) { |
+ _json["transferJobName"] = transferJobName; |
+ } |
+ if (transferSpec != null) { |
+ _json["transferSpec"] = (transferSpec).toJson(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** |
+ * TransferOptions uses three boolean parameters to define the actions to be |
+ * performed on objects in a transfer. |
+ */ |
+class TransferOptions { |
+ /** |
+ * Whether objects should be deleted from the source after they are |
+ * transferred to the sink. |
+ */ |
+ core.bool deleteObjectsFromSourceAfterTransfer; |
+ /** Whether objects that exist only in the sink should be deleted. */ |
+ core.bool deleteObjectsUniqueInSink; |
+ /** Whether overwriting objects that already exist in the sink is allowed. */ |
+ core.bool overwriteObjectsAlreadyExistingInSink; |
+ |
+ TransferOptions(); |
+ |
+ TransferOptions.fromJson(core.Map _json) { |
+ if (_json.containsKey("deleteObjectsFromSourceAfterTransfer")) { |
+ deleteObjectsFromSourceAfterTransfer = _json["deleteObjectsFromSourceAfterTransfer"]; |
+ } |
+ if (_json.containsKey("deleteObjectsUniqueInSink")) { |
+ deleteObjectsUniqueInSink = _json["deleteObjectsUniqueInSink"]; |
+ } |
+ if (_json.containsKey("overwriteObjectsAlreadyExistingInSink")) { |
+ overwriteObjectsAlreadyExistingInSink = _json["overwriteObjectsAlreadyExistingInSink"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (deleteObjectsFromSourceAfterTransfer != null) { |
+ _json["deleteObjectsFromSourceAfterTransfer"] = deleteObjectsFromSourceAfterTransfer; |
+ } |
+ if (deleteObjectsUniqueInSink != null) { |
+ _json["deleteObjectsUniqueInSink"] = deleteObjectsUniqueInSink; |
+ } |
+ if (overwriteObjectsAlreadyExistingInSink != null) { |
+ _json["overwriteObjectsAlreadyExistingInSink"] = overwriteObjectsAlreadyExistingInSink; |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** Configuration for running a transfer. */ |
+class TransferSpec { |
+ /** An AWS S3 data source. */ |
+ AwsS3Data awsS3DataSource; |
+ /** A Google Cloud Storage data sink. */ |
+ GcsData gcsDataSink; |
+ /** A Google Cloud Storage data source. */ |
+ GcsData gcsDataSource; |
+ /** An HTTP URL data source. */ |
+ HttpData httpDataSource; |
+ /** |
+ * Only objects that satisfy these object conditions are included in the set |
+ * of data source and data sink objects. Object conditions based on objects' |
+ * `lastModificationTime` do not exclude objects in a data sink. |
+ */ |
+ ObjectConditions objectConditions; |
+ /** |
+ * If the option `deleteObjectsUniqueInSink` is `true`, object conditions |
+ * based on objects' `lastModificationTime` are ignored and do not exclude |
+ * objects in a data source or a data sink. |
+ */ |
+ TransferOptions transferOptions; |
+ |
+ TransferSpec(); |
+ |
+ TransferSpec.fromJson(core.Map _json) { |
+ if (_json.containsKey("awsS3DataSource")) { |
+ awsS3DataSource = new AwsS3Data.fromJson(_json["awsS3DataSource"]); |
+ } |
+ if (_json.containsKey("gcsDataSink")) { |
+ gcsDataSink = new GcsData.fromJson(_json["gcsDataSink"]); |
+ } |
+ if (_json.containsKey("gcsDataSource")) { |
+ gcsDataSource = new GcsData.fromJson(_json["gcsDataSource"]); |
+ } |
+ if (_json.containsKey("httpDataSource")) { |
+ httpDataSource = new HttpData.fromJson(_json["httpDataSource"]); |
+ } |
+ if (_json.containsKey("objectConditions")) { |
+ objectConditions = new ObjectConditions.fromJson(_json["objectConditions"]); |
+ } |
+ if (_json.containsKey("transferOptions")) { |
+ transferOptions = new TransferOptions.fromJson(_json["transferOptions"]); |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (awsS3DataSource != null) { |
+ _json["awsS3DataSource"] = (awsS3DataSource).toJson(); |
+ } |
+ if (gcsDataSink != null) { |
+ _json["gcsDataSink"] = (gcsDataSink).toJson(); |
+ } |
+ if (gcsDataSource != null) { |
+ _json["gcsDataSource"] = (gcsDataSource).toJson(); |
+ } |
+ if (httpDataSource != null) { |
+ _json["httpDataSource"] = (httpDataSource).toJson(); |
+ } |
+ if (objectConditions != null) { |
+ _json["objectConditions"] = (objectConditions).toJson(); |
+ } |
+ if (transferOptions != null) { |
+ _json["transferOptions"] = (transferOptions).toJson(); |
+ } |
+ return _json; |
+ } |
+} |
+ |
+/** Request passed to UpdateTransferJob. */ |
+class UpdateTransferJobRequest { |
+ /** |
+ * The ID of the Google Developers Console project that owns the job. |
+ * Required. |
+ */ |
+ core.String projectId; |
+ /** The job to update. Required. */ |
+ TransferJob transferJob; |
+ /** |
+ * The field mask of the fields in `transferJob` that are to be updated in |
+ * this request. Fields in `transferJob` that can be updated are: |
+ * `description`, `transferSpec`, and `status`. To update the `transferSpec` |
+ * of the job, a complete transfer specification has to be provided. An |
+ * incomplete specification which misses any required fields will be rejected |
+ * with the error `INVALID_ARGUMENT`. |
+ */ |
+ core.String updateTransferJobFieldMask; |
+ |
+ UpdateTransferJobRequest(); |
+ |
+ UpdateTransferJobRequest.fromJson(core.Map _json) { |
+ if (_json.containsKey("projectId")) { |
+ projectId = _json["projectId"]; |
+ } |
+ if (_json.containsKey("transferJob")) { |
+ transferJob = new TransferJob.fromJson(_json["transferJob"]); |
+ } |
+ if (_json.containsKey("updateTransferJobFieldMask")) { |
+ updateTransferJobFieldMask = _json["updateTransferJobFieldMask"]; |
+ } |
+ } |
+ |
+ core.Map toJson() { |
+ var _json = new core.Map(); |
+ if (projectId != null) { |
+ _json["projectId"] = projectId; |
+ } |
+ if (transferJob != null) { |
+ _json["transferJob"] = (transferJob).toJson(); |
+ } |
+ if (updateTransferJobFieldMask != null) { |
+ _json["updateTransferJobFieldMask"] = updateTransferJobFieldMask; |
+ } |
+ return _json; |
+ } |
+} |