| Index: tools/telemetry/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| diff --git a/tools/telemetry/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py b/tools/telemetry/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| deleted file mode 100644
|
| index 97627e255001b4c3375405c7095bd3637a27de91..0000000000000000000000000000000000000000
|
| --- a/tools/telemetry/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| +++ /dev/null
|
| @@ -1,2916 +0,0 @@
|
| -#!/usr/bin/env python
|
| -"""CLI for storage, version v1."""
|
| -
|
| -import code
|
| -import platform
|
| -import sys
|
| -
|
| -import protorpc
|
| -from protorpc import message_types
|
| -from protorpc import messages
|
| -
|
| -from google.apputils import appcommands
|
| -import gflags as flags
|
| -
|
| -import apitools.base.py as apitools_base
|
| -from apitools.base.py import cli as apitools_base_cli
|
| -import storage_v1_client as client_lib
|
| -import storage_v1_messages as messages
|
| -
|
| -
|
| -def _DeclareStorageFlags():
|
| - """Declare global flags in an idempotent way."""
|
| - if 'api_endpoint' in flags.FLAGS:
|
| - return
|
| - flags.DEFINE_string(
|
| - 'api_endpoint',
|
| - u'https://www.googleapis.com/storage/v1/',
|
| - 'URL of the API endpoint to use.',
|
| - short_name='storage_url')
|
| - flags.DEFINE_string(
|
| - 'history_file',
|
| - u'~/.storage.v1.history',
|
| - 'File with interactive shell history.')
|
| - flags.DEFINE_multistring(
|
| - 'add_header', [],
|
| - 'Additional http headers (as key=value strings). Can be '
|
| - 'specified multiple times.')
|
| - flags.DEFINE_enum(
|
| - 'alt',
|
| - u'json',
|
| - [u'json'],
|
| - u'Data format for the response.')
|
| - flags.DEFINE_string(
|
| - 'fields',
|
| - None,
|
| - u'Selector specifying which fields to include in a partial response.')
|
| - flags.DEFINE_string(
|
| - 'key',
|
| - None,
|
| - u'API key. Your API key identifies your project and provides you with '
|
| - u'API access, quota, and reports. Required unless you provide an OAuth '
|
| - u'2.0 token.')
|
| - flags.DEFINE_string(
|
| - 'oauth_token',
|
| - None,
|
| - u'OAuth 2.0 token for the current user.')
|
| - flags.DEFINE_boolean(
|
| - 'prettyPrint',
|
| - 'True',
|
| - u'Returns response with indentations and line breaks.')
|
| - flags.DEFINE_string(
|
| - 'quotaUser',
|
| - None,
|
| - u'Available to use for quota purposes for server-side applications. Can'
|
| - u' be any arbitrary string assigned to a user, but should not exceed 40'
|
| - u' characters. Overrides userIp if both are provided.')
|
| - flags.DEFINE_string(
|
| - 'trace',
|
| - None,
|
| - 'A tracing token of the form "token:<tokenid>" to include in api '
|
| - 'requests.')
|
| - flags.DEFINE_string(
|
| - 'userIp',
|
| - None,
|
| - u'IP address of the site where the request originates. Use this if you '
|
| - u'want to enforce per-user limits.')
|
| -
|
| -
|
| -FLAGS = flags.FLAGS
|
| -apitools_base_cli.DeclareBaseFlags()
|
| -_DeclareStorageFlags()
|
| -
|
| -
|
| -def GetGlobalParamsFromFlags():
|
| - """Return a StandardQueryParameters based on flags."""
|
| - result = messages.StandardQueryParameters()
|
| - if FLAGS['alt'].present:
|
| - result.alt = messages.StandardQueryParameters.AltValueValuesEnum(FLAGS.alt)
|
| - if FLAGS['fields'].present:
|
| - result.fields = FLAGS.fields.decode('utf8')
|
| - if FLAGS['key'].present:
|
| - result.key = FLAGS.key.decode('utf8')
|
| - if FLAGS['oauth_token'].present:
|
| - result.oauth_token = FLAGS.oauth_token.decode('utf8')
|
| - if FLAGS['prettyPrint'].present:
|
| - result.prettyPrint = FLAGS.prettyPrint
|
| - if FLAGS['quotaUser'].present:
|
| - result.quotaUser = FLAGS.quotaUser.decode('utf8')
|
| - if FLAGS['trace'].present:
|
| - result.trace = FLAGS.trace.decode('utf8')
|
| - if FLAGS['userIp'].present:
|
| - result.userIp = FLAGS.userIp.decode('utf8')
|
| - return result
|
| -
|
| -
|
| -def GetClientFromFlags():
|
| - """Return a client object, configured from flags."""
|
| - log_request = FLAGS.log_request or FLAGS.log_request_response
|
| - log_response = FLAGS.log_response or FLAGS.log_request_response
|
| - api_endpoint = apitools_base.NormalizeApiEndpoint(FLAGS.api_endpoint)
|
| - additional_http_headers = dict(x.split('=', 1) for x in FLAGS.add_header)
|
| - try:
|
| - client = client_lib.StorageV1(
|
| - api_endpoint, log_request=log_request,
|
| - log_response=log_response,
|
| - additional_http_headers=additional_http_headers)
|
| - except apitools_base.CredentialsError as e:
|
| - print 'Error creating credentials: %s' % e
|
| - sys.exit(1)
|
| - return client
|
| -
|
| -
|
| -class PyShell(appcommands.Cmd):
|
| -
|
| - def Run(self, _):
|
| - """Run an interactive python shell with the client."""
|
| - client = GetClientFromFlags()
|
| - params = GetGlobalParamsFromFlags()
|
| - for field in params.all_fields():
|
| - value = params.get_assigned_value(field.name)
|
| - if value != field.default:
|
| - client.AddGlobalParam(field.name, value)
|
| - banner = """
|
| - == storage interactive console ==
|
| - client: a storage client
|
| - apitools_base: base apitools module
|
| - messages: the generated messages module
|
| - """
|
| - local_vars = {
|
| - 'apitools_base': apitools_base,
|
| - 'client': client,
|
| - 'client_lib': client_lib,
|
| - 'messages': messages,
|
| - }
|
| - if platform.system() == 'Linux':
|
| - console = apitools_base_cli.ConsoleWithReadline(
|
| - local_vars, histfile=FLAGS.history_file)
|
| - else:
|
| - console = code.InteractiveConsole(local_vars)
|
| - try:
|
| - console.interact(banner)
|
| - except SystemExit as e:
|
| - return e.code
|
| -
|
| -
|
| -class DefaultObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Delete."""
|
| -
|
| - usage = """defaultObjectAccessControls_delete <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsDelete, self).__init__(name, fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Permanently deletes the default object ACL entry for the specified
|
| - entity on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageDefaultObjectAccessControlsDeleteRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - result = client.defaultObjectAccessControls.Delete(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class DefaultObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Get."""
|
| -
|
| - usage = """defaultObjectAccessControls_get <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsGet, self).__init__(name, fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Returns the default object ACL entry for the specified entity on the
|
| - specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageDefaultObjectAccessControlsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - result = client.defaultObjectAccessControls.Get(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Insert."""
|
| -
|
| - usage = """defaultObjectAccessControls_insert <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsInsert, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entity',
|
| - None,
|
| - u'The entity holding the permission, in one of the following forms: '
|
| - u'- user-userId - user-email - group-groupId - group-email - '
|
| - u'domain-domain - project-team-projectId - allUsers - '
|
| - u'allAuthenticatedUsers Examples: - The user liz@example.com would '
|
| - u'be user-liz@example.com. - The group example@googlegroups.com '
|
| - u'would be group-example@googlegroups.com. - To refer to all members'
|
| - u' of the Google Apps for Business domain example.com, the entity '
|
| - u'would be domain-example.com.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'The content generation of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#objectAccessControl',
|
| - u'The kind of item this is. For object access control entries, this '
|
| - u'is always storage#objectAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'The name of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER or OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Creates a new default object ACL entry on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: The name of the bucket.
|
| -
|
| - Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - generation: The content generation of the object.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For object access control entries, this
|
| - is always storage#objectAccessControl.
|
| - object: The name of the object.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER or OWNER.
|
| - selfLink: The link to this access-control entry.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.ObjectAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entity'].present:
|
| - request.entity = FLAGS.entity.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = FLAGS.object.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.defaultObjectAccessControls.Insert(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class DefaultObjectAccessControlsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.List."""
|
| -
|
| - usage = """defaultObjectAccessControls_list <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsList, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"If present, only return default ACL listing if the bucket's current"
|
| - u' metageneration matches this value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"If present, only return default ACL listing if the bucket's current"
|
| - u' metageneration does not match the given value.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Retrieves default object ACL entries on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| -
|
| - Flags:
|
| - ifMetagenerationMatch: If present, only return default ACL listing if
|
| - the bucket's current metageneration matches this value.
|
| - ifMetagenerationNotMatch: If present, only return default ACL listing if
|
| - the bucket's current metageneration does not match the given value.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageDefaultObjectAccessControlsListRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - result = client.defaultObjectAccessControls.List(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Patch."""
|
| -
|
| - usage = """defaultObjectAccessControls_patch <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsPatch, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'The content generation of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#objectAccessControl',
|
| - u'The kind of item this is. For object access control entries, this '
|
| - u'is always storage#objectAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'The name of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER or OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Updates a default object ACL entry on the specified bucket. This method
|
| - supports patch semantics.
|
| -
|
| - Args:
|
| - bucket: The name of the bucket.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| -
|
| - Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - generation: The content generation of the object.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For object access control entries, this
|
| - is always storage#objectAccessControl.
|
| - object: The name of the object.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER or OWNER.
|
| - selfLink: The link to this access-control entry.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.ObjectAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = FLAGS.object.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.defaultObjectAccessControls.Patch(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Update."""
|
| -
|
| - usage = """defaultObjectAccessControls_update <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsUpdate, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'The content generation of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#objectAccessControl',
|
| - u'The kind of item this is. For object access control entries, this '
|
| - u'is always storage#objectAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'The name of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER or OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Updates a default object ACL entry on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: The name of the bucket.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| -
|
| - Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - generation: The content generation of the object.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For object access control entries, this
|
| - is always storage#objectAccessControl.
|
| - object: The name of the object.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER or OWNER.
|
| - selfLink: The link to this access-control entry.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.ObjectAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = FLAGS.object.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.defaultObjectAccessControls.Update(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Delete."""
|
| -
|
| - usage = """bucketAccessControls_delete <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsDelete, self).__init__(name, fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Permanently deletes the ACL entry for the specified entity on the
|
| - specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketAccessControlsDeleteRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - result = client.bucketAccessControls.Delete(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Get."""
|
| -
|
| - usage = """bucketAccessControls_get <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsGet, self).__init__(name, fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Returns the ACL entry for the specified entity on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketAccessControlsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - result = client.bucketAccessControls.Get(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Insert."""
|
| -
|
| - usage = """bucketAccessControls_insert <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsInsert, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entity',
|
| - None,
|
| - u'The entity holding the permission, in one of the following forms: '
|
| - u'- user-userId - user-email - group-groupId - group-email - '
|
| - u'domain-domain - project-team-projectId - allUsers - '
|
| - u'allAuthenticatedUsers Examples: - The user liz@example.com would '
|
| - u'be user-liz@example.com. - The group example@googlegroups.com '
|
| - u'would be group-example@googlegroups.com. - To refer to all members'
|
| - u' of the Google Apps for Business domain example.com, the entity '
|
| - u'would be domain-example.com.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#bucketAccessControl',
|
| - u'The kind of item this is. For bucket access control entries, this '
|
| - u'is always storage#bucketAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER, WRITER, or '
|
| - u'OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Creates a new ACL entry on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: The name of the bucket.
|
| -
|
| - Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For bucket access control entries, this
|
| - is always storage#bucketAccessControl.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER, WRITER, or
|
| - OWNER.
|
| - selfLink: The link to this access-control entry.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.BucketAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entity'].present:
|
| - request.entity = FLAGS.entity.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.bucketAccessControls.Insert(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.List."""
|
| -
|
| - usage = """bucketAccessControls_list <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsList, self).__init__(name, fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Retrieves ACL entries on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketAccessControlsListRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - result = client.bucketAccessControls.List(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Patch."""
|
| -
|
| - usage = """bucketAccessControls_patch <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsPatch, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#bucketAccessControl',
|
| - u'The kind of item this is. For bucket access control entries, this '
|
| - u'is always storage#bucketAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER, WRITER, or '
|
| - u'OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Updates an ACL entry on the specified bucket. This method supports
|
| - patch semantics.
|
| -
|
| - Args:
|
| - bucket: The name of the bucket.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| -
|
| - Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For bucket access control entries, this
|
| - is always storage#bucketAccessControl.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER, WRITER, or
|
| - OWNER.
|
| - selfLink: The link to this access-control entry.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.BucketAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.bucketAccessControls.Patch(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Update."""
|
| -
|
| - usage = """bucketAccessControls_update <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsUpdate, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#bucketAccessControl',
|
| - u'The kind of item this is. For bucket access control entries, this '
|
| - u'is always storage#bucketAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER, WRITER, or '
|
| - u'OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Updates an ACL entry on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: The name of the bucket.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| -
|
| - Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For bucket access control entries, this
|
| - is always storage#bucketAccessControl.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER, WRITER, or
|
| - OWNER.
|
| - selfLink: The link to this access-control entry.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.BucketAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.bucketAccessControls.Update(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ChannelsStop(apitools_base_cli.NewCmd):
|
| - """Command wrapping channels.Stop."""
|
| -
|
| - usage = """channels_stop"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ChannelsStop, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'address',
|
| - None,
|
| - u'The address where notifications are delivered for this channel.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'expiration',
|
| - None,
|
| - u'Date and time of notification channel expiration, expressed as a '
|
| - u'Unix timestamp, in milliseconds. Optional.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'A UUID or similar unique string that identifies this channel.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'api#channel',
|
| - u'Identifies this as a notification channel used to watch for changes'
|
| - u' to a resource. Value: the fixed string "api#channel".',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'params',
|
| - None,
|
| - u'Additional parameters controlling delivery channel behavior. '
|
| - u'Optional.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'payload',
|
| - None,
|
| - u'A Boolean value to indicate whether payload is wanted. Optional.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'resourceId',
|
| - None,
|
| - u'An opaque ID that identifies the resource being watched on this '
|
| - u'channel. Stable across different API versions.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'resourceUri',
|
| - None,
|
| - u'A version-specific identifier for the watched resource.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'token',
|
| - None,
|
| - u'An arbitrary string delivered to the target address with each '
|
| - u'notification delivered over this channel. Optional.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'type',
|
| - None,
|
| - u'The type of delivery mechanism used for this channel.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self):
|
| - """Stop watching resources through this channel
|
| -
|
| - Flags:
|
| - address: The address where notifications are delivered for this channel.
|
| - expiration: Date and time of notification channel expiration, expressed
|
| - as a Unix timestamp, in milliseconds. Optional.
|
| - id: A UUID or similar unique string that identifies this channel.
|
| - kind: Identifies this as a notification channel used to watch for
|
| - changes to a resource. Value: the fixed string "api#channel".
|
| - params: Additional parameters controlling delivery channel behavior.
|
| - Optional.
|
| - payload: A Boolean value to indicate whether payload is wanted.
|
| - Optional.
|
| - resourceId: An opaque ID that identifies the resource being watched on
|
| - this channel. Stable across different API versions.
|
| - resourceUri: A version-specific identifier for the watched resource.
|
| - token: An arbitrary string delivered to the target address with each
|
| - notification delivered over this channel. Optional.
|
| - type: The type of delivery mechanism used for this channel.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.Channel(
|
| - )
|
| - if FLAGS['address'].present:
|
| - request.address = FLAGS.address.decode('utf8')
|
| - if FLAGS['expiration'].present:
|
| - request.expiration = int(FLAGS.expiration)
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['params'].present:
|
| - request.params = apitools_base.JsonToMessage(messages.Channel.ParamsValue, FLAGS.params)
|
| - if FLAGS['payload'].present:
|
| - request.payload = FLAGS.payload
|
| - if FLAGS['resourceId'].present:
|
| - request.resourceId = FLAGS.resourceId.decode('utf8')
|
| - if FLAGS['resourceUri'].present:
|
| - request.resourceUri = FLAGS.resourceUri.decode('utf8')
|
| - if FLAGS['token'].present:
|
| - request.token = FLAGS.token.decode('utf8')
|
| - if FLAGS['type'].present:
|
| - request.type = FLAGS.type.decode('utf8')
|
| - result = client.channels.Stop(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsCompose(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Compose."""
|
| -
|
| - usage = """objects_compose <destinationBucket> <destinationObject>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsCompose, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'composeRequest',
|
| - None,
|
| - u'A ComposeRequest resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'destinationPredefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to the destination '
|
| - u'object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, destinationBucket, destinationObject):
|
| - """Concatenates a list of existing objects into a new object in the same
|
| - bucket.
|
| -
|
| - Args:
|
| - destinationBucket: Name of the bucket in which to store the new object.
|
| - destinationObject: Name of the new object.
|
| -
|
| - Flags:
|
| - composeRequest: A ComposeRequest resource to be passed as the request
|
| - body.
|
| - destinationPredefinedAcl: Apply a predefined set of access controls to
|
| - the destination object.
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsComposeRequest(
|
| - destinationBucket=destinationBucket.decode('utf8'),
|
| - destinationObject=destinationObject.decode('utf8'),
|
| - )
|
| - if FLAGS['composeRequest'].present:
|
| - request.composeRequest = apitools_base.JsonToMessage(messages.ComposeRequest, FLAGS.composeRequest)
|
| - if FLAGS['destinationPredefinedAcl'].present:
|
| - request.destinationPredefinedAcl = messages.StorageObjectsComposeRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Compose(
|
| - request, global_params=global_params, download=download)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsCopy(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Copy."""
|
| -
|
| - usage = """objects_copy <sourceBucket> <sourceObject> <destinationBucket> <destinationObject>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsCopy, self).__init__(name, fv)
|
| - flags.DEFINE_enum(
|
| - 'destinationPredefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to the destination '
|
| - u'object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifSourceGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifSourceGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifSourceMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'current metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifSourceMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'current metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl, unless the object '
|
| - u'resource specifies the acl property, when it defaults to full.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'sourceGeneration',
|
| - None,
|
| - u'If present, selects a specific revision of the source object (as '
|
| - u'opposed to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, sourceBucket, sourceObject, destinationBucket, destinationObject):
|
| - """Copies an object to a specified location. Optionally overrides
|
| - metadata.
|
| -
|
| - Args:
|
| - sourceBucket: Name of the bucket in which to find the source object.
|
| - sourceObject: Name of the source object.
|
| - destinationBucket: Name of the bucket in which to store the new object.
|
| - Overrides the provided object metadata's bucket value, if any.
|
| - destinationObject: Name of the new object. Required when the object
|
| - metadata is not otherwise provided. Overrides the object metadata's
|
| - name value, if any.
|
| -
|
| - Flags:
|
| - destinationPredefinedAcl: Apply a predefined set of access controls to
|
| - the destination object.
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - destination object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - destination object's current generation does not match the given
|
| - value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - destination object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - destination object's current metageneration does not match the given
|
| - value.
|
| - ifSourceGenerationMatch: Makes the operation conditional on whether the
|
| - source object's generation matches the given value.
|
| - ifSourceGenerationNotMatch: Makes the operation conditional on whether
|
| - the source object's generation does not match the given value.
|
| - ifSourceMetagenerationMatch: Makes the operation conditional on whether
|
| - the source object's current metageneration matches the given value.
|
| - ifSourceMetagenerationNotMatch: Makes the operation conditional on
|
| - whether the source object's current metageneration does not match the
|
| - given value.
|
| - object: A Object resource to be passed as the request body.
|
| - projection: Set of properties to return. Defaults to noAcl, unless the
|
| - object resource specifies the acl property, when it defaults to full.
|
| - sourceGeneration: If present, selects a specific revision of the source
|
| - object (as opposed to the latest version, the default).
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsCopyRequest(
|
| - sourceBucket=sourceBucket.decode('utf8'),
|
| - sourceObject=sourceObject.decode('utf8'),
|
| - destinationBucket=destinationBucket.decode('utf8'),
|
| - destinationObject=destinationObject.decode('utf8'),
|
| - )
|
| - if FLAGS['destinationPredefinedAcl'].present:
|
| - request.destinationPredefinedAcl = messages.StorageObjectsCopyRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['ifSourceGenerationMatch'].present:
|
| - request.ifSourceGenerationMatch = int(FLAGS.ifSourceGenerationMatch)
|
| - if FLAGS['ifSourceGenerationNotMatch'].present:
|
| - request.ifSourceGenerationNotMatch = int(FLAGS.ifSourceGenerationNotMatch)
|
| - if FLAGS['ifSourceMetagenerationMatch'].present:
|
| - request.ifSourceMetagenerationMatch = int(FLAGS.ifSourceMetagenerationMatch)
|
| - if FLAGS['ifSourceMetagenerationNotMatch'].present:
|
| - request.ifSourceMetagenerationNotMatch = int(FLAGS.ifSourceMetagenerationNotMatch)
|
| - if FLAGS['object'].present:
|
| - request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsCopyRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - if FLAGS['sourceGeneration'].present:
|
| - request.sourceGeneration = int(FLAGS.sourceGeneration)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Copy(
|
| - request, global_params=global_params, download=download)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Delete."""
|
| -
|
| - usage = """objects_delete <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsDelete, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, permanently deletes a specific revision of this object '
|
| - u'(as opposed to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Deletes an object and its metadata. Deletions are permanent if
|
| - versioning is not enabled for the bucket, or if the generation parameter
|
| - is used.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, permanently deletes a specific revision of this
|
| - object (as opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsDeleteRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - result = client.objects.Delete(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Get."""
|
| -
|
| - usage = """objects_get <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsGet, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's generation "
|
| - u'matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's generation "
|
| - u'does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Retrieves an object or its metadata.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsGetRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Get(
|
| - request, global_params=global_params, download=download)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Insert."""
|
| -
|
| - usage = """objects_insert <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsInsert, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'contentEncoding',
|
| - None,
|
| - u'If set, sets the contentEncoding property of the final object to '
|
| - u'this value. Setting this parameter is equivalent to setting the '
|
| - u'contentEncoding metadata property. This can be useful when '
|
| - u'uploading an object with uploadType=media to indicate the encoding '
|
| - u'of the content being uploaded.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'name',
|
| - None,
|
| - u'Name of the object. Required when the object metadata is not '
|
| - u"otherwise provided. Overrides the object metadata's name value, if "
|
| - u'any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to this object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl, unless the object '
|
| - u'resource specifies the acl property, when it defaults to full.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'upload_filename',
|
| - '',
|
| - 'Filename to use for upload.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'upload_mime_type',
|
| - '',
|
| - 'MIME type to use for the upload. Only needed if the extension on '
|
| - '--upload_filename does not determine the correct (or any) MIME '
|
| - 'type.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Stores a new object and metadata.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which to store the new object. Overrides
|
| - the provided object metadata's bucket value, if any.
|
| -
|
| - Flags:
|
| - contentEncoding: If set, sets the contentEncoding property of the final
|
| - object to this value. Setting this parameter is equivalent to setting
|
| - the contentEncoding metadata property. This can be useful when
|
| - uploading an object with uploadType=media to indicate the encoding of
|
| - the content being uploaded.
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - name: Name of the object. Required when the object metadata is not
|
| - otherwise provided. Overrides the object metadata's name value, if
|
| - any.
|
| - object: A Object resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this object.
|
| - projection: Set of properties to return. Defaults to noAcl, unless the
|
| - object resource specifies the acl property, when it defaults to full.
|
| - upload_filename: Filename to use for upload.
|
| - upload_mime_type: MIME type to use for the upload. Only needed if the
|
| - extension on --upload_filename does not determine the correct (or any)
|
| - MIME type.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsInsertRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['contentEncoding'].present:
|
| - request.contentEncoding = FLAGS.contentEncoding.decode('utf8')
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['name'].present:
|
| - request.name = FLAGS.name.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageObjectsInsertRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsInsertRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - upload = None
|
| - if FLAGS.upload_filename:
|
| - upload = apitools_base.Upload.FromFile(
|
| - FLAGS.upload_filename, FLAGS.upload_mime_type)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Insert(
|
| - request, global_params=global_params, upload=upload, download=download)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.List."""
|
| -
|
| - usage = """objects_list <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsList, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'delimiter',
|
| - None,
|
| - u'Returns results in a directory-like mode. items will contain only '
|
| - u'objects whose names, aside from the prefix, do not contain '
|
| - u'delimiter. Objects whose names, aside from the prefix, contain '
|
| - u'delimiter will have their name, truncated after the delimiter, '
|
| - u'returned in prefixes. Duplicate prefixes are omitted.',
|
| - flag_values=fv)
|
| - flags.DEFINE_integer(
|
| - 'maxResults',
|
| - None,
|
| - u'Maximum number of items plus prefixes to return. As duplicate '
|
| - u'prefixes are omitted, fewer total results may be returned than '
|
| - u'requested.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'pageToken',
|
| - None,
|
| - u'A previously-returned page token representing part of the larger '
|
| - u'set of results to view.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'prefix',
|
| - None,
|
| - u'Filter results to objects whose names begin with this prefix.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'versions',
|
| - None,
|
| - u'If true, lists all versions of a file as distinct results.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Retrieves a list of objects matching the criteria.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which to look for objects.
|
| -
|
| - Flags:
|
| - delimiter: Returns results in a directory-like mode. items will contain
|
| - only objects whose names, aside from the prefix, do not contain
|
| - delimiter. Objects whose names, aside from the prefix, contain
|
| - delimiter will have their name, truncated after the delimiter,
|
| - returned in prefixes. Duplicate prefixes are omitted.
|
| - maxResults: Maximum number of items plus prefixes to return. As
|
| - duplicate prefixes are omitted, fewer total results may be returned
|
| - than requested.
|
| - pageToken: A previously-returned page token representing part of the
|
| - larger set of results to view.
|
| - prefix: Filter results to objects whose names begin with this prefix.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - versions: If true, lists all versions of a file as distinct results.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsListRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['delimiter'].present:
|
| - request.delimiter = FLAGS.delimiter.decode('utf8')
|
| - if FLAGS['maxResults'].present:
|
| - request.maxResults = FLAGS.maxResults
|
| - if FLAGS['pageToken'].present:
|
| - request.pageToken = FLAGS.pageToken.decode('utf8')
|
| - if FLAGS['prefix'].present:
|
| - request.prefix = FLAGS.prefix.decode('utf8')
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - if FLAGS['versions'].present:
|
| - request.versions = FLAGS.versions
|
| - result = client.objects.List(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Patch."""
|
| -
|
| - usage = """objects_patch <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsPatch, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectResource',
|
| - None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to this object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Updates an object's metadata. This method supports patch semantics.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - objectResource: A Object resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this object.
|
| - projection: Set of properties to return. Defaults to full.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsPatchRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['objectResource'].present:
|
| - request.objectResource = apitools_base.JsonToMessage(messages.Object, FLAGS.objectResource)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageObjectsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.objects.Patch(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Update."""
|
| -
|
| - usage = """objects_update <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsUpdate, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectResource',
|
| - None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to this object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Updates an object's metadata.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - objectResource: A Object resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this object.
|
| - projection: Set of properties to return. Defaults to full.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsUpdateRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['objectResource'].present:
|
| - request.objectResource = apitools_base.JsonToMessage(messages.Object, FLAGS.objectResource)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageObjectsUpdateRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsUpdateRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Update(
|
| - request, global_params=global_params, download=download)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectsWatchAll(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.WatchAll."""
|
| -
|
| - usage = """objects_watchAll <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectsWatchAll, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'channel',
|
| - None,
|
| - u'A Channel resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'delimiter',
|
| - None,
|
| - u'Returns results in a directory-like mode. items will contain only '
|
| - u'objects whose names, aside from the prefix, do not contain '
|
| - u'delimiter. Objects whose names, aside from the prefix, contain '
|
| - u'delimiter will have their name, truncated after the delimiter, '
|
| - u'returned in prefixes. Duplicate prefixes are omitted.',
|
| - flag_values=fv)
|
| - flags.DEFINE_integer(
|
| - 'maxResults',
|
| - None,
|
| - u'Maximum number of items plus prefixes to return. As duplicate '
|
| - u'prefixes are omitted, fewer total results may be returned than '
|
| - u'requested.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'pageToken',
|
| - None,
|
| - u'A previously-returned page token representing part of the larger '
|
| - u'set of results to view.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'prefix',
|
| - None,
|
| - u'Filter results to objects whose names begin with this prefix.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'versions',
|
| - None,
|
| - u'If true, lists all versions of a file as distinct results.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Watch for changes on all objects in a bucket.
|
| -
|
| - Args:
|
| - bucket: Name of the bucket in which to look for objects.
|
| -
|
| - Flags:
|
| - channel: A Channel resource to be passed as the request body.
|
| - delimiter: Returns results in a directory-like mode. items will contain
|
| - only objects whose names, aside from the prefix, do not contain
|
| - delimiter. Objects whose names, aside from the prefix, contain
|
| - delimiter will have their name, truncated after the delimiter,
|
| - returned in prefixes. Duplicate prefixes are omitted.
|
| - maxResults: Maximum number of items plus prefixes to return. As
|
| - duplicate prefixes are omitted, fewer total results may be returned
|
| - than requested.
|
| - pageToken: A previously-returned page token representing part of the
|
| - larger set of results to view.
|
| - prefix: Filter results to objects whose names begin with this prefix.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - versions: If true, lists all versions of a file as distinct results.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsWatchAllRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['channel'].present:
|
| - request.channel = apitools_base.JsonToMessage(messages.Channel, FLAGS.channel)
|
| - if FLAGS['delimiter'].present:
|
| - request.delimiter = FLAGS.delimiter.decode('utf8')
|
| - if FLAGS['maxResults'].present:
|
| - request.maxResults = FLAGS.maxResults
|
| - if FLAGS['pageToken'].present:
|
| - request.pageToken = FLAGS.pageToken.decode('utf8')
|
| - if FLAGS['prefix'].present:
|
| - request.prefix = FLAGS.prefix.decode('utf8')
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsWatchAllRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - if FLAGS['versions'].present:
|
| - request.versions = FLAGS.versions
|
| - result = client.objects.WatchAll(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Delete."""
|
| -
|
| - usage = """objectAccessControls_delete <bucket> <object> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsDelete, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object, entity):
|
| - """Permanently deletes the ACL entry for the specified entity on the
|
| - specified object.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsDeleteRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - result = client.objectAccessControls.Delete(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Get."""
|
| -
|
| - usage = """objectAccessControls_get <bucket> <object> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsGet, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object, entity):
|
| - """Returns the ACL entry for the specified entity on the specified object.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - result = client.objectAccessControls.Get(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Insert."""
|
| -
|
| - usage = """objectAccessControls_insert <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsInsert, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectAccessControl',
|
| - None,
|
| - u'A ObjectAccessControl resource to be passed as the request body.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Creates a new ACL entry on the specified object.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| - request body.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsInsertRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['objectAccessControl'].present:
|
| - request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| - result = client.objectAccessControls.Insert(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.List."""
|
| -
|
| - usage = """objectAccessControls_list <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsList, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Retrieves ACL entries on the specified object.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsListRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - result = client.objectAccessControls.List(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Patch."""
|
| -
|
| - usage = """objectAccessControls_patch <bucket> <object> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsPatch, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectAccessControl',
|
| - None,
|
| - u'A ObjectAccessControl resource to be passed as the request body.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object, entity):
|
| - """Updates an ACL entry on the specified object. This method supports
|
| - patch semantics.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| - request body.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsPatchRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['objectAccessControl'].present:
|
| - request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| - result = client.objectAccessControls.Patch(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Update."""
|
| -
|
| - usage = """objectAccessControls_update <bucket> <object> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsUpdate, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectAccessControl',
|
| - None,
|
| - u'A ObjectAccessControl resource to be passed as the request body.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object, entity):
|
| - """Updates an ACL entry on the specified object.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| - request body.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsUpdateRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['objectAccessControl'].present:
|
| - request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| - result = client.objectAccessControls.Update(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Delete."""
|
| -
|
| - usage = """buckets_delete <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketsDelete, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u'If set, only deletes the bucket if its metageneration matches this '
|
| - u'value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u'If set, only deletes the bucket if its metageneration does not '
|
| - u'match this value.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Permanently deletes an empty bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| -
|
| - Flags:
|
| - ifMetagenerationMatch: If set, only deletes the bucket if its
|
| - metageneration matches this value.
|
| - ifMetagenerationNotMatch: If set, only deletes the bucket if its
|
| - metageneration does not match this value.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsDeleteRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - result = client.buckets.Delete(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Get."""
|
| -
|
| - usage = """buckets_get <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketsGet, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration matches the given value.",
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration does not match the given value.",
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Returns metadata for the specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| -
|
| - Flags:
|
| - ifMetagenerationMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration matches the
|
| - given value.
|
| - ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration does not
|
| - match the given value.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsGetRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Get(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Insert."""
|
| -
|
| - usage = """buckets_insert <project>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketsInsert, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'bucket',
|
| - None,
|
| - u'A Bucket resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| - u'Apply a predefined set of access controls to this bucket.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedDefaultObjectAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of default object access controls to this '
|
| - u'bucket.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl, unless the bucket '
|
| - u'resource specifies acl or defaultObjectAcl properties, when it '
|
| - u'defaults to full.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, project):
|
| - """Creates a new bucket.
|
| -
|
| - Args:
|
| - project: A valid API project identifier.
|
| -
|
| - Flags:
|
| - bucket: A Bucket resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| - predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| - access controls to this bucket.
|
| - projection: Set of properties to return. Defaults to noAcl, unless the
|
| - bucket resource specifies acl or defaultObjectAcl properties, when it
|
| - defaults to full.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsInsertRequest(
|
| - project=project.decode('utf8'),
|
| - )
|
| - if FLAGS['bucket'].present:
|
| - request.bucket = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucket)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageBucketsInsertRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['predefinedDefaultObjectAcl'].present:
|
| - request.predefinedDefaultObjectAcl = messages.StorageBucketsInsertRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsInsertRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Insert(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.List."""
|
| -
|
| - usage = """buckets_list <project>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketsList, self).__init__(name, fv)
|
| - flags.DEFINE_integer(
|
| - 'maxResults',
|
| - None,
|
| - u'Maximum number of buckets to return.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'pageToken',
|
| - None,
|
| - u'A previously-returned page token representing part of the larger '
|
| - u'set of results to view.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'prefix',
|
| - None,
|
| - u'Filter results to buckets whose names begin with this prefix.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, project):
|
| - """Retrieves a list of buckets for a given project.
|
| -
|
| - Args:
|
| - project: A valid API project identifier.
|
| -
|
| - Flags:
|
| - maxResults: Maximum number of buckets to return.
|
| - pageToken: A previously-returned page token representing part of the
|
| - larger set of results to view.
|
| - prefix: Filter results to buckets whose names begin with this prefix.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsListRequest(
|
| - project=project.decode('utf8'),
|
| - )
|
| - if FLAGS['maxResults'].present:
|
| - request.maxResults = FLAGS.maxResults
|
| - if FLAGS['pageToken'].present:
|
| - request.pageToken = FLAGS.pageToken.decode('utf8')
|
| - if FLAGS['prefix'].present:
|
| - request.prefix = FLAGS.prefix.decode('utf8')
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.List(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Patch."""
|
| -
|
| - usage = """buckets_patch <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketsPatch, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'bucketResource',
|
| - None,
|
| - u'A Bucket resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration matches the given value.",
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration does not match the given value.",
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| - u'Apply a predefined set of access controls to this bucket.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedDefaultObjectAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of default object access controls to this '
|
| - u'bucket.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Updates a bucket. This method supports patch semantics.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| -
|
| - Flags:
|
| - bucketResource: A Bucket resource to be passed as the request body.
|
| - ifMetagenerationMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration matches the
|
| - given value.
|
| - ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration does not
|
| - match the given value.
|
| - predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| - predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| - access controls to this bucket.
|
| - projection: Set of properties to return. Defaults to full.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsPatchRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['bucketResource'].present:
|
| - request.bucketResource = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucketResource)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageBucketsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['predefinedDefaultObjectAcl'].present:
|
| - request.predefinedDefaultObjectAcl = messages.StorageBucketsPatchRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Patch(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Update."""
|
| -
|
| - usage = """buckets_update <bucket>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketsUpdate, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'bucketResource',
|
| - None,
|
| - u'A Bucket resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration matches the given value.",
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration does not match the given value.",
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| - u'Apply a predefined set of access controls to this bucket.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedDefaultObjectAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of default object access controls to this '
|
| - u'bucket.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| - flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket):
|
| - """Updates a bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| -
|
| - Flags:
|
| - bucketResource: A Bucket resource to be passed as the request body.
|
| - ifMetagenerationMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration matches the
|
| - given value.
|
| - ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration does not
|
| - match the given value.
|
| - predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| - predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| - access controls to this bucket.
|
| - projection: Set of properties to return. Defaults to full.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsUpdateRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - )
|
| - if FLAGS['bucketResource'].present:
|
| - request.bucketResource = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucketResource)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageBucketsUpdateRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['predefinedDefaultObjectAcl'].present:
|
| - request.predefinedDefaultObjectAcl = messages.StorageBucketsUpdateRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsUpdateRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Update(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -def main(_):
|
| - appcommands.AddCmd('pyshell', PyShell)
|
| - appcommands.AddCmd('defaultObjectAccessControls_delete', DefaultObjectAccessControlsDelete)
|
| - appcommands.AddCmd('defaultObjectAccessControls_get', DefaultObjectAccessControlsGet)
|
| - appcommands.AddCmd('defaultObjectAccessControls_insert', DefaultObjectAccessControlsInsert)
|
| - appcommands.AddCmd('defaultObjectAccessControls_list', DefaultObjectAccessControlsList)
|
| - appcommands.AddCmd('defaultObjectAccessControls_patch', DefaultObjectAccessControlsPatch)
|
| - appcommands.AddCmd('defaultObjectAccessControls_update', DefaultObjectAccessControlsUpdate)
|
| - appcommands.AddCmd('bucketAccessControls_delete', BucketAccessControlsDelete)
|
| - appcommands.AddCmd('bucketAccessControls_get', BucketAccessControlsGet)
|
| - appcommands.AddCmd('bucketAccessControls_insert', BucketAccessControlsInsert)
|
| - appcommands.AddCmd('bucketAccessControls_list', BucketAccessControlsList)
|
| - appcommands.AddCmd('bucketAccessControls_patch', BucketAccessControlsPatch)
|
| - appcommands.AddCmd('bucketAccessControls_update', BucketAccessControlsUpdate)
|
| - appcommands.AddCmd('channels_stop', ChannelsStop)
|
| - appcommands.AddCmd('objects_compose', ObjectsCompose)
|
| - appcommands.AddCmd('objects_copy', ObjectsCopy)
|
| - appcommands.AddCmd('objects_delete', ObjectsDelete)
|
| - appcommands.AddCmd('objects_get', ObjectsGet)
|
| - appcommands.AddCmd('objects_insert', ObjectsInsert)
|
| - appcommands.AddCmd('objects_list', ObjectsList)
|
| - appcommands.AddCmd('objects_patch', ObjectsPatch)
|
| - appcommands.AddCmd('objects_update', ObjectsUpdate)
|
| - appcommands.AddCmd('objects_watchAll', ObjectsWatchAll)
|
| - appcommands.AddCmd('objectAccessControls_delete', ObjectAccessControlsDelete)
|
| - appcommands.AddCmd('objectAccessControls_get', ObjectAccessControlsGet)
|
| - appcommands.AddCmd('objectAccessControls_insert', ObjectAccessControlsInsert)
|
| - appcommands.AddCmd('objectAccessControls_list', ObjectAccessControlsList)
|
| - appcommands.AddCmd('objectAccessControls_patch', ObjectAccessControlsPatch)
|
| - appcommands.AddCmd('objectAccessControls_update', ObjectAccessControlsUpdate)
|
| - appcommands.AddCmd('buckets_delete', BucketsDelete)
|
| - appcommands.AddCmd('buckets_get', BucketsGet)
|
| - appcommands.AddCmd('buckets_insert', BucketsInsert)
|
| - appcommands.AddCmd('buckets_list', BucketsList)
|
| - appcommands.AddCmd('buckets_patch', BucketsPatch)
|
| - appcommands.AddCmd('buckets_update', BucketsUpdate)
|
| -
|
| - apitools_base_cli.SetupLogger()
|
| - if hasattr(appcommands, 'SetDefaultCommand'):
|
| - appcommands.SetDefaultCommand('pyshell')
|
| -
|
| -
|
| -run_main = apitools_base_cli.run_main
|
| -
|
| -if __name__ == '__main__':
|
| - appcommands.Run()
|
|
|
Chromium Code Reviews
Issue 1260493004:
Revert "Add gsutil 4.13 to telemetry/third_party" (Closed)
Base URL: https://chromium.googlesource.com/chromium/src.git@master