aiogremlin.remote package

Submodules

aiogremlin.remote.driver_remote_connection module

class aiogremlin.remote.driver_remote_connection.DriverRemoteConnection(client, loop, *, cluster=None)

Bases: object

Remote connection to a Gremlin Server. Do not instantiate directly, instead use DriverRemoteConnection.open() or DriverRemoteConnection.using()

Parameters

• client (aiogremlin.driver.client.Client) –

• loop (asyncio.BaseEventLoop) –

• cluster (aiogremlin.driver.cluster.Cluster) –

property client

async close()

Close underlying cluster if applicable. If created with DriverRemoteConnection.using(), cluster is NOT closed.

property config

classmethod open(url=None, aliases=None, loop=None, *, graphson_reader=None, graphson_writer=None, **config)

Parameters

• url (str) – Optional url for host Gremlin Server

• aliases (dict) – Optional mapping for aliases. Default is None. Also accepts str argument which will be assigned to g

• loop (asyncio.BaseEventLoop) –

• graphson_reader – Custom graphson_reader

• graphson_writer – Custom graphson_writer

• config – Optional cluster configuration passed as kwargs or dict

async submit(bytecode)

Submit bytecode to the Gremlin Server

classmethod using(cluster, aliases=None)

Create a DriverRemoteConnection using a specific Cluster

Parameters

• cluster (aiogremlin.driver.cluster.Cluster) –

• aliases (dict) – Optional mapping for aliases. Default is None. Also accepts str argument which will be assigned to g

aiogremlin.remote.driver_remote_side_effects module

aiogremlin.remote.remote_connection module

class aiogremlin.remote.remote_connection.AsyncRemoteStrategy(remote_connection)

Bases: gremlin_python.driver.remote_connection.RemoteStrategy

async apply(traversal)

Module contents