server

Documentation

Index

• type DagPoolClusterServer
  • func (s *DagPoolClusterServer) AddDagNode(ctx context.Context, node *proto.DagNodeInfo) (*emptypb.Empty, error)
  • func (s *DagPoolClusterServer) BalanceSlots(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  • func (s *DagPoolClusterServer) GetDagNode(ctx context.Context, req *proto.GetDagNodeReq) (*proto.DagNodeInfo, error)
  • func (s *DagPoolClusterServer) MigrateSlots(ctx context.Context, req *proto.MigrateSlotsReq) (*emptypb.Empty, error)
  • func (s *DagPoolClusterServer) RemoveDagNode(ctx context.Context, req *proto.RemoveDagNodeReq) (*proto.DagNodeInfo, error)
  • func (s *DagPoolClusterServer) RepairDataNode(ctx context.Context, req *proto.RepairDataNodeReq) (*emptypb.Empty, error)
  • func (s *DagPoolClusterServer) Status(context.Context, *emptypb.Empty) (*proto.StatusReply, error)
• type DagPoolServer
  • func (s *DagPoolServer) Add(ctx context.Context, in *proto.AddReq) (*proto.AddReply, error)
  • func (s *DagPoolServer) AddUser(ctx context.Context, in *proto.AddUserReq) (*proto.AddUserReply, error)
  • func (s *DagPoolServer) Get(ctx context.Context, in *proto.GetReq) (*proto.GetReply, error)
  • func (s *DagPoolServer) GetSize(ctx context.Context, in *proto.GetSizeReq) (*proto.GetSizeReply, error)
  • func (s *DagPoolServer) QueryUser(ctx context.Context, in *proto.QueryUserReq) (*proto.QueryUserReply, error)
  • func (s *DagPoolServer) Remove(ctx context.Context, in *proto.RemoveReq) (*proto.RemoveReply, error)
  • func (s *DagPoolServer) RemoveUser(ctx context.Context, in *proto.RemoveUserReq) (*proto.RemoveUserReply, error)
  • func (s *DagPoolServer) UpdateUser(ctx context.Context, in *proto.UpdateUserReq) (*proto.UpdateUserReply, error)

Types

type DagPoolClusterServer

type DagPoolClusterServer struct {
	proto.UnimplementedDagPoolClusterServer
	Cluster pool.Cluster
}

DagPoolClusterServer is used to implement DagPoolClusterServer.

func (*DagPoolClusterServer) AddDagNode

func (s *DagPoolClusterServer) AddDagNode(ctx context.Context, node *proto.DagNodeInfo) (*emptypb.Empty, error)

func (*DagPoolClusterServer) BalanceSlots

func (s *DagPoolClusterServer) BalanceSlots(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*DagPoolClusterServer) GetDagNode

func (s *DagPoolClusterServer) GetDagNode(ctx context.Context, req *proto.GetDagNodeReq) (*proto.DagNodeInfo, error)

func (*DagPoolClusterServer) MigrateSlots

func (s *DagPoolClusterServer) MigrateSlots(ctx context.Context, req *proto.MigrateSlotsReq) (*emptypb.Empty, error)

func (*DagPoolClusterServer) RemoveDagNode

func (s *DagPoolClusterServer) RemoveDagNode(ctx context.Context, req *proto.RemoveDagNodeReq) (*proto.DagNodeInfo, error)

func (*DagPoolClusterServer) RepairDataNode

func (s *DagPoolClusterServer) RepairDataNode(ctx context.Context, req *proto.RepairDataNodeReq) (*emptypb.Empty, error)

func (*DagPoolClusterServer) Status

func (s *DagPoolClusterServer) Status(context.Context, *emptypb.Empty) (*proto.StatusReply, error)

type DagPoolServer

type DagPoolServer struct {
	proto.UnimplementedDagPoolServer
	DagPool pool.DagPool
}

DagPoolServer is used to implement DagPoolServer.

func (*DagPoolServer) Add

func (s *DagPoolServer) Add(ctx context.Context, in *proto.AddReq) (*proto.AddReply, error)

Add is used to add a block to the dag pool server

func (*DagPoolServer) AddUser

func (s *DagPoolServer) AddUser(ctx context.Context, in *proto.AddUserReq) (*proto.AddUserReply, error)

AddUser is used to add a user to the dag pool server

func (*DagPoolServer) Get

func (s *DagPoolServer) Get(ctx context.Context, in *proto.GetReq) (*proto.GetReply, error)

Get is used to get a block from the dag pool server

func (*DagPoolServer) GetSize

func (s *DagPoolServer) GetSize(ctx context.Context, in *proto.GetSizeReq) (*proto.GetSizeReply, error)

GetSize is used to get the size of the block

func (*DagPoolServer) QueryUser

func (s *DagPoolServer) QueryUser(ctx context.Context, in *proto.QueryUserReq) (*proto.QueryUserReply, error)

QueryUser is used to query a user from the dag pool server

func (*DagPoolServer) Remove

func (s *DagPoolServer) Remove(ctx context.Context, in *proto.RemoveReq) (*proto.RemoveReply, error)

Remove is used to remove a block from the dag pool server

func (*DagPoolServer) RemoveUser

func (s *DagPoolServer) RemoveUser(ctx context.Context, in *proto.RemoveUserReq) (*proto.RemoveUserReply, error)

RemoveUser is used to remove a user from the dag pool server

func (*DagPoolServer) UpdateUser

func (s *DagPoolServer) UpdateUser(ctx context.Context, in *proto.UpdateUserReq) (*proto.UpdateUserReply, error)

UpdateUser is used to update a user from the dag pool server