pool

type Cluster interface {
	AddDagNode(nodeConfig *config.DagNodeConfig) error
	GetDagNode(dagNodeName string) (*config.DagNodeConfig, error)
	RemoveDagNode(dagNodeName string) (*config.DagNodeConfig, error)
	MigrateSlots(fromDagNodeName, toDagNodeName string, pairs []slotsmgr.SlotPair) error
	BalanceSlots() error
	Status() (*proto.StatusReply, error)
	RepairDataNode(ctx context.Context, dagNodeName string, fromNodeIndex int, repairNodeIndex int) error
}

type DagPool interface {
	Add(ctx context.Context, block blocks.Block, user string, password string, pin bool) error
	Get(ctx context.Context, c cid.Cid, user string, password string) (blocks.Block, error)
	GetSize(ctx context.Context, c cid.Cid, user string, password string) (int, error)
	Remove(ctx context.Context, c cid.Cid, user string, password string, unpin bool) error
	AddUser(newUser dpuser.DagPoolUser, user string, password string) error
	RemoveUser(rmUser string, user string, password string) error
	QueryUser(qUser string, user string, password string) (*dpuser.DagPoolUser, error)
	UpdateUser(uUser dpuser.DagPoolUser, user string, password string) error
	Close() error
}