diff options
Diffstat (limited to 'docker/api/buildkit/filesync')
| -rw-r--r-- | docker/api/buildkit/filesync/filesync.proto | 20 | ||||
| -rw-r--r-- | docker/api/buildkit/filesync/filesync.py | 22 | ||||
| -rw-r--r-- | docker/api/buildkit/filesync/filesync_grpc.py | 81 | ||||
| -rw-r--r-- | docker/api/buildkit/filesync/filesync_pb2.py | 127 |
4 files changed, 250 insertions, 0 deletions
diff --git a/docker/api/buildkit/filesync/filesync.proto b/docker/api/buildkit/filesync/filesync.proto new file mode 100644 index 0000000..327a043 --- /dev/null +++ b/docker/api/buildkit/filesync/filesync.proto @@ -0,0 +1,20 @@ +syntax = "proto3"; + +package moby.filesync.v1; + +option go_package = "filesync"; + +service FileSync{ + rpc DiffCopy(stream BytesMessage) returns (stream BytesMessage); + rpc TarStream(stream BytesMessage) returns (stream BytesMessage); +} + +service FileSend{ + rpc DiffCopy(stream BytesMessage) returns (stream BytesMessage); +} + + +// BytesMessage contains a chunk of byte data +message BytesMessage{ + bytes data = 1; +}
\ No newline at end of file diff --git a/docker/api/buildkit/filesync/filesync.py b/docker/api/buildkit/filesync/filesync.py new file mode 100644 index 0000000..cf33cba --- /dev/null +++ b/docker/api/buildkit/filesync/filesync.py @@ -0,0 +1,22 @@ +from .filesync_pb2 import BytesMessage +from .filesync_grpc import FileSendBase, FileSyncBase +from ..grpc import Attachable + + +class FileSync(FileSyncBase, Attachable): + def __init__(self, *args, **kwargs): + super(FileSync, self).__init__(*args, **kwargs) + + async def DiffCopy(self, stream): + pass + + async def TarStream(self, stream): + pass + + +class FileSend(FileSendBase, Attachable): + def __init__(self, *args, **kwargs): + super(FileSync, self).__init__(*args, **kwargs) + + async def DiffCopy(self, stream): + pass diff --git a/docker/api/buildkit/filesync/filesync_grpc.py b/docker/api/buildkit/filesync/filesync_grpc.py new file mode 100644 index 0000000..7405754 --- /dev/null +++ b/docker/api/buildkit/filesync/filesync_grpc.py @@ -0,0 +1,81 @@ +# Generated by the Protocol Buffers compiler. DO NOT EDIT! +# source: filesync.proto +# plugin: grpclib.plugin.main +import abc + +import grpclib.const +import grpclib.client + +import filesync_pb2 + + +class FileSyncBase(abc.ABC): + + @abc.abstractmethod + async def DiffCopy(self, stream): + pass + + @abc.abstractmethod + async def TarStream(self, stream): + pass + + def __mapping__(self): + return { + '/moby.filesync.v1.FileSync/DiffCopy': grpclib.const.Handler( + self.DiffCopy, + grpclib.const.Cardinality.STREAM_STREAM, + filesync_pb2.BytesMessage, + filesync_pb2.BytesMessage, + ), + '/moby.filesync.v1.FileSync/TarStream': grpclib.const.Handler( + self.TarStream, + grpclib.const.Cardinality.STREAM_STREAM, + filesync_pb2.BytesMessage, + filesync_pb2.BytesMessage, + ), + } + + +class FileSyncStub: + + def __init__(self, channel: grpclib.client.Channel) -> None: + self.DiffCopy = grpclib.client.StreamStreamMethod( + channel, + '/moby.filesync.v1.FileSync/DiffCopy', + filesync_pb2.BytesMessage, + filesync_pb2.BytesMessage, + ) + self.TarStream = grpclib.client.StreamStreamMethod( + channel, + '/moby.filesync.v1.FileSync/TarStream', + filesync_pb2.BytesMessage, + filesync_pb2.BytesMessage, + ) + + +class FileSendBase(abc.ABC): + + @abc.abstractmethod + async def DiffCopy(self, stream): + pass + + def __mapping__(self): + return { + '/moby.filesync.v1.FileSend/DiffCopy': grpclib.const.Handler( + self.DiffCopy, + grpclib.const.Cardinality.STREAM_STREAM, + filesync_pb2.BytesMessage, + filesync_pb2.BytesMessage, + ), + } + + +class FileSendStub: + + def __init__(self, channel: grpclib.client.Channel) -> None: + self.DiffCopy = grpclib.client.StreamStreamMethod( + channel, + '/moby.filesync.v1.FileSend/DiffCopy', + filesync_pb2.BytesMessage, + filesync_pb2.BytesMessage, + ) diff --git a/docker/api/buildkit/filesync/filesync_pb2.py b/docker/api/buildkit/filesync/filesync_pb2.py new file mode 100644 index 0000000..136c5b1 --- /dev/null +++ b/docker/api/buildkit/filesync/filesync_pb2.py @@ -0,0 +1,127 @@ +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: filesync.proto + +import sys +_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1')) +from google.protobuf import descriptor as _descriptor +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection +from google.protobuf import symbol_database as _symbol_database +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + + + +DESCRIPTOR = _descriptor.FileDescriptor( + name='filesync.proto', + package='moby.filesync.v1', + syntax='proto3', + serialized_options=_b('Z\010filesync'), + serialized_pb=_b('\n\x0e\x66ilesync.proto\x12\x10moby.filesync.v1\"\x1c\n\x0c\x42ytesMessage\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x32\xab\x01\n\x08\x46ileSync\x12N\n\x08\x44iffCopy\x12\x1e.moby.filesync.v1.BytesMessage\x1a\x1e.moby.filesync.v1.BytesMessage(\x01\x30\x01\x12O\n\tTarStream\x12\x1e.moby.filesync.v1.BytesMessage\x1a\x1e.moby.filesync.v1.BytesMessage(\x01\x30\x01\x32Z\n\x08\x46ileSend\x12N\n\x08\x44iffCopy\x12\x1e.moby.filesync.v1.BytesMessage\x1a\x1e.moby.filesync.v1.BytesMessage(\x01\x30\x01\x42\nZ\x08\x66ilesyncb\x06proto3') +) + + + + +_BYTESMESSAGE = _descriptor.Descriptor( + name='BytesMessage', + full_name='moby.filesync.v1.BytesMessage', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='data', full_name='moby.filesync.v1.BytesMessage.data', index=0, + number=1, type=12, cpp_type=9, label=1, + has_default_value=False, default_value=_b(""), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=36, + serialized_end=64, +) + +DESCRIPTOR.message_types_by_name['BytesMessage'] = _BYTESMESSAGE +_sym_db.RegisterFileDescriptor(DESCRIPTOR) + +BytesMessage = _reflection.GeneratedProtocolMessageType('BytesMessage', (_message.Message,), dict( + DESCRIPTOR = _BYTESMESSAGE, + __module__ = 'filesync_pb2' + # @@protoc_insertion_point(class_scope:moby.filesync.v1.BytesMessage) + )) +_sym_db.RegisterMessage(BytesMessage) + + +DESCRIPTOR._options = None + +_FILESYNC = _descriptor.ServiceDescriptor( + name='FileSync', + full_name='moby.filesync.v1.FileSync', + file=DESCRIPTOR, + index=0, + serialized_options=None, + serialized_start=67, + serialized_end=238, + methods=[ + _descriptor.MethodDescriptor( + name='DiffCopy', + full_name='moby.filesync.v1.FileSync.DiffCopy', + index=0, + containing_service=None, + input_type=_BYTESMESSAGE, + output_type=_BYTESMESSAGE, + serialized_options=None, + ), + _descriptor.MethodDescriptor( + name='TarStream', + full_name='moby.filesync.v1.FileSync.TarStream', + index=1, + containing_service=None, + input_type=_BYTESMESSAGE, + output_type=_BYTESMESSAGE, + serialized_options=None, + ), +]) +_sym_db.RegisterServiceDescriptor(_FILESYNC) + +DESCRIPTOR.services_by_name['FileSync'] = _FILESYNC + + +_FILESEND = _descriptor.ServiceDescriptor( + name='FileSend', + full_name='moby.filesync.v1.FileSend', + file=DESCRIPTOR, + index=1, + serialized_options=None, + serialized_start=240, + serialized_end=330, + methods=[ + _descriptor.MethodDescriptor( + name='DiffCopy', + full_name='moby.filesync.v1.FileSend.DiffCopy', + index=0, + containing_service=None, + input_type=_BYTESMESSAGE, + output_type=_BYTESMESSAGE, + serialized_options=None, + ), +]) +_sym_db.RegisterServiceDescriptor(_FILESEND) + +DESCRIPTOR.services_by_name['FileSend'] = _FILESEND + +# @@protoc_insertion_point(module_scope) |