Skip to content

Commit

Permalink
feat: [google-cloud-parallelstore] add file_stripe_level and director…
Browse files Browse the repository at this point in the history 
…y_stripe_level fields to Instance (#12970)

- [ ] Regenerate this pull request now.

PiperOrigin-RevId: 658160286

Source-Link:
googleapis/googleapis@24c5ee0

Source-Link:
googleapis/googleapis-gen@6e26922
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXBhcmFsbGVsc3RvcmUvLk93bEJvdC55YW1sIiwiaCI6IjZlMjY5MjI3ODk0ZmNhMzIxMGE0ODIzODVkMTJjZmMxYzRkMTUzMmYifQ==

---------

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] and gcf-owl-bot[bot] authored Aug 1, 2024
1 parent e8c2ca3 commit 17f4b3a
Show file tree
Hide file tree
Showing 8 changed files with 110 additions and 3 deletions.
4 changes: 4 additions & 0 deletions packages/google-cloud-parallelstore/google/cloud/parallelstore/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,9 +29,11 @@
DeleteInstanceRequest,
DestinationGcsBucket,
DestinationParallelstore,
DirectoryStripeLevel,
ExportDataMetadata,
ExportDataRequest,
ExportDataResponse,
FileStripeLevel,
GetInstanceRequest,
ImportDataMetadata,
ImportDataRequest,
Expand Down Expand Up @@ -71,5 +73,7 @@
"TransferCounters",
"TransferOperationMetadata",
"UpdateInstanceRequest",
"DirectoryStripeLevel",
"FileStripeLevel",
"TransferType",
)
2 changes: 1 addition & 1 deletion packages/google-cloud-parallelstore/google/cloud/parallelstore/gapic_version.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
__version__ = "0.2.2" # {x-release-please-version}
__version__ = "0.0.0" # {x-release-please-version}
4 changes: 4 additions & 0 deletions packages/google-cloud-parallelstore/google/cloud/parallelstore_v1beta/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,11 @@
DeleteInstanceRequest,
DestinationGcsBucket,
DestinationParallelstore,
DirectoryStripeLevel,
ExportDataMetadata,
ExportDataRequest,
ExportDataResponse,
FileStripeLevel,
GetInstanceRequest,
ImportDataMetadata,
ImportDataRequest,
Expand All @@ -49,9 +51,11 @@
"DeleteInstanceRequest",
"DestinationGcsBucket",
"DestinationParallelstore",
"DirectoryStripeLevel",
"ExportDataMetadata",
"ExportDataRequest",
"ExportDataResponse",
"FileStripeLevel",
"GetInstanceRequest",
"ImportDataMetadata",
"ImportDataRequest",
Expand Down
2 changes: 1 addition & 1 deletion packages/google-cloud-parallelstore/google/cloud/parallelstore_v1beta/gapic_version.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,4 +13,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
__version__ = "0.2.2" # {x-release-please-version}
__version__ = "0.0.0" # {x-release-please-version}
4 changes: 4 additions & 0 deletions packages/google-cloud-parallelstore/google/cloud/parallelstore_v1beta/types/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,11 @@
DeleteInstanceRequest,
DestinationGcsBucket,
DestinationParallelstore,
DirectoryStripeLevel,
ExportDataMetadata,
ExportDataRequest,
ExportDataResponse,
FileStripeLevel,
GetInstanceRequest,
ImportDataMetadata,
ImportDataRequest,
Expand Down Expand Up @@ -58,5 +60,7 @@
"TransferCounters",
"TransferOperationMetadata",
"UpdateInstanceRequest",
"DirectoryStripeLevel",
"FileStripeLevel",
"TransferType",
)
59 changes: 59 additions & 0 deletions packages/google-cloud-parallelstore/google/cloud/parallelstore_v1beta/types/parallelstore.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
package="google.cloud.parallelstore.v1beta",
manifest={
"TransferType",
"FileStripeLevel",
"DirectoryStripeLevel",
"Instance",
"ListInstancesRequest",
"ListInstancesResponse",
Expand Down Expand Up @@ -65,6 +67,44 @@ class TransferType(proto.Enum):
EXPORT = 2


class FileStripeLevel(proto.Enum):
r"""Represents the striping options for files.
Values:
FILE_STRIPE_LEVEL_UNSPECIFIED (0):
Default file striping
FILE_STRIPE_LEVEL_MIN (1):
Minimum file striping
FILE_STRIPE_LEVEL_BALANCED (2):
Medium file striping
FILE_STRIPE_LEVEL_MAX (3):
Maximum file striping
"""
FILE_STRIPE_LEVEL_UNSPECIFIED = 0
FILE_STRIPE_LEVEL_MIN = 1
FILE_STRIPE_LEVEL_BALANCED = 2
FILE_STRIPE_LEVEL_MAX = 3


class DirectoryStripeLevel(proto.Enum):
r"""Represents the striping options for directories.
Values:
DIRECTORY_STRIPE_LEVEL_UNSPECIFIED (0):
Default directory striping
DIRECTORY_STRIPE_LEVEL_MIN (1):
Minimum directory striping
DIRECTORY_STRIPE_LEVEL_BALANCED (2):
Medium directory striping
DIRECTORY_STRIPE_LEVEL_MAX (3):
Maximum directory striping
"""
DIRECTORY_STRIPE_LEVEL_UNSPECIFIED = 0
DIRECTORY_STRIPE_LEVEL_MIN = 1
DIRECTORY_STRIPE_LEVEL_BALANCED = 2
DIRECTORY_STRIPE_LEVEL_MAX = 3


class Instance(proto.Message):
r"""A Parallelstore instance.
Expand Down Expand Up @@ -141,6 +181,15 @@ class Instance(proto.Message):
10.0.0.0/29. This field is populated by the
service and and contains the value currently
used by the service.
file_stripe_level (google.cloud.parallelstore_v1beta.types.FileStripeLevel):
Optional. Stripe level for files.
MIN better suited for small size files.
MAX higher throughput performance for larger
files.
directory_stripe_level (google.cloud.parallelstore_v1beta.types.DirectoryStripeLevel):
Optional. Stripe level for directories.
MIN when directory has a small number of files.
MAX when directory has a large number of files.
"""

class State(proto.Enum):
Expand Down Expand Up @@ -216,6 +265,16 @@ class State(proto.Enum):
proto.STRING,
number=14,
)
file_stripe_level: "FileStripeLevel" = proto.Field(
proto.ENUM,
number=15,
enum="FileStripeLevel",
)
directory_stripe_level: "DirectoryStripeLevel" = proto.Field(
proto.ENUM,
number=16,
enum="DirectoryStripeLevel",
)


class ListInstancesRequest(proto.Message):
Expand Down
2 changes: 1 addition & 1 deletion ...elstore/samples/generated_samples/snippet_metadata_google.cloud.parallelstore.v1beta.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
],
"language": "PYTHON",
"name": "google-cloud-parallelstore",
"version": "0.2.2"
"version": "0.1.0"
},
"snippets": [
{
Expand Down
36 changes: 36 additions & 0 deletions ...es/google-cloud-parallelstore/tests/unit/gapic/parallelstore_v1beta/test_parallelstore.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1726,6 +1726,8 @@ def test_get_instance(request_type, transport: str = "grpc"):
network="network_value",
reserved_ip_range="reserved_ip_range_value",
effective_reserved_ip_range="effective_reserved_ip_range_value",
file_stripe_level=parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN,
directory_stripe_level=parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN,
)
response = client.get_instance(request)

Expand All @@ -1746,6 +1748,14 @@ def test_get_instance(request_type, transport: str = "grpc"):
assert response.network == "network_value"
assert response.reserved_ip_range == "reserved_ip_range_value"
assert response.effective_reserved_ip_range == "effective_reserved_ip_range_value"
assert (
response.file_stripe_level
== parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN
)
assert (
response.directory_stripe_level
== parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN
)


def test_get_instance_empty_call():
Expand Down Expand Up @@ -1853,6 +1863,8 @@ async def test_get_instance_empty_call_async():
network="network_value",
reserved_ip_range="reserved_ip_range_value",
effective_reserved_ip_range="effective_reserved_ip_range_value",
file_stripe_level=parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN,
directory_stripe_level=parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN,
)
)
response = await client.get_instance()
Expand Down Expand Up @@ -1929,6 +1941,8 @@ async def test_get_instance_async(
network="network_value",
reserved_ip_range="reserved_ip_range_value",
effective_reserved_ip_range="effective_reserved_ip_range_value",
file_stripe_level=parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN,
directory_stripe_level=parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN,
)
)
response = await client.get_instance(request)
Expand All @@ -1950,6 +1964,14 @@ async def test_get_instance_async(
assert response.network == "network_value"
assert response.reserved_ip_range == "reserved_ip_range_value"
assert response.effective_reserved_ip_range == "effective_reserved_ip_range_value"
assert (
response.file_stripe_level
== parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN
)
assert (
response.directory_stripe_level
== parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN
)


@pytest.mark.asyncio
Expand Down Expand Up @@ -4207,6 +4229,8 @@ def test_get_instance_rest(request_type):
network="network_value",
reserved_ip_range="reserved_ip_range_value",
effective_reserved_ip_range="effective_reserved_ip_range_value",
file_stripe_level=parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN,
directory_stripe_level=parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN,
)

# Wrap the value into a proper Response obj
Expand All @@ -4231,6 +4255,14 @@ def test_get_instance_rest(request_type):
assert response.network == "network_value"
assert response.reserved_ip_range == "reserved_ip_range_value"
assert response.effective_reserved_ip_range == "effective_reserved_ip_range_value"
assert (
response.file_stripe_level
== parallelstore.FileStripeLevel.FILE_STRIPE_LEVEL_MIN
)
assert (
response.directory_stripe_level
== parallelstore.DirectoryStripeLevel.DIRECTORY_STRIPE_LEVEL_MIN
)


def test_get_instance_rest_use_cached_wrapped_rpc():
Expand Down Expand Up @@ -4526,6 +4558,8 @@ def test_create_instance_rest(request_type):
"network": "network_value",
"reserved_ip_range": "reserved_ip_range_value",
"effective_reserved_ip_range": "effective_reserved_ip_range_value",
"file_stripe_level": 1,
"directory_stripe_level": 1,
}
# The version of a generated dependency at test runtime may differ from the version used during generation.
# Delete any fields which are not present in the current runtime dependency
Expand Down Expand Up @@ -4947,6 +4981,8 @@ def test_update_instance_rest(request_type):
"network": "network_value",
"reserved_ip_range": "reserved_ip_range_value",
"effective_reserved_ip_range": "effective_reserved_ip_range_value",
"file_stripe_level": 1,
"directory_stripe_level": 1,
}
# The version of a generated dependency at test runtime may differ from the version used during generation.
# Delete any fields which are not present in the current runtime dependency
Expand Down

0 comments on commit 17f4b3a

Please sign in to comment.