mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-09-06 08:35:55 +00:00
d971cfc269
* Database isolation: Balancer Remove naive Balancer remove debugging lines Thread dax.Transaction through Controller Change role to roleType Swap out Balancer interface with new one Standardize InvalidTransaction error Add some interface comments * Remove type.Worker; replace with type.Address * Remove database validate from Queryer This is already being handled in the `CreateTable()` method. Prior to doing that validation, we were getting a panic, but that's no longer the case. * Remove dax.TableQualifier; replace with dax.QualifiedDatabaseID * Update IDK test to create database
114 lines
2.4 KiB
Go
114 lines
2.4 KiB
Go
package controller
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/molecula/featurebase/v3/dax"
|
|
"github.com/molecula/featurebase/v3/errors"
|
|
)
|
|
|
|
// pUnit represents a table/partition combination. As a Stringer, it can be
|
|
// used as a job in the Balancer.
|
|
type pUnit struct {
|
|
t dax.TableKey
|
|
p dax.PartitionNum
|
|
}
|
|
|
|
func (p pUnit) String() string {
|
|
return fmt.Sprintf("%s|part_%d", p.t, p.p)
|
|
}
|
|
|
|
func (p pUnit) Job() dax.Job {
|
|
return dax.Job(fmt.Sprintf("%s|part_%d", p.t, p.p))
|
|
}
|
|
|
|
func (p pUnit) table() dax.TableKey {
|
|
return p.t
|
|
}
|
|
|
|
func (p pUnit) partitionNum() dax.PartitionNum {
|
|
return p.p
|
|
}
|
|
|
|
func partition(t dax.TableKey, p dax.PartitionNum) pUnit {
|
|
return pUnit{t, p}
|
|
}
|
|
|
|
func partitions(t dax.TableKey, p ...dax.PartitionNum) []pUnit {
|
|
ret := make([]pUnit, 0, len(p))
|
|
for _, vp := range p {
|
|
ret = append(ret, pUnit{t, vp})
|
|
}
|
|
return ret
|
|
}
|
|
|
|
func decodePartition(j dax.Job) (pUnit, error) {
|
|
s := string(j)
|
|
parts := strings.Split(s, "|")
|
|
if len(parts) != 2 {
|
|
return pUnit{}, errors.Errorf("cannot decode string to partition: %s", s)
|
|
}
|
|
pparts := strings.Split(parts[1], "_")
|
|
if len(pparts) != 2 {
|
|
return pUnit{}, errors.Errorf("cannot decode partition part of string: %s", pparts[1])
|
|
}
|
|
intVar, err := strconv.Atoi(pparts[1])
|
|
if err != nil {
|
|
return pUnit{}, errors.Wrap(err, "converting string to int")
|
|
}
|
|
|
|
return pUnit{
|
|
t: dax.TableKey(parts[0]),
|
|
p: dax.PartitionNum(intVar),
|
|
}, nil
|
|
}
|
|
|
|
// sUnit represents a table/shard combination. As a Stringer, it can be used as
|
|
// a job in the Balancer.
|
|
type sUnit struct {
|
|
t dax.TableKey
|
|
s dax.ShardNum
|
|
}
|
|
|
|
func (s sUnit) String() string {
|
|
return fmt.Sprintf("%s|shard_%s", s.t, s.s)
|
|
}
|
|
|
|
func (s sUnit) Job() dax.Job {
|
|
return dax.Job(fmt.Sprintf("%s|shard_%s", s.t, s.s))
|
|
}
|
|
|
|
func (s sUnit) table() dax.TableKey {
|
|
return s.t
|
|
}
|
|
|
|
func (s sUnit) shardNum() dax.ShardNum {
|
|
return s.s
|
|
}
|
|
|
|
func shard(t dax.TableKey, s dax.ShardNum) sUnit {
|
|
return sUnit{t, s}
|
|
}
|
|
|
|
func decodeShard(j dax.Job) (sUnit, error) {
|
|
s := string(j)
|
|
parts := strings.Split(s, "|")
|
|
if len(parts) != 2 {
|
|
return sUnit{}, errors.Errorf("cannot decode string to shardV: %s", s)
|
|
}
|
|
pparts := strings.Split(parts[1], "_")
|
|
if len(pparts) != 2 {
|
|
return sUnit{}, errors.Errorf("cannot decode shard part of string: %s", pparts[1])
|
|
}
|
|
uint64Var, err := strconv.ParseUint(pparts[1], 10, 64)
|
|
if err != nil {
|
|
return sUnit{}, errors.Wrap(err, "converting string to int")
|
|
}
|
|
|
|
return sUnit{
|
|
t: dax.TableKey(parts[0]),
|
|
s: dax.ShardNum(uint64Var),
|
|
}, nil
|
|
}
|