Versions in this module Expand all Collapse all v0 v0.3.1 Oct 17, 2018 v0.3.0 Oct 12, 2018 Changes in this version + var ErrIntOverflowFilesync = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthFilesync = fmt.Errorf("proto: negative length found during unmarshaling") + func CopyFileWriter(ctx context.Context, 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 []SyncedDir) session.Attachable + func NewFSSyncTarget(w io.WriteCloser) 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) Reset() + func (m *BytesMessage) Size() (n int) + func (m *BytesMessage) Unmarshal(dAtA []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 FSSendRequestOpt struct + CacheUpdater CacheUpdater + DestDir string + ExcludePatterns []string + FollowPaths []string + IncludePatterns []string + Name string + OverrideExcludes bool + 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() (*BytesMessage, error) + Send func(*BytesMessage) error + type FileSync_DiffCopyServer interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type FileSync_TarStreamClient interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type FileSync_TarStreamServer interface + Recv func() (*BytesMessage, error) + Send func(*BytesMessage) error + type SyncedDir struct + Dir string + Excludes []string + Map func(*fstypes.Stat) bool + Name string