autogen_ext.runtimes.grpc.protos.agent_worker_pb2_grpc#

Client and server classes corresponding to protobuf-defined services.

class AgentRpcStub(channel)[source]#

Bases: object

Missing associated documentation comment in .proto file.

class AgentRpcServicer[source]#

Bases: object

Missing associated documentation comment in .proto file.

OpenChannel(request_iterator, context)[source]#

Missing associated documentation comment in .proto file.

OpenControlChannel(request_iterator, context)[source]#

Missing associated documentation comment in .proto file.

RegisterAgent(request, context)[source]#

Missing associated documentation comment in .proto file.

AddSubscription(request, context)[source]#

Missing associated documentation comment in .proto file.

RemoveSubscription(request, context)[source]#

Missing associated documentation comment in .proto file.

GetSubscriptions(request, context)[source]#

Missing associated documentation comment in .proto file.

add_AgentRpcServicer_to_server(servicer, server)[source]#
class AgentRpc[source]#

Bases: object

Missing associated documentation comment in .proto file.

static OpenChannel(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
static OpenControlChannel(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
static RegisterAgent(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
static AddSubscription(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
static RemoveSubscription(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
static GetSubscriptions(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#