Documentation ¶
Index ¶
- Variables
- func RegisterDataNodeServer(s grpc.ServiceRegistrar, srv DataNodeServer)
- func RegisterMasterNodeServer(s grpc.ServiceRegistrar, srv MasterNodeServer)
- type Cell
- type Chunk
- func (*Chunk) Descriptor() ([]byte, []int)deprecated
- func (x *Chunk) GetDatanode() string
- func (x *Chunk) GetHoldsMeta() bool
- func (x *Chunk) GetId() uint64
- func (x *Chunk) GetVersion() uint64
- func (*Chunk) ProtoMessage()
- func (x *Chunk) ProtoReflect() protoreflect.Message
- func (x *Chunk) Reset()
- func (x *Chunk) String() string
- type CreateSheetReply
- func (*CreateSheetReply) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSheetReply) GetFd() uint64
- func (x *CreateSheetReply) GetStatus() Status
- func (*CreateSheetReply) ProtoMessage()
- func (x *CreateSheetReply) ProtoReflect() protoreflect.Message
- func (x *CreateSheetReply) Reset()
- func (x *CreateSheetReply) String() string
- type CreateSheetRequest
- func (*CreateSheetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSheetRequest) GetFilename() string
- func (*CreateSheetRequest) ProtoMessage()
- func (x *CreateSheetRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSheetRequest) Reset()
- func (x *CreateSheetRequest) String() string
- type DataNodeClient
- type DataNodeServer
- type DeleteChunkReply
- type DeleteChunkRequest
- type DeleteSheetReply
- type DeleteSheetRequest
- func (*DeleteSheetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSheetRequest) GetFilename() string
- func (*DeleteSheetRequest) ProtoMessage()
- func (x *DeleteSheetRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSheetRequest) Reset()
- func (x *DeleteSheetRequest) String() string
- type Empty
- type ListSheetsReply
- func (*ListSheetsReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListSheetsReply) GetSheets() []*Sheet
- func (x *ListSheetsReply) GetStatus() Status
- func (*ListSheetsReply) ProtoMessage()
- func (x *ListSheetsReply) ProtoReflect() protoreflect.Message
- func (x *ListSheetsReply) Reset()
- func (x *ListSheetsReply) String() string
- type MasterNodeClient
- type MasterNodeServer
- type OpenSheetReply
- func (*OpenSheetReply) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSheetReply) GetFd() uint64
- func (x *OpenSheetReply) GetStatus() Status
- func (*OpenSheetReply) ProtoMessage()
- func (x *OpenSheetReply) ProtoReflect() protoreflect.Message
- func (x *OpenSheetReply) Reset()
- func (x *OpenSheetReply) String() string
- type OpenSheetRequest
- type ReadCellReply
- func (*ReadCellReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReadCellReply) GetCell() *Cell
- func (x *ReadCellReply) GetStatus() Status
- func (*ReadCellReply) ProtoMessage()
- func (x *ReadCellReply) ProtoReflect() protoreflect.Message
- func (x *ReadCellReply) Reset()
- func (x *ReadCellReply) String() string
- type ReadCellRequest
- func (*ReadCellRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadCellRequest) GetColumn() uint32
- func (x *ReadCellRequest) GetFd() uint64
- func (x *ReadCellRequest) GetRow() uint32
- func (*ReadCellRequest) ProtoMessage()
- func (x *ReadCellRequest) ProtoReflect() protoreflect.Message
- func (x *ReadCellRequest) Reset()
- func (x *ReadCellRequest) String() string
- type ReadChunkReply
- func (*ReadChunkReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReadChunkReply) GetData() []byte
- func (x *ReadChunkReply) GetStatus() Status
- func (x *ReadChunkReply) GetVersion() uint64
- func (*ReadChunkReply) ProtoMessage()
- func (x *ReadChunkReply) ProtoReflect() protoreflect.Message
- func (x *ReadChunkReply) Reset()
- func (x *ReadChunkReply) String() string
- type ReadChunkRequest
- func (*ReadChunkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadChunkRequest) GetId() uint64
- func (x *ReadChunkRequest) GetOffset() uint64
- func (x *ReadChunkRequest) GetSize() uint64
- func (x *ReadChunkRequest) GetVersion() uint64
- func (*ReadChunkRequest) ProtoMessage()
- func (x *ReadChunkRequest) ProtoReflect() protoreflect.Message
- func (x *ReadChunkRequest) Reset()
- func (x *ReadChunkRequest) String() string
- type ReadSheetReply
- func (*ReadSheetReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReadSheetReply) GetChunks() []*Chunk
- func (x *ReadSheetReply) GetStatus() Status
- func (*ReadSheetReply) ProtoMessage()
- func (x *ReadSheetReply) ProtoReflect() protoreflect.Message
- func (x *ReadSheetReply) Reset()
- func (x *ReadSheetReply) String() string
- type ReadSheetRequest
- type RecycleSheetReply
- type RecycleSheetRequest
- func (*RecycleSheetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RecycleSheetRequest) GetFilename() string
- func (*RecycleSheetRequest) ProtoMessage()
- func (x *RecycleSheetRequest) ProtoReflect() protoreflect.Message
- func (x *RecycleSheetRequest) Reset()
- func (x *RecycleSheetRequest) String() string
- type RegisterDataNodeReply
- func (*RegisterDataNodeReply) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterDataNodeReply) GetStatus() Status
- func (*RegisterDataNodeReply) ProtoMessage()
- func (x *RegisterDataNodeReply) ProtoReflect() protoreflect.Message
- func (x *RegisterDataNodeReply) Reset()
- func (x *RegisterDataNodeReply) String() string
- type RegisterDataNodeRequest
- func (*RegisterDataNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterDataNodeRequest) GetAddr() string
- func (*RegisterDataNodeRequest) ProtoMessage()
- func (x *RegisterDataNodeRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterDataNodeRequest) Reset()
- func (x *RegisterDataNodeRequest) String() string
- type ResumeSheetReply
- type ResumeSheetRequest
- func (*ResumeSheetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeSheetRequest) GetFilename() string
- func (*ResumeSheetRequest) ProtoMessage()
- func (x *ResumeSheetRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeSheetRequest) Reset()
- func (x *ResumeSheetRequest) String() string
- type Sheet
- type Status
- type UnimplementedDataNodeServer
- func (UnimplementedDataNodeServer) DeleteChunk(context.Context, *DeleteChunkRequest) (*DeleteChunkReply, error)
- func (UnimplementedDataNodeServer) ReadChunk(context.Context, *ReadChunkRequest) (*ReadChunkReply, error)
- func (UnimplementedDataNodeServer) WriteChunk(context.Context, *WriteChunkRequest) (*WriteChunkReply, error)
- type UnimplementedMasterNodeServer
- func (UnimplementedMasterNodeServer) CreateSheet(context.Context, *CreateSheetRequest) (*CreateSheetReply, error)
- func (UnimplementedMasterNodeServer) DeleteSheet(context.Context, *DeleteSheetRequest) (*DeleteSheetReply, error)
- func (UnimplementedMasterNodeServer) ListSheets(context.Context, *Empty) (*ListSheetsReply, error)
- func (UnimplementedMasterNodeServer) OpenSheet(context.Context, *OpenSheetRequest) (*OpenSheetReply, error)
- func (UnimplementedMasterNodeServer) ReadCell(context.Context, *ReadCellRequest) (*ReadCellReply, error)
- func (UnimplementedMasterNodeServer) ReadSheet(context.Context, *ReadSheetRequest) (*ReadSheetReply, error)
- func (UnimplementedMasterNodeServer) RecycleSheet(context.Context, *RecycleSheetRequest) (*RecycleSheetReply, error)
- func (UnimplementedMasterNodeServer) RegisterDataNode(context.Context, *RegisterDataNodeRequest) (*RegisterDataNodeReply, error)
- func (UnimplementedMasterNodeServer) ResumeSheet(context.Context, *ResumeSheetRequest) (*ResumeSheetReply, error)
- func (UnimplementedMasterNodeServer) WriteCell(context.Context, *WriteCellRequest) (*WriteCellReply, error)
- type UnsafeDataNodeServer
- type UnsafeMasterNodeServer
- type WriteCellReply
- func (*WriteCellReply) Descriptor() ([]byte, []int)deprecated
- func (x *WriteCellReply) GetCell() *Cell
- func (x *WriteCellReply) GetStatus() Status
- func (*WriteCellReply) ProtoMessage()
- func (x *WriteCellReply) ProtoReflect() protoreflect.Message
- func (x *WriteCellReply) Reset()
- func (x *WriteCellReply) String() string
- type WriteCellRequest
- func (*WriteCellRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteCellRequest) GetColumn() uint32
- func (x *WriteCellRequest) GetFd() uint64
- func (x *WriteCellRequest) GetRow() uint32
- func (*WriteCellRequest) ProtoMessage()
- func (x *WriteCellRequest) ProtoReflect() protoreflect.Message
- func (x *WriteCellRequest) Reset()
- func (x *WriteCellRequest) String() string
- type WriteChunkReply
- type WriteChunkRequest
- func (*WriteChunkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteChunkRequest) GetData() []byte
- func (x *WriteChunkRequest) GetId() uint64
- func (x *WriteChunkRequest) GetOffset() uint64
- func (x *WriteChunkRequest) GetPadding() string
- func (x *WriteChunkRequest) GetSize() uint64
- func (x *WriteChunkRequest) GetTargetSize() uint64
- func (x *WriteChunkRequest) GetVersion() uint64
- func (*WriteChunkRequest) ProtoMessage()
- func (x *WriteChunkRequest) ProtoReflect() protoreflect.Message
- func (x *WriteChunkRequest) Reset()
- func (x *WriteChunkRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( Status_name = map[int32]string{ 0: "OK", 1: "Exist", 2: "NotFound", 3: "WrongVersion", 4: "Invalid", 5: "Unavailable", } Status_value = map[string]int32{ "OK": 0, "Exist": 1, "NotFound": 2, "WrongVersion": 3, "Invalid": 4, "Unavailable": 5, } )
Enum value maps for Status.
var DataNode_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sheetfs.DataNode", HandlerType: (*DataNodeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReadChunk", Handler: _DataNode_ReadChunk_Handler, }, { MethodName: "WriteChunk", Handler: _DataNode_WriteChunk_Handler, }, { MethodName: "DeleteChunk", Handler: _DataNode_DeleteChunk_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protocol/sheetfs.proto", }
DataNode_ServiceDesc is the grpc.ServiceDesc for DataNode service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_protocol_sheetfs_proto protoreflect.FileDescriptor
var MasterNode_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sheetfs.MasterNode", HandlerType: (*MasterNodeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterDataNode", Handler: _MasterNode_RegisterDataNode_Handler, }, { MethodName: "CreateSheet", Handler: _MasterNode_CreateSheet_Handler, }, { MethodName: "DeleteSheet", Handler: _MasterNode_DeleteSheet_Handler, }, { MethodName: "OpenSheet", Handler: _MasterNode_OpenSheet_Handler, }, { MethodName: "ReadSheet", Handler: _MasterNode_ReadSheet_Handler, }, { MethodName: "RecycleSheet", Handler: _MasterNode_RecycleSheet_Handler, }, { MethodName: "ResumeSheet", Handler: _MasterNode_ResumeSheet_Handler, }, { MethodName: "ListSheets", Handler: _MasterNode_ListSheets_Handler, }, { MethodName: "ReadCell", Handler: _MasterNode_ReadCell_Handler, }, { MethodName: "WriteCell", Handler: _MasterNode_WriteCell_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protocol/sheetfs.proto", }
MasterNode_ServiceDesc is the grpc.ServiceDesc for MasterNode service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterDataNodeServer ¶
func RegisterDataNodeServer(s grpc.ServiceRegistrar, srv DataNodeServer)
func RegisterMasterNodeServer ¶
func RegisterMasterNodeServer(s grpc.ServiceRegistrar, srv MasterNodeServer)
Types ¶
type Cell ¶
type Cell struct { Chunk *Chunk `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*Cell) Descriptor
deprecated
func (*Cell) ProtoMessage ¶
func (*Cell) ProtoMessage()
func (*Cell) ProtoReflect ¶
func (x *Cell) ProtoReflect() protoreflect.Message
type Chunk ¶
type Chunk struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Datanode string `protobuf:"bytes,2,opt,name=datanode,proto3" json:"datanode,omitempty"` Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` HoldsMeta bool `protobuf:"varint,4,opt,name=holds_meta,json=holdsMeta,proto3" json:"holds_meta,omitempty"` // contains filtered or unexported fields }
func (*Chunk) Descriptor
deprecated
func (*Chunk) GetDatanode ¶
func (*Chunk) GetHoldsMeta ¶
func (*Chunk) GetVersion ¶
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
func (*Chunk) ProtoReflect ¶
func (x *Chunk) ProtoReflect() protoreflect.Message
type CreateSheetReply ¶
type CreateSheetReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Fd uint64 `protobuf:"varint,2,opt,name=fd,proto3" json:"fd,omitempty"` // contains filtered or unexported fields }
func (*CreateSheetReply) Descriptor
deprecated
func (*CreateSheetReply) Descriptor() ([]byte, []int)
Deprecated: Use CreateSheetReply.ProtoReflect.Descriptor instead.
func (*CreateSheetReply) GetFd ¶
func (x *CreateSheetReply) GetFd() uint64
func (*CreateSheetReply) GetStatus ¶
func (x *CreateSheetReply) GetStatus() Status
func (*CreateSheetReply) ProtoMessage ¶
func (*CreateSheetReply) ProtoMessage()
func (*CreateSheetReply) ProtoReflect ¶
func (x *CreateSheetReply) ProtoReflect() protoreflect.Message
func (*CreateSheetReply) Reset ¶
func (x *CreateSheetReply) Reset()
func (*CreateSheetReply) String ¶
func (x *CreateSheetReply) String() string
type CreateSheetRequest ¶
type CreateSheetRequest struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
func (*CreateSheetRequest) Descriptor
deprecated
func (*CreateSheetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSheetRequest.ProtoReflect.Descriptor instead.
func (*CreateSheetRequest) GetFilename ¶
func (x *CreateSheetRequest) GetFilename() string
func (*CreateSheetRequest) ProtoMessage ¶
func (*CreateSheetRequest) ProtoMessage()
func (*CreateSheetRequest) ProtoReflect ¶
func (x *CreateSheetRequest) ProtoReflect() protoreflect.Message
func (*CreateSheetRequest) Reset ¶
func (x *CreateSheetRequest) Reset()
func (*CreateSheetRequest) String ¶
func (x *CreateSheetRequest) String() string
type DataNodeClient ¶
type DataNodeClient interface { ReadChunk(ctx context.Context, in *ReadChunkRequest, opts ...grpc.CallOption) (*ReadChunkReply, error) WriteChunk(ctx context.Context, in *WriteChunkRequest, opts ...grpc.CallOption) (*WriteChunkReply, error) DeleteChunk(ctx context.Context, in *DeleteChunkRequest, opts ...grpc.CallOption) (*DeleteChunkReply, error) }
DataNodeClient is the client API for DataNode service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDataNodeClient ¶
func NewDataNodeClient(cc grpc.ClientConnInterface) DataNodeClient
type DataNodeServer ¶
type DataNodeServer interface { ReadChunk(context.Context, *ReadChunkRequest) (*ReadChunkReply, error) WriteChunk(context.Context, *WriteChunkRequest) (*WriteChunkReply, error) DeleteChunk(context.Context, *DeleteChunkRequest) (*DeleteChunkReply, error) // contains filtered or unexported methods }
DataNodeServer is the server API for DataNode service. All implementations must embed UnimplementedDataNodeServer for forward compatibility
type DeleteChunkReply ¶
type DeleteChunkReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*DeleteChunkReply) Descriptor
deprecated
func (*DeleteChunkReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteChunkReply.ProtoReflect.Descriptor instead.
func (*DeleteChunkReply) GetStatus ¶
func (x *DeleteChunkReply) GetStatus() Status
func (*DeleteChunkReply) ProtoMessage ¶
func (*DeleteChunkReply) ProtoMessage()
func (*DeleteChunkReply) ProtoReflect ¶
func (x *DeleteChunkReply) ProtoReflect() protoreflect.Message
func (*DeleteChunkReply) Reset ¶
func (x *DeleteChunkReply) Reset()
func (*DeleteChunkReply) String ¶
func (x *DeleteChunkReply) String() string
type DeleteChunkRequest ¶
type DeleteChunkRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DeleteChunkRequest) Descriptor
deprecated
func (*DeleteChunkRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteChunkRequest.ProtoReflect.Descriptor instead.
func (*DeleteChunkRequest) GetId ¶
func (x *DeleteChunkRequest) GetId() uint64
func (*DeleteChunkRequest) ProtoMessage ¶
func (*DeleteChunkRequest) ProtoMessage()
func (*DeleteChunkRequest) ProtoReflect ¶
func (x *DeleteChunkRequest) ProtoReflect() protoreflect.Message
func (*DeleteChunkRequest) Reset ¶
func (x *DeleteChunkRequest) Reset()
func (*DeleteChunkRequest) String ¶
func (x *DeleteChunkRequest) String() string
type DeleteSheetReply ¶
type DeleteSheetReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*DeleteSheetReply) Descriptor
deprecated
func (*DeleteSheetReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSheetReply.ProtoReflect.Descriptor instead.
func (*DeleteSheetReply) GetStatus ¶
func (x *DeleteSheetReply) GetStatus() Status
func (*DeleteSheetReply) ProtoMessage ¶
func (*DeleteSheetReply) ProtoMessage()
func (*DeleteSheetReply) ProtoReflect ¶
func (x *DeleteSheetReply) ProtoReflect() protoreflect.Message
func (*DeleteSheetReply) Reset ¶
func (x *DeleteSheetReply) Reset()
func (*DeleteSheetReply) String ¶
func (x *DeleteSheetReply) String() string
type DeleteSheetRequest ¶
type DeleteSheetRequest struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
func (*DeleteSheetRequest) Descriptor
deprecated
func (*DeleteSheetRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSheetRequest.ProtoReflect.Descriptor instead.
func (*DeleteSheetRequest) GetFilename ¶
func (x *DeleteSheetRequest) GetFilename() string
func (*DeleteSheetRequest) ProtoMessage ¶
func (*DeleteSheetRequest) ProtoMessage()
func (*DeleteSheetRequest) ProtoReflect ¶
func (x *DeleteSheetRequest) ProtoReflect() protoreflect.Message
func (*DeleteSheetRequest) Reset ¶
func (x *DeleteSheetRequest) Reset()
func (*DeleteSheetRequest) String ¶
func (x *DeleteSheetRequest) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type ListSheetsReply ¶
type ListSheetsReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Sheets []*Sheet `protobuf:"bytes,2,rep,name=sheets,proto3" json:"sheets,omitempty"` // contains filtered or unexported fields }
func (*ListSheetsReply) Descriptor
deprecated
func (*ListSheetsReply) Descriptor() ([]byte, []int)
Deprecated: Use ListSheetsReply.ProtoReflect.Descriptor instead.
func (*ListSheetsReply) GetSheets ¶
func (x *ListSheetsReply) GetSheets() []*Sheet
func (*ListSheetsReply) GetStatus ¶
func (x *ListSheetsReply) GetStatus() Status
func (*ListSheetsReply) ProtoMessage ¶
func (*ListSheetsReply) ProtoMessage()
func (*ListSheetsReply) ProtoReflect ¶
func (x *ListSheetsReply) ProtoReflect() protoreflect.Message
func (*ListSheetsReply) Reset ¶
func (x *ListSheetsReply) Reset()
func (*ListSheetsReply) String ¶
func (x *ListSheetsReply) String() string
type MasterNodeClient ¶
type MasterNodeClient interface { RegisterDataNode(ctx context.Context, in *RegisterDataNodeRequest, opts ...grpc.CallOption) (*RegisterDataNodeReply, error) CreateSheet(ctx context.Context, in *CreateSheetRequest, opts ...grpc.CallOption) (*CreateSheetReply, error) DeleteSheet(ctx context.Context, in *DeleteSheetRequest, opts ...grpc.CallOption) (*DeleteSheetReply, error) OpenSheet(ctx context.Context, in *OpenSheetRequest, opts ...grpc.CallOption) (*OpenSheetReply, error) ReadSheet(ctx context.Context, in *ReadSheetRequest, opts ...grpc.CallOption) (*ReadSheetReply, error) RecycleSheet(ctx context.Context, in *RecycleSheetRequest, opts ...grpc.CallOption) (*RecycleSheetReply, error) ResumeSheet(ctx context.Context, in *ResumeSheetRequest, opts ...grpc.CallOption) (*ResumeSheetReply, error) ListSheets(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListSheetsReply, error) ReadCell(ctx context.Context, in *ReadCellRequest, opts ...grpc.CallOption) (*ReadCellReply, error) WriteCell(ctx context.Context, in *WriteCellRequest, opts ...grpc.CallOption) (*WriteCellReply, error) }
MasterNodeClient is the client API for MasterNode service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMasterNodeClient ¶
func NewMasterNodeClient(cc grpc.ClientConnInterface) MasterNodeClient
type MasterNodeServer ¶
type MasterNodeServer interface { RegisterDataNode(context.Context, *RegisterDataNodeRequest) (*RegisterDataNodeReply, error) CreateSheet(context.Context, *CreateSheetRequest) (*CreateSheetReply, error) DeleteSheet(context.Context, *DeleteSheetRequest) (*DeleteSheetReply, error) OpenSheet(context.Context, *OpenSheetRequest) (*OpenSheetReply, error) ReadSheet(context.Context, *ReadSheetRequest) (*ReadSheetReply, error) RecycleSheet(context.Context, *RecycleSheetRequest) (*RecycleSheetReply, error) ResumeSheet(context.Context, *ResumeSheetRequest) (*ResumeSheetReply, error) ListSheets(context.Context, *Empty) (*ListSheetsReply, error) ReadCell(context.Context, *ReadCellRequest) (*ReadCellReply, error) WriteCell(context.Context, *WriteCellRequest) (*WriteCellReply, error) // contains filtered or unexported methods }
MasterNodeServer is the server API for MasterNode service. All implementations must embed UnimplementedMasterNodeServer for forward compatibility
type OpenSheetReply ¶
type OpenSheetReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Fd uint64 `protobuf:"varint,2,opt,name=fd,proto3" json:"fd,omitempty"` // contains filtered or unexported fields }
func (*OpenSheetReply) Descriptor
deprecated
func (*OpenSheetReply) Descriptor() ([]byte, []int)
Deprecated: Use OpenSheetReply.ProtoReflect.Descriptor instead.
func (*OpenSheetReply) GetFd ¶
func (x *OpenSheetReply) GetFd() uint64
func (*OpenSheetReply) GetStatus ¶
func (x *OpenSheetReply) GetStatus() Status
func (*OpenSheetReply) ProtoMessage ¶
func (*OpenSheetReply) ProtoMessage()
func (*OpenSheetReply) ProtoReflect ¶
func (x *OpenSheetReply) ProtoReflect() protoreflect.Message
func (*OpenSheetReply) Reset ¶
func (x *OpenSheetReply) Reset()
func (*OpenSheetReply) String ¶
func (x *OpenSheetReply) String() string
type OpenSheetRequest ¶
type OpenSheetRequest struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
func (*OpenSheetRequest) Descriptor
deprecated
func (*OpenSheetRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenSheetRequest.ProtoReflect.Descriptor instead.
func (*OpenSheetRequest) GetFilename ¶
func (x *OpenSheetRequest) GetFilename() string
func (*OpenSheetRequest) ProtoMessage ¶
func (*OpenSheetRequest) ProtoMessage()
func (*OpenSheetRequest) ProtoReflect ¶
func (x *OpenSheetRequest) ProtoReflect() protoreflect.Message
func (*OpenSheetRequest) Reset ¶
func (x *OpenSheetRequest) Reset()
func (*OpenSheetRequest) String ¶
func (x *OpenSheetRequest) String() string
type ReadCellReply ¶
type ReadCellReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Cell *Cell `protobuf:"bytes,2,opt,name=cell,proto3" json:"cell,omitempty"` // contains filtered or unexported fields }
func (*ReadCellReply) Descriptor
deprecated
func (*ReadCellReply) Descriptor() ([]byte, []int)
Deprecated: Use ReadCellReply.ProtoReflect.Descriptor instead.
func (*ReadCellReply) GetCell ¶
func (x *ReadCellReply) GetCell() *Cell
func (*ReadCellReply) GetStatus ¶
func (x *ReadCellReply) GetStatus() Status
func (*ReadCellReply) ProtoMessage ¶
func (*ReadCellReply) ProtoMessage()
func (*ReadCellReply) ProtoReflect ¶
func (x *ReadCellReply) ProtoReflect() protoreflect.Message
func (*ReadCellReply) Reset ¶
func (x *ReadCellReply) Reset()
func (*ReadCellReply) String ¶
func (x *ReadCellReply) String() string
type ReadCellRequest ¶
type ReadCellRequest struct { Fd uint64 `protobuf:"varint,1,opt,name=fd,proto3" json:"fd,omitempty"` Row uint32 `protobuf:"varint,2,opt,name=row,proto3" json:"row,omitempty"` Column uint32 `protobuf:"varint,3,opt,name=column,proto3" json:"column,omitempty"` // contains filtered or unexported fields }
func (*ReadCellRequest) Descriptor
deprecated
func (*ReadCellRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadCellRequest.ProtoReflect.Descriptor instead.
func (*ReadCellRequest) GetColumn ¶
func (x *ReadCellRequest) GetColumn() uint32
func (*ReadCellRequest) GetFd ¶
func (x *ReadCellRequest) GetFd() uint64
func (*ReadCellRequest) GetRow ¶
func (x *ReadCellRequest) GetRow() uint32
func (*ReadCellRequest) ProtoMessage ¶
func (*ReadCellRequest) ProtoMessage()
func (*ReadCellRequest) ProtoReflect ¶
func (x *ReadCellRequest) ProtoReflect() protoreflect.Message
func (*ReadCellRequest) Reset ¶
func (x *ReadCellRequest) Reset()
func (*ReadCellRequest) String ¶
func (x *ReadCellRequest) String() string
type ReadChunkReply ¶
type ReadChunkReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ReadChunkReply) Descriptor
deprecated
func (*ReadChunkReply) Descriptor() ([]byte, []int)
Deprecated: Use ReadChunkReply.ProtoReflect.Descriptor instead.
func (*ReadChunkReply) GetData ¶
func (x *ReadChunkReply) GetData() []byte
func (*ReadChunkReply) GetStatus ¶
func (x *ReadChunkReply) GetStatus() Status
func (*ReadChunkReply) GetVersion ¶
func (x *ReadChunkReply) GetVersion() uint64
func (*ReadChunkReply) ProtoMessage ¶
func (*ReadChunkReply) ProtoMessage()
func (*ReadChunkReply) ProtoReflect ¶
func (x *ReadChunkReply) ProtoReflect() protoreflect.Message
func (*ReadChunkReply) Reset ¶
func (x *ReadChunkReply) Reset()
func (*ReadChunkReply) String ¶
func (x *ReadChunkReply) String() string
type ReadChunkRequest ¶
type ReadChunkRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` Version uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ReadChunkRequest) Descriptor
deprecated
func (*ReadChunkRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadChunkRequest.ProtoReflect.Descriptor instead.
func (*ReadChunkRequest) GetId ¶
func (x *ReadChunkRequest) GetId() uint64
func (*ReadChunkRequest) GetOffset ¶
func (x *ReadChunkRequest) GetOffset() uint64
func (*ReadChunkRequest) GetSize ¶
func (x *ReadChunkRequest) GetSize() uint64
func (*ReadChunkRequest) GetVersion ¶
func (x *ReadChunkRequest) GetVersion() uint64
func (*ReadChunkRequest) ProtoMessage ¶
func (*ReadChunkRequest) ProtoMessage()
func (*ReadChunkRequest) ProtoReflect ¶
func (x *ReadChunkRequest) ProtoReflect() protoreflect.Message
func (*ReadChunkRequest) Reset ¶
func (x *ReadChunkRequest) Reset()
func (*ReadChunkRequest) String ¶
func (x *ReadChunkRequest) String() string
type ReadSheetReply ¶
type ReadSheetReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Chunks []*Chunk `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks,omitempty"` // contains filtered or unexported fields }
func (*ReadSheetReply) Descriptor
deprecated
func (*ReadSheetReply) Descriptor() ([]byte, []int)
Deprecated: Use ReadSheetReply.ProtoReflect.Descriptor instead.
func (*ReadSheetReply) GetChunks ¶
func (x *ReadSheetReply) GetChunks() []*Chunk
func (*ReadSheetReply) GetStatus ¶
func (x *ReadSheetReply) GetStatus() Status
func (*ReadSheetReply) ProtoMessage ¶
func (*ReadSheetReply) ProtoMessage()
func (*ReadSheetReply) ProtoReflect ¶
func (x *ReadSheetReply) ProtoReflect() protoreflect.Message
func (*ReadSheetReply) Reset ¶
func (x *ReadSheetReply) Reset()
func (*ReadSheetReply) String ¶
func (x *ReadSheetReply) String() string
type ReadSheetRequest ¶
type ReadSheetRequest struct { Fd uint64 `protobuf:"varint,1,opt,name=fd,proto3" json:"fd,omitempty"` // contains filtered or unexported fields }
func (*ReadSheetRequest) Descriptor
deprecated
func (*ReadSheetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadSheetRequest.ProtoReflect.Descriptor instead.
func (*ReadSheetRequest) GetFd ¶
func (x *ReadSheetRequest) GetFd() uint64
func (*ReadSheetRequest) ProtoMessage ¶
func (*ReadSheetRequest) ProtoMessage()
func (*ReadSheetRequest) ProtoReflect ¶
func (x *ReadSheetRequest) ProtoReflect() protoreflect.Message
func (*ReadSheetRequest) Reset ¶
func (x *ReadSheetRequest) Reset()
func (*ReadSheetRequest) String ¶
func (x *ReadSheetRequest) String() string
type RecycleSheetReply ¶
type RecycleSheetReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*RecycleSheetReply) Descriptor
deprecated
func (*RecycleSheetReply) Descriptor() ([]byte, []int)
Deprecated: Use RecycleSheetReply.ProtoReflect.Descriptor instead.
func (*RecycleSheetReply) GetStatus ¶
func (x *RecycleSheetReply) GetStatus() Status
func (*RecycleSheetReply) ProtoMessage ¶
func (*RecycleSheetReply) ProtoMessage()
func (*RecycleSheetReply) ProtoReflect ¶
func (x *RecycleSheetReply) ProtoReflect() protoreflect.Message
func (*RecycleSheetReply) Reset ¶
func (x *RecycleSheetReply) Reset()
func (*RecycleSheetReply) String ¶
func (x *RecycleSheetReply) String() string
type RecycleSheetRequest ¶
type RecycleSheetRequest struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
func (*RecycleSheetRequest) Descriptor
deprecated
func (*RecycleSheetRequest) Descriptor() ([]byte, []int)
Deprecated: Use RecycleSheetRequest.ProtoReflect.Descriptor instead.
func (*RecycleSheetRequest) GetFilename ¶
func (x *RecycleSheetRequest) GetFilename() string
func (*RecycleSheetRequest) ProtoMessage ¶
func (*RecycleSheetRequest) ProtoMessage()
func (*RecycleSheetRequest) ProtoReflect ¶
func (x *RecycleSheetRequest) ProtoReflect() protoreflect.Message
func (*RecycleSheetRequest) Reset ¶
func (x *RecycleSheetRequest) Reset()
func (*RecycleSheetRequest) String ¶
func (x *RecycleSheetRequest) String() string
type RegisterDataNodeReply ¶
type RegisterDataNodeReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*RegisterDataNodeReply) Descriptor
deprecated
func (*RegisterDataNodeReply) Descriptor() ([]byte, []int)
Deprecated: Use RegisterDataNodeReply.ProtoReflect.Descriptor instead.
func (*RegisterDataNodeReply) GetStatus ¶
func (x *RegisterDataNodeReply) GetStatus() Status
func (*RegisterDataNodeReply) ProtoMessage ¶
func (*RegisterDataNodeReply) ProtoMessage()
func (*RegisterDataNodeReply) ProtoReflect ¶
func (x *RegisterDataNodeReply) ProtoReflect() protoreflect.Message
func (*RegisterDataNodeReply) Reset ¶
func (x *RegisterDataNodeReply) Reset()
func (*RegisterDataNodeReply) String ¶
func (x *RegisterDataNodeReply) String() string
type RegisterDataNodeRequest ¶
type RegisterDataNodeRequest struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` // contains filtered or unexported fields }
func (*RegisterDataNodeRequest) Descriptor
deprecated
func (*RegisterDataNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterDataNodeRequest.ProtoReflect.Descriptor instead.
func (*RegisterDataNodeRequest) GetAddr ¶
func (x *RegisterDataNodeRequest) GetAddr() string
func (*RegisterDataNodeRequest) ProtoMessage ¶
func (*RegisterDataNodeRequest) ProtoMessage()
func (*RegisterDataNodeRequest) ProtoReflect ¶
func (x *RegisterDataNodeRequest) ProtoReflect() protoreflect.Message
func (*RegisterDataNodeRequest) Reset ¶
func (x *RegisterDataNodeRequest) Reset()
func (*RegisterDataNodeRequest) String ¶
func (x *RegisterDataNodeRequest) String() string
type ResumeSheetReply ¶
type ResumeSheetReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ResumeSheetReply) Descriptor
deprecated
func (*ResumeSheetReply) Descriptor() ([]byte, []int)
Deprecated: Use ResumeSheetReply.ProtoReflect.Descriptor instead.
func (*ResumeSheetReply) GetStatus ¶
func (x *ResumeSheetReply) GetStatus() Status
func (*ResumeSheetReply) ProtoMessage ¶
func (*ResumeSheetReply) ProtoMessage()
func (*ResumeSheetReply) ProtoReflect ¶
func (x *ResumeSheetReply) ProtoReflect() protoreflect.Message
func (*ResumeSheetReply) Reset ¶
func (x *ResumeSheetReply) Reset()
func (*ResumeSheetReply) String ¶
func (x *ResumeSheetReply) String() string
type ResumeSheetRequest ¶
type ResumeSheetRequest struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
func (*ResumeSheetRequest) Descriptor
deprecated
func (*ResumeSheetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeSheetRequest.ProtoReflect.Descriptor instead.
func (*ResumeSheetRequest) GetFilename ¶
func (x *ResumeSheetRequest) GetFilename() string
func (*ResumeSheetRequest) ProtoMessage ¶
func (*ResumeSheetRequest) ProtoMessage()
func (*ResumeSheetRequest) ProtoReflect ¶
func (x *ResumeSheetRequest) ProtoReflect() protoreflect.Message
func (*ResumeSheetRequest) Reset ¶
func (x *ResumeSheetRequest) Reset()
func (*ResumeSheetRequest) String ¶
func (x *ResumeSheetRequest) String() string
type Sheet ¶
type Sheet struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` Recycled bool `protobuf:"varint,2,opt,name=recycled,proto3" json:"recycled,omitempty"` // contains filtered or unexported fields }
func (*Sheet) Descriptor
deprecated
func (*Sheet) GetFilename ¶
func (*Sheet) GetRecycled ¶
func (*Sheet) ProtoMessage ¶
func (*Sheet) ProtoMessage()
func (*Sheet) ProtoReflect ¶
func (x *Sheet) ProtoReflect() protoreflect.Message
type Status ¶
type Status int32
func (Status) Descriptor ¶
func (Status) Descriptor() protoreflect.EnumDescriptor
func (Status) EnumDescriptor
deprecated
func (Status) Number ¶
func (x Status) Number() protoreflect.EnumNumber
func (Status) Type ¶
func (Status) Type() protoreflect.EnumType
type UnimplementedDataNodeServer ¶
type UnimplementedDataNodeServer struct { }
UnimplementedDataNodeServer must be embedded to have forward compatible implementations.
func (UnimplementedDataNodeServer) DeleteChunk ¶
func (UnimplementedDataNodeServer) DeleteChunk(context.Context, *DeleteChunkRequest) (*DeleteChunkReply, error)
func (UnimplementedDataNodeServer) ReadChunk ¶
func (UnimplementedDataNodeServer) ReadChunk(context.Context, *ReadChunkRequest) (*ReadChunkReply, error)
func (UnimplementedDataNodeServer) WriteChunk ¶
func (UnimplementedDataNodeServer) WriteChunk(context.Context, *WriteChunkRequest) (*WriteChunkReply, error)
type UnimplementedMasterNodeServer ¶
type UnimplementedMasterNodeServer struct { }
UnimplementedMasterNodeServer must be embedded to have forward compatible implementations.
func (UnimplementedMasterNodeServer) CreateSheet ¶
func (UnimplementedMasterNodeServer) CreateSheet(context.Context, *CreateSheetRequest) (*CreateSheetReply, error)
func (UnimplementedMasterNodeServer) DeleteSheet ¶
func (UnimplementedMasterNodeServer) DeleteSheet(context.Context, *DeleteSheetRequest) (*DeleteSheetReply, error)
func (UnimplementedMasterNodeServer) ListSheets ¶
func (UnimplementedMasterNodeServer) ListSheets(context.Context, *Empty) (*ListSheetsReply, error)
func (UnimplementedMasterNodeServer) OpenSheet ¶
func (UnimplementedMasterNodeServer) OpenSheet(context.Context, *OpenSheetRequest) (*OpenSheetReply, error)
func (UnimplementedMasterNodeServer) ReadCell ¶
func (UnimplementedMasterNodeServer) ReadCell(context.Context, *ReadCellRequest) (*ReadCellReply, error)
func (UnimplementedMasterNodeServer) ReadSheet ¶
func (UnimplementedMasterNodeServer) ReadSheet(context.Context, *ReadSheetRequest) (*ReadSheetReply, error)
func (UnimplementedMasterNodeServer) RecycleSheet ¶
func (UnimplementedMasterNodeServer) RecycleSheet(context.Context, *RecycleSheetRequest) (*RecycleSheetReply, error)
func (UnimplementedMasterNodeServer) RegisterDataNode ¶
func (UnimplementedMasterNodeServer) RegisterDataNode(context.Context, *RegisterDataNodeRequest) (*RegisterDataNodeReply, error)
func (UnimplementedMasterNodeServer) ResumeSheet ¶
func (UnimplementedMasterNodeServer) ResumeSheet(context.Context, *ResumeSheetRequest) (*ResumeSheetReply, error)
func (UnimplementedMasterNodeServer) WriteCell ¶
func (UnimplementedMasterNodeServer) WriteCell(context.Context, *WriteCellRequest) (*WriteCellReply, error)
type UnsafeDataNodeServer ¶
type UnsafeDataNodeServer interface {
// contains filtered or unexported methods
}
UnsafeDataNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataNodeServer will result in compilation errors.
type UnsafeMasterNodeServer ¶
type UnsafeMasterNodeServer interface {
// contains filtered or unexported methods
}
UnsafeMasterNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MasterNodeServer will result in compilation errors.
type WriteCellReply ¶
type WriteCellReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` Cell *Cell `protobuf:"bytes,2,opt,name=cell,proto3" json:"cell,omitempty"` // contains filtered or unexported fields }
func (*WriteCellReply) Descriptor
deprecated
func (*WriteCellReply) Descriptor() ([]byte, []int)
Deprecated: Use WriteCellReply.ProtoReflect.Descriptor instead.
func (*WriteCellReply) GetCell ¶
func (x *WriteCellReply) GetCell() *Cell
func (*WriteCellReply) GetStatus ¶
func (x *WriteCellReply) GetStatus() Status
func (*WriteCellReply) ProtoMessage ¶
func (*WriteCellReply) ProtoMessage()
func (*WriteCellReply) ProtoReflect ¶
func (x *WriteCellReply) ProtoReflect() protoreflect.Message
func (*WriteCellReply) Reset ¶
func (x *WriteCellReply) Reset()
func (*WriteCellReply) String ¶
func (x *WriteCellReply) String() string
type WriteCellRequest ¶
type WriteCellRequest struct { Fd uint64 `protobuf:"varint,1,opt,name=fd,proto3" json:"fd,omitempty"` Row uint32 `protobuf:"varint,2,opt,name=row,proto3" json:"row,omitempty"` Column uint32 `protobuf:"varint,3,opt,name=column,proto3" json:"column,omitempty"` // contains filtered or unexported fields }
func (*WriteCellRequest) Descriptor
deprecated
func (*WriteCellRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteCellRequest.ProtoReflect.Descriptor instead.
func (*WriteCellRequest) GetColumn ¶
func (x *WriteCellRequest) GetColumn() uint32
func (*WriteCellRequest) GetFd ¶
func (x *WriteCellRequest) GetFd() uint64
func (*WriteCellRequest) GetRow ¶
func (x *WriteCellRequest) GetRow() uint32
func (*WriteCellRequest) ProtoMessage ¶
func (*WriteCellRequest) ProtoMessage()
func (*WriteCellRequest) ProtoReflect ¶
func (x *WriteCellRequest) ProtoReflect() protoreflect.Message
func (*WriteCellRequest) Reset ¶
func (x *WriteCellRequest) Reset()
func (*WriteCellRequest) String ¶
func (x *WriteCellRequest) String() string
type WriteChunkReply ¶
type WriteChunkReply struct { Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*WriteChunkReply) Descriptor
deprecated
func (*WriteChunkReply) Descriptor() ([]byte, []int)
Deprecated: Use WriteChunkReply.ProtoReflect.Descriptor instead.
func (*WriteChunkReply) GetStatus ¶
func (x *WriteChunkReply) GetStatus() Status
func (*WriteChunkReply) ProtoMessage ¶
func (*WriteChunkReply) ProtoMessage()
func (*WriteChunkReply) ProtoReflect ¶
func (x *WriteChunkReply) ProtoReflect() protoreflect.Message
func (*WriteChunkReply) Reset ¶
func (x *WriteChunkReply) Reset()
func (*WriteChunkReply) String ¶
func (x *WriteChunkReply) String() string
type WriteChunkRequest ¶
type WriteChunkRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` TargetSize uint64 `protobuf:"varint,4,opt,name=target_size,json=targetSize,proto3" json:"target_size,omitempty"` Version uint64 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"` Padding string `protobuf:"bytes,6,opt,name=padding,proto3" json:"padding,omitempty"` Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*WriteChunkRequest) Descriptor
deprecated
func (*WriteChunkRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteChunkRequest.ProtoReflect.Descriptor instead.
func (*WriteChunkRequest) GetData ¶
func (x *WriteChunkRequest) GetData() []byte
func (*WriteChunkRequest) GetId ¶
func (x *WriteChunkRequest) GetId() uint64
func (*WriteChunkRequest) GetOffset ¶
func (x *WriteChunkRequest) GetOffset() uint64
func (*WriteChunkRequest) GetPadding ¶
func (x *WriteChunkRequest) GetPadding() string
func (*WriteChunkRequest) GetSize ¶
func (x *WriteChunkRequest) GetSize() uint64
func (*WriteChunkRequest) GetTargetSize ¶ added in v1.0.0
func (x *WriteChunkRequest) GetTargetSize() uint64
func (*WriteChunkRequest) GetVersion ¶
func (x *WriteChunkRequest) GetVersion() uint64
func (*WriteChunkRequest) ProtoMessage ¶
func (*WriteChunkRequest) ProtoMessage()
func (*WriteChunkRequest) ProtoReflect ¶
func (x *WriteChunkRequest) ProtoReflect() protoreflect.Message
func (*WriteChunkRequest) Reset ¶
func (x *WriteChunkRequest) Reset()
func (*WriteChunkRequest) String ¶
func (x *WriteChunkRequest) String() string