Skip to content
This repository was archived by the owner on Nov 29, 2023. It is now read-only.
200 changes: 200 additions & 0 deletions google/cloud/dataproc_v1/gapic_metadata.json
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,36 @@
]
}
}
},
"rest": {
"libraryClient": "AutoscalingPolicyServiceClient",
"rpcs": {
"CreateAutoscalingPolicy": {
"methods": [
"create_autoscaling_policy"
]
},
"DeleteAutoscalingPolicy": {
"methods": [
"delete_autoscaling_policy"
]
},
"GetAutoscalingPolicy": {
"methods": [
"get_autoscaling_policy"
]
},
"ListAutoscalingPolicies": {
"methods": [
"list_autoscaling_policies"
]
},
"UpdateAutoscalingPolicy": {
"methods": [
"update_autoscaling_policy"
]
}
}
}
}
},
Expand Down Expand Up @@ -120,6 +150,31 @@
]
}
}
},
"rest": {
"libraryClient": "BatchControllerClient",
"rpcs": {
"CreateBatch": {
"methods": [
"create_batch"
]
},
"DeleteBatch": {
"methods": [
"delete_batch"
]
},
"GetBatch": {
"methods": [
"get_batch"
]
},
"ListBatches": {
"methods": [
"list_batches"
]
}
}
}
}
},
Expand Down Expand Up @@ -214,6 +269,51 @@
]
}
}
},
"rest": {
"libraryClient": "ClusterControllerClient",
"rpcs": {
"CreateCluster": {
"methods": [
"create_cluster"
]
},
"DeleteCluster": {
"methods": [
"delete_cluster"
]
},
"DiagnoseCluster": {
"methods": [
"diagnose_cluster"
]
},
"GetCluster": {
"methods": [
"get_cluster"
]
},
"ListClusters": {
"methods": [
"list_clusters"
]
},
"StartCluster": {
"methods": [
"start_cluster"
]
},
"StopCluster": {
"methods": [
"stop_cluster"
]
},
"UpdateCluster": {
"methods": [
"update_cluster"
]
}
}
}
}
},
Expand Down Expand Up @@ -298,6 +398,46 @@
]
}
}
},
"rest": {
"libraryClient": "JobControllerClient",
"rpcs": {
"CancelJob": {
"methods": [
"cancel_job"
]
},
"DeleteJob": {
"methods": [
"delete_job"
]
},
"GetJob": {
"methods": [
"get_job"
]
},
"ListJobs": {
"methods": [
"list_jobs"
]
},
"SubmitJob": {
"methods": [
"submit_job"
]
},
"SubmitJobAsOperation": {
"methods": [
"submit_job_as_operation"
]
},
"UpdateJob": {
"methods": [
"update_job"
]
}
}
}
}
},
Expand Down Expand Up @@ -342,6 +482,26 @@
]
}
}
},
"rest": {
"libraryClient": "NodeGroupControllerClient",
"rpcs": {
"CreateNodeGroup": {
"methods": [
"create_node_group"
]
},
"GetNodeGroup": {
"methods": [
"get_node_group"
]
},
"ResizeNodeGroup": {
"methods": [
"resize_node_group"
]
}
}
}
}
},
Expand Down Expand Up @@ -426,6 +586,46 @@
]
}
}
},
"rest": {
"libraryClient": "WorkflowTemplateServiceClient",
"rpcs": {
"CreateWorkflowTemplate": {
"methods": [
"create_workflow_template"
]
},
"DeleteWorkflowTemplate": {
"methods": [
"delete_workflow_template"
]
},
"GetWorkflowTemplate": {
"methods": [
"get_workflow_template"
]
},
"InstantiateInlineWorkflowTemplate": {
"methods": [
"instantiate_inline_workflow_template"
]
},
"InstantiateWorkflowTemplate": {
"methods": [
"instantiate_workflow_template"
]
},
"ListWorkflowTemplates": {
"methods": [
"list_workflow_templates"
]
},
"UpdateWorkflowTemplate": {
"methods": [
"update_workflow_template"
]
}
}
}
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,7 @@
from .transports.base import AutoscalingPolicyServiceTransport, DEFAULT_CLIENT_INFO
from .transports.grpc import AutoscalingPolicyServiceGrpcTransport
from .transports.grpc_asyncio import AutoscalingPolicyServiceGrpcAsyncIOTransport
from .transports.rest import AutoscalingPolicyServiceRestTransport


class AutoscalingPolicyServiceClientMeta(type):
Expand All @@ -66,6 +67,7 @@ class AutoscalingPolicyServiceClientMeta(type):
) # type: Dict[str, Type[AutoscalingPolicyServiceTransport]]
_transport_registry["grpc"] = AutoscalingPolicyServiceGrpcTransport
_transport_registry["grpc_asyncio"] = AutoscalingPolicyServiceGrpcAsyncIOTransport
_transport_registry["rest"] = AutoscalingPolicyServiceRestTransport

def get_transport_class(
cls,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,8 @@
from .base import AutoscalingPolicyServiceTransport
from .grpc import AutoscalingPolicyServiceGrpcTransport
from .grpc_asyncio import AutoscalingPolicyServiceGrpcAsyncIOTransport
from .rest import AutoscalingPolicyServiceRestTransport
from .rest import AutoscalingPolicyServiceRestInterceptor


# Compile a registry of transports.
Expand All @@ -27,9 +29,12 @@
) # type: Dict[str, Type[AutoscalingPolicyServiceTransport]]
_transport_registry["grpc"] = AutoscalingPolicyServiceGrpcTransport
_transport_registry["grpc_asyncio"] = AutoscalingPolicyServiceGrpcAsyncIOTransport
_transport_registry["rest"] = AutoscalingPolicyServiceRestTransport

__all__ = (
"AutoscalingPolicyServiceTransport",
"AutoscalingPolicyServiceGrpcTransport",
"AutoscalingPolicyServiceGrpcAsyncIOTransport",
"AutoscalingPolicyServiceRestTransport",
"AutoscalingPolicyServiceRestInterceptor",
)
Loading