Documentation ¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
rdirsync.proto
It has these top-level messages:
StatRequest ReadDirRequest FileInfos FileInfo FetchFileRequest FileChunk SendFileRequest Empty ChownRequest ChmodRequest ChtimesRequest ChangeAttributesRequest EnsureNotExistRequest EnsureDirExistsRequest
Index ¶
- func ConvertTimeFromPB(t int64) time.Time
- func ConvertTimeToPB(t time.Time) int64
- func RegisterRDirSyncServer(s *grpc.Server, srv RDirSyncServer)
- type ChangeAttributesRequest
- type ChmodRequest
- type ChownRequest
- type ChtimesRequest
- type Empty
- type EnsureDirExistsRequest
- type EnsureNotExistRequest
- type FetchFileRequest
- type FileChunk
- type FileInfo
- type FileInfos
- type RDirSyncClient
- type RDirSyncServer
- type RDirSync_FetchFileClient
- type RDirSync_FetchFileServer
- type RDirSync_ReadDirClient
- type RDirSync_ReadDirServer
- type RDirSync_SendFileClient
- type RDirSync_SendFileServer
- type ReadDirRequest
- type SendFileRequest
- type StatRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertTimeFromPB ¶
func ConvertTimeToPB ¶
func RegisterRDirSyncServer ¶
func RegisterRDirSyncServer(s *grpc.Server, srv RDirSyncServer)
Types ¶
type ChangeAttributesRequest ¶
type ChangeAttributesRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` ChangesOwner bool `protobuf:"varint,2,opt,name=changesOwner" json:"changesOwner,omitempty"` ChangesMode bool `protobuf:"varint,3,opt,name=changesMode" json:"changesMode,omitempty"` ChangesTime bool `protobuf:"varint,4,opt,name=changesTime" json:"changesTime,omitempty"` Owner string `protobuf:"bytes,5,opt,name=owner" json:"owner,omitempty"` Group string `protobuf:"bytes,6,opt,name=group" json:"group,omitempty"` Mode int32 `protobuf:"varint,7,opt,name=mode" json:"mode,omitempty"` Atime int64 `protobuf:"varint,8,opt,name=atime" json:"atime,omitempty"` Mtime int64 `protobuf:"varint,9,opt,name=mtime" json:"mtime,omitempty"` }
func (*ChangeAttributesRequest) Descriptor ¶
func (*ChangeAttributesRequest) Descriptor() ([]byte, []int)
func (*ChangeAttributesRequest) ProtoMessage ¶
func (*ChangeAttributesRequest) ProtoMessage()
func (*ChangeAttributesRequest) Reset ¶
func (m *ChangeAttributesRequest) Reset()
func (*ChangeAttributesRequest) String ¶
func (m *ChangeAttributesRequest) String() string
type ChmodRequest ¶
type ChmodRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` Mode int32 `protobuf:"varint,2,opt,name=mode" json:"mode,omitempty"` }
func (*ChmodRequest) Descriptor ¶
func (*ChmodRequest) Descriptor() ([]byte, []int)
func (*ChmodRequest) ProtoMessage ¶
func (*ChmodRequest) ProtoMessage()
func (*ChmodRequest) Reset ¶
func (m *ChmodRequest) Reset()
func (*ChmodRequest) String ¶
func (m *ChmodRequest) String() string
type ChownRequest ¶
type ChownRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner" json:"owner,omitempty"` Group string `protobuf:"bytes,3,opt,name=group" json:"group,omitempty"` }
func (*ChownRequest) Descriptor ¶
func (*ChownRequest) Descriptor() ([]byte, []int)
func (*ChownRequest) ProtoMessage ¶
func (*ChownRequest) ProtoMessage()
func (*ChownRequest) Reset ¶
func (m *ChownRequest) Reset()
func (*ChownRequest) String ¶
func (m *ChownRequest) String() string
type ChtimesRequest ¶
type ChtimesRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` Atime int64 `protobuf:"varint,2,opt,name=atime" json:"atime,omitempty"` Mtime int64 `protobuf:"varint,3,opt,name=mtime" json:"mtime,omitempty"` }
func (*ChtimesRequest) Descriptor ¶
func (*ChtimesRequest) Descriptor() ([]byte, []int)
func (*ChtimesRequest) ProtoMessage ¶
func (*ChtimesRequest) ProtoMessage()
func (*ChtimesRequest) Reset ¶
func (m *ChtimesRequest) Reset()
func (*ChtimesRequest) String ¶
func (m *ChtimesRequest) String() string
type Empty ¶
type Empty struct { }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
type EnsureDirExistsRequest ¶
type EnsureDirExistsRequest struct {
Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
}
func (*EnsureDirExistsRequest) Descriptor ¶
func (*EnsureDirExistsRequest) Descriptor() ([]byte, []int)
func (*EnsureDirExistsRequest) ProtoMessage ¶
func (*EnsureDirExistsRequest) ProtoMessage()
func (*EnsureDirExistsRequest) Reset ¶
func (m *EnsureDirExistsRequest) Reset()
func (*EnsureDirExistsRequest) String ¶
func (m *EnsureDirExistsRequest) String() string
type EnsureNotExistRequest ¶
type EnsureNotExistRequest struct {
Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
}
func (*EnsureNotExistRequest) Descriptor ¶
func (*EnsureNotExistRequest) Descriptor() ([]byte, []int)
func (*EnsureNotExistRequest) ProtoMessage ¶
func (*EnsureNotExistRequest) ProtoMessage()
func (*EnsureNotExistRequest) Reset ¶
func (m *EnsureNotExistRequest) Reset()
func (*EnsureNotExistRequest) String ¶
func (m *EnsureNotExistRequest) String() string
type FetchFileRequest ¶
type FetchFileRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` BufSize int32 `protobuf:"varint,2,opt,name=bufSize" json:"bufSize,omitempty"` }
func (*FetchFileRequest) Descriptor ¶
func (*FetchFileRequest) Descriptor() ([]byte, []int)
func (*FetchFileRequest) ProtoMessage ¶
func (*FetchFileRequest) ProtoMessage()
func (*FetchFileRequest) Reset ¶
func (m *FetchFileRequest) Reset()
func (*FetchFileRequest) String ¶
func (m *FetchFileRequest) String() string
type FileChunk ¶
type FileChunk struct {
Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
}
func (*FileChunk) Descriptor ¶
func (*FileChunk) ProtoMessage ¶
func (*FileChunk) ProtoMessage()
type FileInfo ¶
type FileInfo struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Size int64 `protobuf:"varint,2,opt,name=size" json:"size,omitempty"` Mode int32 `protobuf:"varint,3,opt,name=mode" json:"mode,omitempty"` // NOTE: int64 time containes nanoseconds from 1970-01-01T00:00:00Z ModTime int64 `protobuf:"varint,4,opt,name=modTime" json:"modTime,omitempty"` Owner string `protobuf:"bytes,5,opt,name=owner" json:"owner,omitempty"` Group string `protobuf:"bytes,6,opt,name=group" json:"group,omitempty"` }
func (*FileInfo) Descriptor ¶
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
type FileInfos ¶
type FileInfos struct {
Infos []*FileInfo `protobuf:"bytes,1,rep,name=infos" json:"infos,omitempty"`
}
func (*FileInfos) Descriptor ¶
func (*FileInfos) ProtoMessage ¶
func (*FileInfos) ProtoMessage()
type RDirSyncClient ¶
type RDirSyncClient interface { Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*FileInfo, error) ReadDir(ctx context.Context, in *ReadDirRequest, opts ...grpc.CallOption) (RDirSync_ReadDirClient, error) FetchFile(ctx context.Context, in *FetchFileRequest, opts ...grpc.CallOption) (RDirSync_FetchFileClient, error) SendFile(ctx context.Context, opts ...grpc.CallOption) (RDirSync_SendFileClient, error) Chown(ctx context.Context, in *ChownRequest, opts ...grpc.CallOption) (*Empty, error) Chmod(ctx context.Context, in *ChmodRequest, opts ...grpc.CallOption) (*Empty, error) Chtimes(ctx context.Context, in *ChtimesRequest, opts ...grpc.CallOption) (*Empty, error) ChangeAttributes(ctx context.Context, in *ChangeAttributesRequest, opts ...grpc.CallOption) (*Empty, error) EnsureDirExists(ctx context.Context, in *EnsureDirExistsRequest, opts ...grpc.CallOption) (*Empty, error) EnsureNotExist(ctx context.Context, in *EnsureNotExistRequest, opts ...grpc.CallOption) (*Empty, error) }
func NewRDirSyncClient ¶
func NewRDirSyncClient(cc *grpc.ClientConn) RDirSyncClient
type RDirSyncServer ¶
type RDirSyncServer interface { Stat(context.Context, *StatRequest) (*FileInfo, error) ReadDir(*ReadDirRequest, RDirSync_ReadDirServer) error FetchFile(*FetchFileRequest, RDirSync_FetchFileServer) error SendFile(RDirSync_SendFileServer) error Chown(context.Context, *ChownRequest) (*Empty, error) Chmod(context.Context, *ChmodRequest) (*Empty, error) Chtimes(context.Context, *ChtimesRequest) (*Empty, error) ChangeAttributes(context.Context, *ChangeAttributesRequest) (*Empty, error) EnsureDirExists(context.Context, *EnsureDirExistsRequest) (*Empty, error) EnsureNotExist(context.Context, *EnsureNotExistRequest) (*Empty, error) }
type RDirSync_FetchFileClient ¶
type RDirSync_FetchFileClient interface { Recv() (*FileChunk, error) grpc.ClientStream }
type RDirSync_FetchFileServer ¶
type RDirSync_FetchFileServer interface { Send(*FileChunk) error grpc.ServerStream }
type RDirSync_ReadDirClient ¶
type RDirSync_ReadDirClient interface { Recv() (*FileInfos, error) grpc.ClientStream }
type RDirSync_ReadDirServer ¶
type RDirSync_ReadDirServer interface { Send(*FileInfos) error grpc.ServerStream }
type RDirSync_SendFileClient ¶
type RDirSync_SendFileClient interface { Send(*SendFileRequest) error CloseAndRecv() (*Empty, error) grpc.ClientStream }
type RDirSync_SendFileServer ¶
type RDirSync_SendFileServer interface { SendAndClose(*Empty) error Recv() (*SendFileRequest, error) grpc.ServerStream }
type ReadDirRequest ¶
type ReadDirRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` AtMostCount int32 `protobuf:"varint,2,opt,name=atMostCount" json:"atMostCount,omitempty"` WantsOwnerAndGroup bool `protobuf:"varint,3,opt,name=wantsOwnerAndGroup" json:"wantsOwnerAndGroup,omitempty"` }
func (*ReadDirRequest) Descriptor ¶
func (*ReadDirRequest) Descriptor() ([]byte, []int)
func (*ReadDirRequest) ProtoMessage ¶
func (*ReadDirRequest) ProtoMessage()
func (*ReadDirRequest) Reset ¶
func (m *ReadDirRequest) Reset()
func (*ReadDirRequest) String ¶
func (m *ReadDirRequest) String() string
type SendFileRequest ¶
type SendFileRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` Chunk []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"` }
func (*SendFileRequest) Descriptor ¶
func (*SendFileRequest) Descriptor() ([]byte, []int)
func (*SendFileRequest) ProtoMessage ¶
func (*SendFileRequest) ProtoMessage()
func (*SendFileRequest) Reset ¶
func (m *SendFileRequest) Reset()
func (*SendFileRequest) String ¶
func (m *SendFileRequest) String() string
type StatRequest ¶
type StatRequest struct { Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"` WantsOwnerAndGroup bool `protobuf:"varint,2,opt,name=wantsOwnerAndGroup" json:"wantsOwnerAndGroup,omitempty"` }
func (*StatRequest) Descriptor ¶
func (*StatRequest) Descriptor() ([]byte, []int)
func (*StatRequest) ProtoMessage ¶
func (*StatRequest) ProtoMessage()
func (*StatRequest) Reset ¶
func (m *StatRequest) Reset()
func (*StatRequest) String ¶
func (m *StatRequest) String() string
Click to show internal directories.
Click to hide internal directories.