scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixed function rename :)

Browse source
This commit is contained in:
rutherford-jasper 2023-04-10 10:50:09 -05:00
parent 62e0b3197f
commit e8fd63cb10
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
dax/controller/balancer.go
View file

@ -47,8 +47,8 @@ type Balancer interface {
// Nodes returns all nodes known by the Balancer.
Nodes(tx dax.Transaction) ([]*dax.Node, error)
// GetDatabaseWorkerCount returns the number of workers
GetDatabaseWorkerCount(tx dax.Transaction, qdbid dax.QualifiedDatabaseID) (int, error)
// WorkerCount returns the number of workers
WorkerCount(tx dax.Transaction, qdbid dax.QualifiedDatabaseID) (int, error)
}
// Ensure type implements interface.
@ -97,6 +97,6 @@ func (b *NopBalancer) ReadNode(tx dax.Transaction, addr dax.Address) (*dax.Node,
func (b *NopBalancer) Nodes(tx dax.Transaction) ([]*dax.Node, error) {
return []*dax.Node{}, nil
}
func (b *NopBalancer) GetDatabaseWorkerCount(tx dax.Transaction, qdbid dax.QualifiedDatabaseID) (int, error) {
func (b *NopBalancer) WorkerCount(tx dax.Transaction, qdbid dax.QualifiedDatabaseID) (int, error) {
return 0, nil
}

2
dax/controller/controller.go
View file

@ -793,7 +793,7 @@ func (c *Controller) GetDatabaseWorkerCount(ctx context.Context, qdbid dax.Quali
}
defer tx.Rollback()
return c.Balancer.GetDatabaseWorkerCount(tx, qdbid)
return c.Balancer.WorkerCount(tx, qdbid)
}
// CreateTable adds a table to the schemar, and then sends directives to all