fs_rpc

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
}

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
}

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
}

type CreateSheetRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

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)
}

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
}

type DeleteChunkReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type DeleteChunkRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteSheetReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type DeleteSheetRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

type Empty struct {
	// contains filtered or unexported fields
}

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
}

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)
}

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
}

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
}

type OpenSheetRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

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
}

type ReadSheetRequest struct {
	Fd uint64 `protobuf:"varint,1,opt,name=fd,proto3" json:"fd,omitempty"`
	// contains filtered or unexported fields
}

type RecycleSheetReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type RecycleSheetRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

type RegisterDataNodeReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type RegisterDataNodeRequest struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

type ResumeSheetReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ResumeSheetRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

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
}

type Status int32

type UnimplementedDataNodeServer struct {
}

type UnimplementedMasterNodeServer struct {
}

type UnsafeDataNodeServer interface {
	// contains filtered or unexported methods
}

type UnsafeMasterNodeServer interface {
	// contains filtered or unexported methods
}

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
}

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
}

type WriteChunkReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=sheetfs.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

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
}