Documentation ¶
Index ¶
- type Server
- func (s *Server) CreateSheet(ctx context.Context, request *fs_rpc.CreateSheetRequest) (*fs_rpc.CreateSheetReply, error)
- func (s *Server) DeleteSheet(ctx context.Context, request *fs_rpc.DeleteSheetRequest) (*fs_rpc.DeleteSheetReply, error)
- func (s *Server) ListSheets(ctx context.Context, empty *fs_rpc.Empty) (*fs_rpc.ListSheetsReply, error)
- func (s *Server) OpenSheet(ctx context.Context, request *fs_rpc.OpenSheetRequest) (*fs_rpc.OpenSheetReply, error)
- func (s *Server) ReadCell(ctx context.Context, request *fs_rpc.ReadCellRequest) (*fs_rpc.ReadCellReply, error)
- func (s *Server) ReadSheet(ctx context.Context, request *fs_rpc.ReadSheetRequest) (*fs_rpc.ReadSheetReply, error)
- func (s *Server) RecycleSheet(ctx context.Context, request *fs_rpc.RecycleSheetRequest) (*fs_rpc.RecycleSheetReply, error)
- func (s *Server) RegisterDataNode(ctx context.Context, request *fs_rpc.RegisterDataNodeRequest) (*fs_rpc.RegisterDataNodeReply, error)
- func (s *Server) ResumeSheet(ctx context.Context, request *fs_rpc.ResumeSheetRequest) (*fs_rpc.ResumeSheetReply, error)
- func (s *Server) WriteCell(ctx context.Context, request *fs_rpc.WriteCellRequest) (*fs_rpc.WriteCellReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶ added in v1.0.0
type Server struct { fs_rpc.UnimplementedMasterNodeServer // contains filtered or unexported fields }
func NewServer ¶
func NewServer(fm *filemgr.FileManager, alloc *datanode_alloc.DataNodeAllocator) (*Server, error)
NewServer
@para
fm: a initialized FileManager
@return
*server: initialized server error: errors during auto migration.
func (*Server) CreateSheet ¶ added in v1.0.0
func (s *Server) CreateSheet(ctx context.Context, request *fs_rpc.CreateSheetRequest) (*fs_rpc.CreateSheetReply, error)
func (*Server) DeleteSheet ¶ added in v1.0.0
func (s *Server) DeleteSheet(ctx context.Context, request *fs_rpc.DeleteSheetRequest) (*fs_rpc.DeleteSheetReply, error)
func (*Server) ListSheets ¶ added in v1.0.0
func (*Server) OpenSheet ¶ added in v1.0.0
func (s *Server) OpenSheet(ctx context.Context, request *fs_rpc.OpenSheetRequest) (*fs_rpc.OpenSheetReply, error)
func (*Server) ReadCell ¶ added in v1.0.0
func (s *Server) ReadCell(ctx context.Context, request *fs_rpc.ReadCellRequest) (*fs_rpc.ReadCellReply, error)
func (*Server) ReadSheet ¶ added in v1.0.0
func (s *Server) ReadSheet(ctx context.Context, request *fs_rpc.ReadSheetRequest) (*fs_rpc.ReadSheetReply, error)
func (*Server) RecycleSheet ¶ added in v1.0.0
func (s *Server) RecycleSheet(ctx context.Context, request *fs_rpc.RecycleSheetRequest) (*fs_rpc.RecycleSheetReply, error)
func (*Server) RegisterDataNode ¶ added in v1.0.0
func (s *Server) RegisterDataNode(ctx context.Context, request *fs_rpc.RegisterDataNodeRequest) (*fs_rpc.RegisterDataNodeReply, error)
func (*Server) ResumeSheet ¶ added in v1.0.0
func (s *Server) ResumeSheet(ctx context.Context, request *fs_rpc.ResumeSheetRequest) (*fs_rpc.ResumeSheetReply, error)
func (*Server) WriteCell ¶ added in v1.0.0
func (s *Server) WriteCell(ctx context.Context, request *fs_rpc.WriteCellRequest) (*fs_rpc.WriteCellReply, error)
Click to show internal directories.
Click to hide internal directories.