fs_rpc

package
Version: v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 16, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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)

View Source
var File_protocol_sheetfs_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Cell.ProtoReflect.Descriptor instead.

func (*Cell) GetChunk

func (x *Cell) GetChunk() *Chunk

func (*Cell) GetOffset

func (x *Cell) GetOffset() uint64

func (*Cell) GetSize

func (x *Cell) GetSize() uint64

func (*Cell) ProtoMessage

func (*Cell) ProtoMessage()

func (*Cell) ProtoReflect

func (x *Cell) ProtoReflect() protoreflect.Message

func (*Cell) Reset

func (x *Cell) Reset()

func (*Cell) String

func (x *Cell) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetDatanode

func (x *Chunk) GetDatanode() string

func (*Chunk) GetHoldsMeta

func (x *Chunk) GetHoldsMeta() bool

func (*Chunk) GetId

func (x *Chunk) GetId() uint64

func (*Chunk) GetVersion

func (x *Chunk) GetVersion() uint64

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect

func (x *Chunk) ProtoReflect() protoreflect.Message

func (*Chunk) Reset

func (x *Chunk) Reset()

func (*Chunk) String

func (x *Chunk) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Sheet.ProtoReflect.Descriptor instead.

func (*Sheet) GetFilename

func (x *Sheet) GetFilename() string

func (*Sheet) GetRecycled

func (x *Sheet) GetRecycled() bool

func (*Sheet) ProtoMessage

func (*Sheet) ProtoMessage()

func (*Sheet) ProtoReflect

func (x *Sheet) ProtoReflect() protoreflect.Message

func (*Sheet) Reset

func (x *Sheet) Reset()

func (*Sheet) String

func (x *Sheet) String() string

type Status

type Status int32
const (
	Status_OK           Status = 0
	Status_Exist        Status = 1
	Status_NotFound     Status = 2
	Status_WrongVersion Status = 3
	Status_Invalid      Status = 4
	Status_Unavailable  Status = 5
)

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

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

func (UnimplementedDataNodeServer) WriteChunk

type UnimplementedMasterNodeServer

type UnimplementedMasterNodeServer struct {
}

UnimplementedMasterNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedMasterNodeServer) CreateSheet

func (UnimplementedMasterNodeServer) DeleteSheet

func (UnimplementedMasterNodeServer) ListSheets

func (UnimplementedMasterNodeServer) OpenSheet

func (UnimplementedMasterNodeServer) ReadCell

func (UnimplementedMasterNodeServer) ReadSheet

func (UnimplementedMasterNodeServer) RecycleSheet

func (UnimplementedMasterNodeServer) RegisterDataNode

func (UnimplementedMasterNodeServer) ResumeSheet

func (UnimplementedMasterNodeServer) WriteCell

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL