Versions in this module Expand all Collapse all v1 v1.1.10 Dec 12, 2023 Changes in this version + var ErrIntOverflowFilesync = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthFilesync = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupFilesync = fmt.Errorf("proto: unexpected end of group") + func CopyFileWriter(ctx context.Context, md map[string]string, c session.Caller) (io.WriteCloser, error) + func CopyToCaller(ctx context.Context, fs fsutil.FS, c session.Caller, progress func(int, bool)) error + func FSSync(ctx context.Context, c session.Caller, opt FSSendRequestOpt) error + func NewFSSyncProvider(dirs DirSource) session.Attachable + func NewFSSyncTarget(f func(map[string]string) (io.WriteCloser, error)) session.Attachable + func NewFSSyncTargetDir(outdir string) session.Attachable + func RegisterFileSendServer(s *grpc.Server, srv FileSendServer) + func RegisterFileSyncServer(s *grpc.Server, srv FileSyncServer) + type BytesMessage struct + Data []byte + func (*BytesMessage) Descriptor() ([]byte, []int) + func (*BytesMessage) ProtoMessage() + func (m *BytesMessage) GetData() []byte + func (m *BytesMessage) Marshal() (dAtA []byte, err error) + func (m *BytesMessage) MarshalTo(dAtA []byte) (int, error) + func (m *BytesMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BytesMessage) Reset() + func (m *BytesMessage) Size() (n int) + func (m *BytesMessage) Unmarshal(dAtA []byte) error + func (m *BytesMessage) XXX_DiscardUnknown() + func (m *BytesMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BytesMessage) XXX_Merge(src proto.Message) + func (m *BytesMessage) XXX_Size() int + func (m *BytesMessage) XXX_Unmarshal(b []byte) error + func (this *BytesMessage) Equal(that interface{}) bool + func (this *BytesMessage) GoString() string + func (this *BytesMessage) String() string + type CacheUpdater interface + ContentHasher func() fsutil.ContentHasher + HandleChange func(fsutil.ChangeKind, string, os.FileInfo, error) error + MarkSupported func(bool) + type DirSource interface + LookupDir func(string) (fsutil.FS, bool) + type FSSendRequestOpt struct + CacheUpdater CacheUpdater + DestDir string + Differ fsutil.DiffType + ExcludePatterns []string + Filter func(string, *fstypes.Stat) bool + FollowPaths []string + IncludePatterns []string + Name string + ProgressCb func(int, bool) + type FileSendClient interface + DiffCopy func(ctx context.Context, opts ...grpc.CallOption) (FileSend_DiffCopyClient, error) + func NewFileSendClient(cc *grpc.ClientConn) FileSendClient + type FileSendServer interface + DiffCopy func(FileSend_DiffCopyServer) error + type FileSend_DiffCopyClient interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type FileSend_DiffCopyServer interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type FileSyncClient interface + DiffCopy func(ctx context.Context, opts ...grpc.CallOption) (FileSync_DiffCopyClient, error) + TarStream func(ctx context.Context, opts ...grpc.CallOption) (FileSync_TarStreamClient, error) + func NewFileSyncClient(cc *grpc.ClientConn) FileSyncClient + type FileSyncServer interface + DiffCopy func(FileSync_DiffCopyServer) error + TarStream func(FileSync_TarStreamServer) error + type FileSync_DiffCopyClient interface + Recv func() (*types.Packet, error) + Send func(*types.Packet) error + type FileSync_DiffCopyServer interface + Recv func() (*types.Packet, error) + Send func(*types.Packet) error + type FileSync_TarStreamClient interface + Recv func() (*types.Packet, error) + Send func(*types.Packet) error + type FileSync_TarStreamServer interface + Recv func() (*types.Packet, error) + Send func(*types.Packet) error + type InvalidSessionError struct + func (e InvalidSessionError) Error() string + func (e InvalidSessionError) Unwrap() error + type StaticDirSource map[string]fsutil.FS + func (dirs StaticDirSource) LookupDir(name string) (fsutil.FS, bool) + type Stream interface + Context func() context.Context + RecvMsg func(m interface{}) error + SendMsg func(m interface{}) error + type UnimplementedFileSendServer struct + func (*UnimplementedFileSendServer) DiffCopy(srv FileSend_DiffCopyServer) error + type UnimplementedFileSyncServer struct + func (*UnimplementedFileSyncServer) DiffCopy(srv FileSync_DiffCopyServer) error + func (*UnimplementedFileSyncServer) TarStream(srv FileSync_TarStreamServer) error