aiogremlin.remote package

Submodules

aiogremlin.remote.driver_remote_connection module

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

Bases: object

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

Parameters:
client
close()[source]

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

config
classmethod open(url=None, aliases=None, loop=None, *, graphson_reader=None, graphson_writer=None, **config)[source]
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
submit(bytecode)[source]

Submit bytecode to the Gremlin Server

classmethod using(cluster, aliases=None)[source]

Create a DriverRemoteConnection using a specific Cluster

Parameters:

aiogremlin.remote.driver_remote_side_effects module

class aiogremlin.remote.driver_remote_side_effects.AsyncRemoteTraversalSideEffects(side_effect, client)[source]

Bases: gremlin_python.process.traversal.TraversalSideEffects

close()[source]

Release side effects

get(key)[source]

Get side effects associated with a specific key

keys()[source]

Get side effect keys associated with Traversal

aiogremlin.remote.remote_connection module

class aiogremlin.remote.remote_connection.AsyncRemoteStrategy(remote_connection)[source]

Bases: gremlin_python.driver.remote_connection.RemoteStrategy

apply(traversal)[source]

Module contents