Skip to main content

messages_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

Module​

Functions​

add_MessageServiceServicer_to_server​

def add_MessageServiceServicer_to_server(servicer, server):

Classes​

MessageService​

class MessageService():

Missing associated documentation comment in .proto file.

Static methods​

AcknowledgeMessage​

def AcknowledgeMessage(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

GetBitfountMessage​

def GetBitfountMessage(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

GetLargeObjectStorage​

def GetLargeObjectStorage(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

InitiateTask​

def InitiateTask(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

PodConnect​

def PodConnect(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

SendBitfountMessage​

def SendBitfountMessage(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

SetupTask​

def SetupTask(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

SetupTaskMailboxes​

def SetupTaskMailboxes(    request,    target,    options=(),    channel_credentials=None,    call_credentials=None,    insecure=False,    compression=None,    wait_for_ready=None,    timeout=None,    metadata=None,):

MessageServiceServicer​

class MessageServiceServicer():

Missing associated documentation comment in .proto file.

Methods​

AcknowledgeMessage​

def AcknowledgeMessage(self, request, context):

Missing associated documentation comment in .proto file.

GetBitfountMessage​

def GetBitfountMessage(self, request, context):

Missing associated documentation comment in .proto file.

GetLargeObjectStorage​

def GetLargeObjectStorage(self, request, context):

Missing associated documentation comment in .proto file.

InitiateTask​

def InitiateTask(self, request, context):

Missing associated documentation comment in .proto file.

PodConnect​

def PodConnect(self, request, context):

Missing associated documentation comment in .proto file.

SendBitfountMessage​

def SendBitfountMessage(self, request, context):

Missing associated documentation comment in .proto file.

SetupTask​

def SetupTask(self, request, context):

These are part of the newer unified flow where all task requests go via S3.

SetupTaskMailboxes​

def SetupTaskMailboxes(self, request, context):

Missing associated documentation comment in .proto file.

MessageServiceStub​

class MessageServiceStub(channel):

Missing associated documentation comment in .proto file.

Constructor.

Arguments

  • channel: A grpc.Channel.