Documentation
¶
Overview ¶
Package boltdb contains the boltdb implementation of the Balancer interface.
Index ¶
- Variables
- func NewBalancer(db *boltdb.DB, schemar schemar.Schemar, logger logger.Logger) *balancer.Balancer
- type NodeService
- func (s *NodeService) CreateNode(tx dax.Transaction, addr dax.Address, node *dax.Node) error
- func (s *NodeService) DeleteNode(tx dax.Transaction, addr dax.Address) error
- func (s *NodeService) Nodes(tx dax.Transaction) ([]*dax.Node, error)
- func (s *NodeService) ReadNode(tx dax.Transaction, addr dax.Address) (*dax.Node, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var BalancerBuckets []boltdb.Bucket = []boltdb.Bucket{
bucketBalancer,
}
BalancerBuckets defines the buckets used by this package. It can be called during setup to create the buckets ahead of time.
Functions ¶
Types ¶
type NodeService ¶
type NodeService struct {
// contains filtered or unexported fields
}
NodeService represents a service for managing nodes.
func NewNodeService ¶
func NewNodeService(db *boltdb.DB, logger logger.Logger) *NodeService
NewNodeService returns a new instance of NodeService with default values.
func (*NodeService) CreateNode ¶
func (s *NodeService) CreateNode(tx dax.Transaction, addr dax.Address, node *dax.Node) error
func (*NodeService) DeleteNode ¶
func (s *NodeService) DeleteNode(tx dax.Transaction, addr dax.Address) error
func (*NodeService) Nodes ¶
func (s *NodeService) Nodes(tx dax.Transaction) ([]*dax.Node, error)
func (*NodeService) ReadNode ¶
func (s *NodeService) ReadNode(tx dax.Transaction, addr dax.Address) (*dax.Node, error)
Click to show internal directories.
Click to hide internal directories.