+ LdZddlmZddlmZddlmZddlmZGddZy) z)Cloud Datastream private connections API.)absolute_import)division)unicode_literals)utilc&eZdZdZddZdZddZy) RoutesClientz9Client for private connections routes service in the API.Nc|xstj|_|xstj|_|jj |_tj|_yN) rGetClientInstance_clientGetMessagesModule _messages,projects_locations_privateConnections_routes_serviceGetResourceParser_resource_parser)selfclientmessagess /lib/googlecloudsdk/api_lib/datastream/routes.py__init__zRoutesClient.__init__sN5T335DL9!7!7!9DNLLMMDM 224Dc|jj|i|j|j|j}|S)zReturns a route object.)namelabels displayNamedestinationAddressdestinationPort)rRoute display_namedestination_addressdestination_port)rroute_idargs route_objs r _GetRoutezRoutesClient._GetRoute!sB$$ bd.?.?33--%/I rc|j||}tj}|jj}|||j ||}|j j|S)aCreates a route. Args: parent_ref: a Resource reference to a parent datastream.projects. locations.privateConnections resource for this route. route_id: str, the name of the resource to create. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for creating the private connection. )routerouteIdparent requestId)r&rGenerateRequestIdr@DatastreamProjectsLocationsPrivateConnectionsRoutesCreateRequestrrCreate)r parent_refr#r$r( request_idcreate_req_type create_reqs rr.zRoutesClient.Create)sb NN8T *E'')JnneeO   J ==   ++r)NNr )__name__ __module__ __qualname____doc__rr&r.rrrrsA5 ,rrN)r6 __future__rrr!googlecloudsdk.api_lib.datastreamrrr7rrr:s 0&'2),),r