buildgrid.server.logstream.instance module

class buildgrid.server.logstream.instance.LogStreamByteStreamInstance(storage: buildgrid.server.logstream.streaming.memory.StreamStorage)

Bases: object

read(resource_name: str)
write(resource_name: str, request: google.bytestream.bytestream_pb2.WriteRequest, requests: List[google.bytestream.bytestream_pb2.WriteRequest]) → google.bytestream.bytestream_pb2.WriteResponse
disconnect_reader(resource_name)
class buildgrid.server.logstream.instance.LogStreamInstance(prefix: str, storage: Optional[buildgrid.server.logstream.streaming.memory.StreamStorage] = None)

Bases: object

register_instance_with_server(instance_name: str, server: Server) → None
create_logstream(parent: str) → google.devtools.logstream.v1alpha1.logstream_pb2.LogStream