Documentation
¶
Overview ¶
Package filesync is a generated protocol buffer package.
It is generated from these files:
filesync.proto
It has these top-level messages:
BytesMessage
Index ¶
- Variables
- func CopyFileWriter(ctx context.Context, c session.Caller) (io.WriteCloser, error)
- func CopyToCaller(ctx context.Context, srcPath string, c session.Caller, ...) 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
- func (*BytesMessage) Descriptor() ([]byte, []int)
- func (this *BytesMessage) Equal(that interface{}) bool
- func (m *BytesMessage) GetData() []byte
- func (this *BytesMessage) GoString() string
- func (m *BytesMessage) Marshal() (dAtA []byte, err error)
- func (m *BytesMessage) MarshalTo(dAtA []byte) (int, error)
- func (*BytesMessage) ProtoMessage()
- func (m *BytesMessage) Reset()
- func (m *BytesMessage) Size() (n int)
- func (this *BytesMessage) String() string
- func (m *BytesMessage) Unmarshal(dAtA []byte) error
- type CacheUpdater
- type FSSendRequestOpt
- type FileSendClient
- type FileSendServer
- type FileSend_DiffCopyClient
- type FileSend_DiffCopyServer
- type FileSyncClient
- type FileSyncServer
- type FileSync_DiffCopyClient
- type FileSync_DiffCopyServer
- type FileSync_TarStreamClient
- type FileSync_TarStreamServer
- type SyncedDir
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthFilesync = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowFilesync = fmt.Errorf("proto: integer overflow") )
Functions ¶
func CopyFileWriter ¶
func CopyToCaller ¶
func NewFSSyncProvider ¶
func NewFSSyncProvider(dirs []SyncedDir) session.Attachable
NewFSSyncProvider creates a new provider for sending files from client
func NewFSSyncTarget ¶
func NewFSSyncTarget(w io.WriteCloser) session.Attachable
NewFSSyncTarget allows writing into an io.WriteCloser
func NewFSSyncTargetDir ¶
func NewFSSyncTargetDir(outdir string) session.Attachable
NewFSSyncTargetDir allows writing into a directory
func RegisterFileSendServer ¶
func RegisterFileSendServer(s *grpc.Server, srv FileSendServer)
func RegisterFileSyncServer ¶
func RegisterFileSyncServer(s *grpc.Server, srv FileSyncServer)
Types ¶
type BytesMessage ¶
type BytesMessage struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
BytesMessage contains a chunk of byte data
func (*BytesMessage) Descriptor ¶
func (*BytesMessage) Descriptor() ([]byte, []int)
func (*BytesMessage) Equal ¶
func (this *BytesMessage) Equal(that interface{}) bool
func (*BytesMessage) GetData ¶
func (m *BytesMessage) GetData() []byte
func (*BytesMessage) GoString ¶
func (this *BytesMessage) GoString() string
func (*BytesMessage) Marshal ¶
func (m *BytesMessage) Marshal() (dAtA []byte, err error)
func (*BytesMessage) ProtoMessage ¶
func (*BytesMessage) ProtoMessage()
func (*BytesMessage) Reset ¶
func (m *BytesMessage) Reset()
func (*BytesMessage) Size ¶
func (m *BytesMessage) Size() (n int)
func (*BytesMessage) String ¶
func (this *BytesMessage) String() string
func (*BytesMessage) Unmarshal ¶
func (m *BytesMessage) Unmarshal(dAtA []byte) error
type CacheUpdater ¶
type CacheUpdater interface { MarkSupported(bool) HandleChange(fsutil.ChangeKind, string, os.FileInfo, error) error ContentHasher() fsutil.ContentHasher }
CacheUpdater is an object capable of sending notifications for the cache hash changes
type FSSendRequestOpt ¶
type FSSendRequestOpt struct { Name string IncludePatterns []string ExcludePatterns []string FollowPaths []string OverrideExcludes bool // deprecated: this is used by docker/cli for automatically loading .dockerignore from the directory DestDir string CacheUpdater CacheUpdater ProgressCb func(int, bool) }
FSSendRequestOpt defines options for FSSend request
type FileSendClient ¶
type FileSendClient interface {
DiffCopy(ctx context.Context, opts ...grpc.CallOption) (FileSend_DiffCopyClient, error)
}
func NewFileSendClient ¶
func NewFileSendClient(cc *grpc.ClientConn) FileSendClient
type FileSendServer ¶
type FileSendServer interface {
DiffCopy(FileSend_DiffCopyServer) error
}
type FileSend_DiffCopyClient ¶
type FileSend_DiffCopyClient interface { Send(*BytesMessage) error Recv() (*BytesMessage, error) grpc.ClientStream }
type FileSend_DiffCopyServer ¶
type FileSend_DiffCopyServer interface { Send(*BytesMessage) error Recv() (*BytesMessage, error) grpc.ServerStream }
type FileSyncClient ¶
type FileSyncClient interface { DiffCopy(ctx context.Context, opts ...grpc.CallOption) (FileSync_DiffCopyClient, error) TarStream(ctx context.Context, opts ...grpc.CallOption) (FileSync_TarStreamClient, error) }
func NewFileSyncClient ¶
func NewFileSyncClient(cc *grpc.ClientConn) FileSyncClient
type FileSyncServer ¶
type FileSyncServer interface { DiffCopy(FileSync_DiffCopyServer) error TarStream(FileSync_TarStreamServer) error }
type FileSync_DiffCopyClient ¶
type FileSync_DiffCopyClient interface { Send(*BytesMessage) error Recv() (*BytesMessage, error) grpc.ClientStream }
type FileSync_DiffCopyServer ¶
type FileSync_DiffCopyServer interface { Send(*BytesMessage) error Recv() (*BytesMessage, error) grpc.ServerStream }
type FileSync_TarStreamClient ¶
type FileSync_TarStreamClient interface { Send(*BytesMessage) error Recv() (*BytesMessage, error) grpc.ClientStream }
type FileSync_TarStreamServer ¶
type FileSync_TarStreamServer interface { Send(*BytesMessage) error Recv() (*BytesMessage, error) grpc.ServerStream }
Click to show internal directories.
Click to hide internal directories.