Packages
snakepit
0.6.2
0.13.0
0.12.0
0.11.1
0.11.0
0.10.1
0.10.0
0.9.1
0.9.0
0.8.9
0.8.8
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.11
0.6.10
0.6.9
0.6.8
0.6.7
0.6.6
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
0.4.0
0.3.3
0.3.2
0.3.1
0.3.0
0.2.1
0.2.0
0.1.2
0.1.1
0.1.0
High-performance pooler and session manager for external language integrations. Supports Python, Node.js, Ruby, and more with gRPC streaming, session management, and production-ready process cleanup.
Current section
Files
Jump to
Current section
Files
priv/python/snakepit_bridge_pb2_grpc.py
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
import snakepit_bridge_pb2 as snakepit__bridge__pb2
GRPC_GENERATED_VERSION = '1.73.1'
GRPC_VERSION = grpc.__version__
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
raise RuntimeError(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in snakepit_bridge_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
)
class BridgeServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Ping = channel.unary_unary(
'/snakepit.bridge.BridgeService/Ping',
request_serializer=snakepit__bridge__pb2.PingRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.PingResponse.FromString,
_registered_method=True)
self.InitializeSession = channel.unary_unary(
'/snakepit.bridge.BridgeService/InitializeSession',
request_serializer=snakepit__bridge__pb2.InitializeSessionRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.InitializeSessionResponse.FromString,
_registered_method=True)
self.CleanupSession = channel.unary_unary(
'/snakepit.bridge.BridgeService/CleanupSession',
request_serializer=snakepit__bridge__pb2.CleanupSessionRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.CleanupSessionResponse.FromString,
_registered_method=True)
self.GetSession = channel.unary_unary(
'/snakepit.bridge.BridgeService/GetSession',
request_serializer=snakepit__bridge__pb2.GetSessionRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.GetSessionResponse.FromString,
_registered_method=True)
self.Heartbeat = channel.unary_unary(
'/snakepit.bridge.BridgeService/Heartbeat',
request_serializer=snakepit__bridge__pb2.HeartbeatRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.HeartbeatResponse.FromString,
_registered_method=True)
self.GetVariable = channel.unary_unary(
'/snakepit.bridge.BridgeService/GetVariable',
request_serializer=snakepit__bridge__pb2.GetVariableRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.GetVariableResponse.FromString,
_registered_method=True)
self.SetVariable = channel.unary_unary(
'/snakepit.bridge.BridgeService/SetVariable',
request_serializer=snakepit__bridge__pb2.SetVariableRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.SetVariableResponse.FromString,
_registered_method=True)
self.GetVariables = channel.unary_unary(
'/snakepit.bridge.BridgeService/GetVariables',
request_serializer=snakepit__bridge__pb2.BatchGetVariablesRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.BatchGetVariablesResponse.FromString,
_registered_method=True)
self.SetVariables = channel.unary_unary(
'/snakepit.bridge.BridgeService/SetVariables',
request_serializer=snakepit__bridge__pb2.BatchSetVariablesRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.BatchSetVariablesResponse.FromString,
_registered_method=True)
self.RegisterVariable = channel.unary_unary(
'/snakepit.bridge.BridgeService/RegisterVariable',
request_serializer=snakepit__bridge__pb2.RegisterVariableRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.RegisterVariableResponse.FromString,
_registered_method=True)
self.ListVariables = channel.unary_unary(
'/snakepit.bridge.BridgeService/ListVariables',
request_serializer=snakepit__bridge__pb2.ListVariablesRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.ListVariablesResponse.FromString,
_registered_method=True)
self.DeleteVariable = channel.unary_unary(
'/snakepit.bridge.BridgeService/DeleteVariable',
request_serializer=snakepit__bridge__pb2.DeleteVariableRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.DeleteVariableResponse.FromString,
_registered_method=True)
self.ExecuteTool = channel.unary_unary(
'/snakepit.bridge.BridgeService/ExecuteTool',
request_serializer=snakepit__bridge__pb2.ExecuteToolRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.ExecuteToolResponse.FromString,
_registered_method=True)
self.ExecuteStreamingTool = channel.unary_stream(
'/snakepit.bridge.BridgeService/ExecuteStreamingTool',
request_serializer=snakepit__bridge__pb2.ExecuteToolRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.ToolChunk.FromString,
_registered_method=True)
self.RegisterTools = channel.unary_unary(
'/snakepit.bridge.BridgeService/RegisterTools',
request_serializer=snakepit__bridge__pb2.RegisterToolsRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.RegisterToolsResponse.FromString,
_registered_method=True)
self.GetExposedElixirTools = channel.unary_unary(
'/snakepit.bridge.BridgeService/GetExposedElixirTools',
request_serializer=snakepit__bridge__pb2.GetExposedElixirToolsRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.GetExposedElixirToolsResponse.FromString,
_registered_method=True)
self.ExecuteElixirTool = channel.unary_unary(
'/snakepit.bridge.BridgeService/ExecuteElixirTool',
request_serializer=snakepit__bridge__pb2.ExecuteElixirToolRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.ExecuteElixirToolResponse.FromString,
_registered_method=True)
self.WatchVariables = channel.unary_stream(
'/snakepit.bridge.BridgeService/WatchVariables',
request_serializer=snakepit__bridge__pb2.WatchVariablesRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.VariableUpdate.FromString,
_registered_method=True)
self.AddDependency = channel.unary_unary(
'/snakepit.bridge.BridgeService/AddDependency',
request_serializer=snakepit__bridge__pb2.AddDependencyRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.AddDependencyResponse.FromString,
_registered_method=True)
self.StartOptimization = channel.unary_unary(
'/snakepit.bridge.BridgeService/StartOptimization',
request_serializer=snakepit__bridge__pb2.StartOptimizationRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.StartOptimizationResponse.FromString,
_registered_method=True)
self.StopOptimization = channel.unary_unary(
'/snakepit.bridge.BridgeService/StopOptimization',
request_serializer=snakepit__bridge__pb2.StopOptimizationRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.StopOptimizationResponse.FromString,
_registered_method=True)
self.GetVariableHistory = channel.unary_unary(
'/snakepit.bridge.BridgeService/GetVariableHistory',
request_serializer=snakepit__bridge__pb2.GetVariableHistoryRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.GetVariableHistoryResponse.FromString,
_registered_method=True)
self.RollbackVariable = channel.unary_unary(
'/snakepit.bridge.BridgeService/RollbackVariable',
request_serializer=snakepit__bridge__pb2.RollbackVariableRequest.SerializeToString,
response_deserializer=snakepit__bridge__pb2.RollbackVariableResponse.FromString,
_registered_method=True)
class BridgeServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
def Ping(self, request, context):
"""Health & Session Management
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def InitializeSession(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def CleanupSession(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetSession(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Heartbeat(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetVariable(self, request, context):
"""Variable Operations
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def SetVariable(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetVariables(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def SetVariables(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def RegisterVariable(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListVariables(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def DeleteVariable(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ExecuteTool(self, request, context):
"""Tool Execution
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ExecuteStreamingTool(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def RegisterTools(self, request, context):
"""Tool Registration & Discovery
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetExposedElixirTools(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ExecuteElixirTool(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def WatchVariables(self, request, context):
"""Streaming & Reactive
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AddDependency(self, request, context):
"""Advanced Features (Stage 4)
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def StartOptimization(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def StopOptimization(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetVariableHistory(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def RollbackVariable(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def add_BridgeServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'Ping': grpc.unary_unary_rpc_method_handler(
servicer.Ping,
request_deserializer=snakepit__bridge__pb2.PingRequest.FromString,
response_serializer=snakepit__bridge__pb2.PingResponse.SerializeToString,
),
'InitializeSession': grpc.unary_unary_rpc_method_handler(
servicer.InitializeSession,
request_deserializer=snakepit__bridge__pb2.InitializeSessionRequest.FromString,
response_serializer=snakepit__bridge__pb2.InitializeSessionResponse.SerializeToString,
),
'CleanupSession': grpc.unary_unary_rpc_method_handler(
servicer.CleanupSession,
request_deserializer=snakepit__bridge__pb2.CleanupSessionRequest.FromString,
response_serializer=snakepit__bridge__pb2.CleanupSessionResponse.SerializeToString,
),
'GetSession': grpc.unary_unary_rpc_method_handler(
servicer.GetSession,
request_deserializer=snakepit__bridge__pb2.GetSessionRequest.FromString,
response_serializer=snakepit__bridge__pb2.GetSessionResponse.SerializeToString,
),
'Heartbeat': grpc.unary_unary_rpc_method_handler(
servicer.Heartbeat,
request_deserializer=snakepit__bridge__pb2.HeartbeatRequest.FromString,
response_serializer=snakepit__bridge__pb2.HeartbeatResponse.SerializeToString,
),
'GetVariable': grpc.unary_unary_rpc_method_handler(
servicer.GetVariable,
request_deserializer=snakepit__bridge__pb2.GetVariableRequest.FromString,
response_serializer=snakepit__bridge__pb2.GetVariableResponse.SerializeToString,
),
'SetVariable': grpc.unary_unary_rpc_method_handler(
servicer.SetVariable,
request_deserializer=snakepit__bridge__pb2.SetVariableRequest.FromString,
response_serializer=snakepit__bridge__pb2.SetVariableResponse.SerializeToString,
),
'GetVariables': grpc.unary_unary_rpc_method_handler(
servicer.GetVariables,
request_deserializer=snakepit__bridge__pb2.BatchGetVariablesRequest.FromString,
response_serializer=snakepit__bridge__pb2.BatchGetVariablesResponse.SerializeToString,
),
'SetVariables': grpc.unary_unary_rpc_method_handler(
servicer.SetVariables,
request_deserializer=snakepit__bridge__pb2.BatchSetVariablesRequest.FromString,
response_serializer=snakepit__bridge__pb2.BatchSetVariablesResponse.SerializeToString,
),
'RegisterVariable': grpc.unary_unary_rpc_method_handler(
servicer.RegisterVariable,
request_deserializer=snakepit__bridge__pb2.RegisterVariableRequest.FromString,
response_serializer=snakepit__bridge__pb2.RegisterVariableResponse.SerializeToString,
),
'ListVariables': grpc.unary_unary_rpc_method_handler(
servicer.ListVariables,
request_deserializer=snakepit__bridge__pb2.ListVariablesRequest.FromString,
response_serializer=snakepit__bridge__pb2.ListVariablesResponse.SerializeToString,
),
'DeleteVariable': grpc.unary_unary_rpc_method_handler(
servicer.DeleteVariable,
request_deserializer=snakepit__bridge__pb2.DeleteVariableRequest.FromString,
response_serializer=snakepit__bridge__pb2.DeleteVariableResponse.SerializeToString,
),
'ExecuteTool': grpc.unary_unary_rpc_method_handler(
servicer.ExecuteTool,
request_deserializer=snakepit__bridge__pb2.ExecuteToolRequest.FromString,
response_serializer=snakepit__bridge__pb2.ExecuteToolResponse.SerializeToString,
),
'ExecuteStreamingTool': grpc.unary_stream_rpc_method_handler(
servicer.ExecuteStreamingTool,
request_deserializer=snakepit__bridge__pb2.ExecuteToolRequest.FromString,
response_serializer=snakepit__bridge__pb2.ToolChunk.SerializeToString,
),
'RegisterTools': grpc.unary_unary_rpc_method_handler(
servicer.RegisterTools,
request_deserializer=snakepit__bridge__pb2.RegisterToolsRequest.FromString,
response_serializer=snakepit__bridge__pb2.RegisterToolsResponse.SerializeToString,
),
'GetExposedElixirTools': grpc.unary_unary_rpc_method_handler(
servicer.GetExposedElixirTools,
request_deserializer=snakepit__bridge__pb2.GetExposedElixirToolsRequest.FromString,
response_serializer=snakepit__bridge__pb2.GetExposedElixirToolsResponse.SerializeToString,
),
'ExecuteElixirTool': grpc.unary_unary_rpc_method_handler(
servicer.ExecuteElixirTool,
request_deserializer=snakepit__bridge__pb2.ExecuteElixirToolRequest.FromString,
response_serializer=snakepit__bridge__pb2.ExecuteElixirToolResponse.SerializeToString,
),
'WatchVariables': grpc.unary_stream_rpc_method_handler(
servicer.WatchVariables,
request_deserializer=snakepit__bridge__pb2.WatchVariablesRequest.FromString,
response_serializer=snakepit__bridge__pb2.VariableUpdate.SerializeToString,
),
'AddDependency': grpc.unary_unary_rpc_method_handler(
servicer.AddDependency,
request_deserializer=snakepit__bridge__pb2.AddDependencyRequest.FromString,
response_serializer=snakepit__bridge__pb2.AddDependencyResponse.SerializeToString,
),
'StartOptimization': grpc.unary_unary_rpc_method_handler(
servicer.StartOptimization,
request_deserializer=snakepit__bridge__pb2.StartOptimizationRequest.FromString,
response_serializer=snakepit__bridge__pb2.StartOptimizationResponse.SerializeToString,
),
'StopOptimization': grpc.unary_unary_rpc_method_handler(
servicer.StopOptimization,
request_deserializer=snakepit__bridge__pb2.StopOptimizationRequest.FromString,
response_serializer=snakepit__bridge__pb2.StopOptimizationResponse.SerializeToString,
),
'GetVariableHistory': grpc.unary_unary_rpc_method_handler(
servicer.GetVariableHistory,
request_deserializer=snakepit__bridge__pb2.GetVariableHistoryRequest.FromString,
response_serializer=snakepit__bridge__pb2.GetVariableHistoryResponse.SerializeToString,
),
'RollbackVariable': grpc.unary_unary_rpc_method_handler(
servicer.RollbackVariable,
request_deserializer=snakepit__bridge__pb2.RollbackVariableRequest.FromString,
response_serializer=snakepit__bridge__pb2.RollbackVariableResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'snakepit.bridge.BridgeService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('snakepit.bridge.BridgeService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
class BridgeService(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Ping(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/Ping',
snakepit__bridge__pb2.PingRequest.SerializeToString,
snakepit__bridge__pb2.PingResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def InitializeSession(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/InitializeSession',
snakepit__bridge__pb2.InitializeSessionRequest.SerializeToString,
snakepit__bridge__pb2.InitializeSessionResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def CleanupSession(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/CleanupSession',
snakepit__bridge__pb2.CleanupSessionRequest.SerializeToString,
snakepit__bridge__pb2.CleanupSessionResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetSession(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/GetSession',
snakepit__bridge__pb2.GetSessionRequest.SerializeToString,
snakepit__bridge__pb2.GetSessionResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Heartbeat(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/Heartbeat',
snakepit__bridge__pb2.HeartbeatRequest.SerializeToString,
snakepit__bridge__pb2.HeartbeatResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetVariable(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/GetVariable',
snakepit__bridge__pb2.GetVariableRequest.SerializeToString,
snakepit__bridge__pb2.GetVariableResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def SetVariable(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/SetVariable',
snakepit__bridge__pb2.SetVariableRequest.SerializeToString,
snakepit__bridge__pb2.SetVariableResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetVariables(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/GetVariables',
snakepit__bridge__pb2.BatchGetVariablesRequest.SerializeToString,
snakepit__bridge__pb2.BatchGetVariablesResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def SetVariables(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/SetVariables',
snakepit__bridge__pb2.BatchSetVariablesRequest.SerializeToString,
snakepit__bridge__pb2.BatchSetVariablesResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def RegisterVariable(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/RegisterVariable',
snakepit__bridge__pb2.RegisterVariableRequest.SerializeToString,
snakepit__bridge__pb2.RegisterVariableResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def ListVariables(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/ListVariables',
snakepit__bridge__pb2.ListVariablesRequest.SerializeToString,
snakepit__bridge__pb2.ListVariablesResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def DeleteVariable(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/DeleteVariable',
snakepit__bridge__pb2.DeleteVariableRequest.SerializeToString,
snakepit__bridge__pb2.DeleteVariableResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def ExecuteTool(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/ExecuteTool',
snakepit__bridge__pb2.ExecuteToolRequest.SerializeToString,
snakepit__bridge__pb2.ExecuteToolResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def ExecuteStreamingTool(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_stream(
request,
target,
'/snakepit.bridge.BridgeService/ExecuteStreamingTool',
snakepit__bridge__pb2.ExecuteToolRequest.SerializeToString,
snakepit__bridge__pb2.ToolChunk.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def RegisterTools(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/RegisterTools',
snakepit__bridge__pb2.RegisterToolsRequest.SerializeToString,
snakepit__bridge__pb2.RegisterToolsResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetExposedElixirTools(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/GetExposedElixirTools',
snakepit__bridge__pb2.GetExposedElixirToolsRequest.SerializeToString,
snakepit__bridge__pb2.GetExposedElixirToolsResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def ExecuteElixirTool(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/ExecuteElixirTool',
snakepit__bridge__pb2.ExecuteElixirToolRequest.SerializeToString,
snakepit__bridge__pb2.ExecuteElixirToolResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def WatchVariables(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_stream(
request,
target,
'/snakepit.bridge.BridgeService/WatchVariables',
snakepit__bridge__pb2.WatchVariablesRequest.SerializeToString,
snakepit__bridge__pb2.VariableUpdate.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def AddDependency(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/AddDependency',
snakepit__bridge__pb2.AddDependencyRequest.SerializeToString,
snakepit__bridge__pb2.AddDependencyResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def StartOptimization(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/StartOptimization',
snakepit__bridge__pb2.StartOptimizationRequest.SerializeToString,
snakepit__bridge__pb2.StartOptimizationResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def StopOptimization(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/StopOptimization',
snakepit__bridge__pb2.StopOptimizationRequest.SerializeToString,
snakepit__bridge__pb2.StopOptimizationResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetVariableHistory(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/GetVariableHistory',
snakepit__bridge__pb2.GetVariableHistoryRequest.SerializeToString,
snakepit__bridge__pb2.GetVariableHistoryResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def RollbackVariable(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(
request,
target,
'/snakepit.bridge.BridgeService/RollbackVariable',
snakepit__bridge__pb2.RollbackVariableRequest.SerializeToString,
snakepit__bridge__pb2.RollbackVariableResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)