controller

package

Go to main page

Versions in this module

v3

v3.29.0

Jan 25, 2023

Changes in this version

+ func NewNopNodeService() *nopNodeService

type AddressSet

+ func (s AddressSet) Merge(o AddressSet)

type Balancer

+ BalanceDatabase func(tx dax.Transaction, qdbid dax.QualifiedDatabaseID) ([]dax.WorkerDiff, error)

+ Nodes func(tx dax.Transaction) ([]*dax.Node, error)

+ ReadNode func(tx dax.Transaction, addr dax.Address) (*dax.Node, error)

+ WorkersForTable func(tx dax.Transaction, roleType dax.RoleType, qtid dax.QualifiedTableID) ([]dax.WorkerInfo, error)

type Config

+ Balancer Balancer

+ SnapshotterDir string

+ WriteloggerDir string

type Controller

+ Balancer Balancer

+ Snapshotter *snapshotter.Snapshotter

+ Writelogger *writelogger.Writelogger

+ func (c *Controller) CreateDatabase(ctx context.Context, qdb *dax.QualifiedDatabase) error

+ func (c *Controller) CreateNode(context.Context, dax.Address, *dax.Node) error

+ func (c *Controller) DatabaseByID(ctx context.Context, qdbid dax.QualifiedDatabaseID) (*dax.QualifiedDatabase, error)

+ func (c *Controller) DatabaseByName(ctx context.Context, orgID dax.OrganizationID, dbname dax.DatabaseName) (*dax.QualifiedDatabase, error)

+ func (c *Controller) Databases(ctx context.Context, orgID dax.OrganizationID, ids ...dax.DatabaseID) ([]*dax.QualifiedDatabase, error)

+ func (c *Controller) DeleteNode(context.Context, dax.Address) error

+ func (c *Controller) DropDatabase(ctx context.Context, qdbid dax.QualifiedDatabaseID) error

+ func (c *Controller) IngestShard(ctx context.Context, qtid dax.QualifiedTableID, shrdNum dax.ShardNum) (dax.Address, error)

+ func (c *Controller) ReadNode(context.Context, dax.Address) (*dax.Node, error)

+ func (c *Controller) SetDatabaseOptions(ctx context.Context, qdbid dax.QualifiedDatabaseID, opts dax.DatabaseOptions) error

+ func (c *Controller) TableByID(ctx context.Context, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error)

+ func (c *Controller) TableByName(ctx context.Context, qdbid dax.QualifiedDatabaseID, name dax.TableName) (*dax.QualifiedTable, error)

+ func (c *Controller) TableID(ctx context.Context, qdbid dax.QualifiedDatabaseID, name dax.TableName) (dax.QualifiedTableID, error)

+ type NodeService interface

+ CreateNode func(dax.Transaction, dax.Address, *dax.Node) error

+ DeleteNode func(dax.Transaction, dax.Address) error

+ Nodes func(dax.Transaction) ([]*dax.Node, error)

+ ReadNode func(dax.Transaction, dax.Address) (*dax.Node, error)

type NopBalancer

+ func (b *NopBalancer) BalanceDatabase(tx dax.Transaction, qdbid dax.QualifiedDatabaseID) ([]dax.WorkerDiff, error)

+ func (b *NopBalancer) Nodes(tx dax.Transaction) ([]*dax.Node, error)

+ func (b *NopBalancer) ReadNode(tx dax.Transaction, addr dax.Address) (*dax.Node, error)

+ func (b *NopBalancer) WorkersForTable(tx dax.Transaction, roleType dax.RoleType, qtid dax.QualifiedTableID) ([]dax.WorkerInfo, error)

v3.27.0

Jan 12, 2023

Changes in this version

type Balancer

+ RemoveJobs func(ctx context.Context, prefix string) ([]dax.WorkerDiff, error)

type Config

+ SnappingTurtleTimeout time.Duration

type NopBalancer

+ func (b *NopBalancer) RemoveJobs(ctx context.Context, prefix string) ([]dax.WorkerDiff, error)

v3.26.0

Dec 12, 2022

Changes in this version

+ const ErrCodeCustom

+ const ErrCodeDirectiveSendFailure

+ const ErrCodeInternal

+ const ErrCodeInvalidRequest

+ const ErrCodeNoAvailableNode

+ const ErrCodeNodeExists

+ const ErrCodeNodeKeyInvalid

+ const ErrCodeRoleTypeInvalid

+ const ErrCodeTODO

+ const ErrCodeUnassignedJobs

+ const UndefinedErrorMessage

+ func NewErrCustom() error

+ func NewErrDirectiveSendFailure(msg string) error

+ func NewErrInternal(msg string) error

+ func NewErrInvalidRequest(msg string) error

+ func NewErrNoAvailableNode() error

+ func NewErrNodeExists(addr dax.Address) error

+ func NewErrNodeKeyInvalid(addr dax.Address) error

+ func NewErrRoleTypeInvalid(roleType dax.RoleType) error

+ func NewErrUnassignedJobs(jobs []dax.Job) error

+ type AddressSet map[dax.Address]struct

+ func NewAddressSet() AddressSet

+ func (s AddressSet) Add(p dax.Address)

+ func (s AddressSet) Contains(p dax.Address) bool

+ func (s AddressSet) Minus(m AddressSet) []dax.Address

+ func (s AddressSet) Remove(p dax.Address)

+ func (s AddressSet) SortedSlice() []dax.Address

+ type Balancer interface

+ AddJobs func(ctx context.Context, job ...fmt.Stringer) ([]dax.WorkerDiff, error)

+ AddWorker func(ctx context.Context, worker fmt.Stringer) ([]dax.WorkerDiff, error)

+ Balance func(ctx context.Context) ([]dax.WorkerDiff, error)

+ CurrentState func(ctx context.Context) ([]dax.WorkerInfo, error)

+ RemoveJob func(ctx context.Context, job fmt.Stringer) ([]dax.WorkerDiff, error)

+ RemoveWorker func(ctx context.Context, worker fmt.Stringer) ([]dax.WorkerDiff, error)

+ WorkerState func(ctx context.Context, worker dax.Worker) (dax.WorkerInfo, error)

+ WorkersForJobPrefix func(ctx context.Context, prefix string) ([]dax.WorkerInfo, error)

+ WorkersForJobs func(ctx context.Context, jobs []dax.Job) ([]dax.WorkerInfo, error)

+ type ComputeNode struct

+ Address dax.Address

+ Shards dax.ShardNums

+ Table dax.TableKey

+ type Config struct

+ BoltDB *boltdb.DB

+ ComputeBalancer Balancer

+ Director Director

+ Logger logger.Logger

+ RegistrationBatchTimeout time.Duration

+ Schemar schemar.Schemar

+ StorageMethod string

+ TranslateBalancer Balancer

+ type Controller struct

+ ComputeBalancer Balancer

+ Director Director

+ Schemar schemar.Schemar

+ TranslateBalancer Balancer

+ func New(cfg Config) *Controller

+ func (c *Controller) AddAddresses(ctx context.Context, addrs ...dax.Address) error

+ func (c *Controller) AddShards(ctx context.Context, qtid dax.QualifiedTableID, shards ...dax.VersionedShard) error

+ func (c *Controller) CheckInNode(ctx context.Context, n *dax.Node) error

+ func (c *Controller) ComputeNodes(ctx context.Context, qtid dax.QualifiedTableID, shards dax.ShardNums, ...) ([]ComputeNode, error)

+ func (c *Controller) CreateField(ctx context.Context, qtid dax.QualifiedTableID, fld *dax.Field) error

+ func (c *Controller) CreateTable(ctx context.Context, qtbl *dax.QualifiedTable) error

+ func (c *Controller) DebugNodes(ctx context.Context) ([]*dax.Node, error)

+ func (c *Controller) DeregisterNodes(ctx context.Context, addresses ...dax.Address) error

+ func (c *Controller) DropField(ctx context.Context, qtid dax.QualifiedTableID, fldName dax.FieldName) error

+ func (c *Controller) DropTable(ctx context.Context, qtid dax.QualifiedTableID) error

+ func (c *Controller) IngestPartition(ctx context.Context, qtid dax.QualifiedTableID, partition dax.PartitionNum) (dax.Address, error)

+ func (c *Controller) InitializePoller(ctx context.Context) error

+ func (c *Controller) Nodes(ctx context.Context, role dax.Role, createMissing bool) ([]dax.AssignedNode, error)

+ func (c *Controller) RegisterNode(ctx context.Context, n *dax.Node) error

+ func (c *Controller) RegisterNodes(ctx context.Context, nodes ...*dax.Node) error

+ func (c *Controller) RemoveAddresses(ctx context.Context, addrs ...dax.Address) error

+ func (c *Controller) RemoveShards(ctx context.Context, qtid dax.QualifiedTableID, shards ...dax.VersionedShard) error

+ func (c *Controller) Run() error

+ func (c *Controller) SetPoller(poller dax.AddressManager)

+ func (c *Controller) SnapshotFieldKeys(ctx context.Context, qtid dax.QualifiedTableID, field dax.FieldName) error

+ func (c *Controller) SnapshotShardData(ctx context.Context, qtid dax.QualifiedTableID, shardNum dax.ShardNum) error

+ func (c *Controller) SnapshotTable(ctx context.Context, qtid dax.QualifiedTableID) error

+ func (c *Controller) SnapshotTableKeys(ctx context.Context, qtid dax.QualifiedTableID, partitionNum dax.PartitionNum) error

+ func (c *Controller) Stop()

+ func (c *Controller) Table(ctx context.Context, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error)

+ func (c *Controller) Tables(ctx context.Context, qual dax.TableQualifier, ids ...dax.TableID) ([]*dax.QualifiedTable, error)

+ func (c *Controller) TranslateNodes(ctx context.Context, qtid dax.QualifiedTableID, partitions dax.PartitionNums, ...) ([]TranslateNode, error)

+ type Director interface

+ SendDirective func(ctx context.Context, dir *dax.Directive) error

+ SendSnapshotFieldKeysRequest func(ctx context.Context, req *dax.SnapshotFieldKeysRequest) error

+ SendSnapshotShardDataRequest func(ctx context.Context, req *dax.SnapshotShardDataRequest) error

+ SendSnapshotTableKeysRequest func(ctx context.Context, req *dax.SnapshotTableKeysRequest) error

+ type NewBalancerFn func(string, logger.Logger) Balancer

+ type NopBalancer struct

+ func NewNopBalancer() *NopBalancer

+ func (b *NopBalancer) AddJobs(ctx context.Context, job ...fmt.Stringer) ([]dax.WorkerDiff, error)

+ func (b *NopBalancer) AddWorker(ctx context.Context, worker fmt.Stringer) ([]dax.WorkerDiff, error)

+ func (b *NopBalancer) Balance(ctx context.Context) ([]dax.WorkerDiff, error)

+ func (b *NopBalancer) CurrentState(ctx context.Context) ([]dax.WorkerInfo, error)

+ func (b *NopBalancer) RemoveJob(ctx context.Context, job fmt.Stringer) ([]dax.WorkerDiff, error)

+ func (b *NopBalancer) RemoveWorker(ctx context.Context, worker fmt.Stringer) ([]dax.WorkerDiff, error)

+ func (b *NopBalancer) WorkerState(ctx context.Context, worker dax.Worker) (dax.WorkerInfo, error)

+ func (b *NopBalancer) WorkersForJobPrefix(ctx context.Context, prefix string) ([]dax.WorkerInfo, error)

+ func (b *NopBalancer) WorkersForJobs(ctx context.Context, jobs []dax.Job) ([]dax.WorkerInfo, error)

+ type NopDirector struct

+ func NewNopDirector() *NopDirector

+ func (d *NopDirector) SendDirective(ctx context.Context, dir *dax.Directive) error

+ func (d *NopDirector) SendSnapshotFieldKeysRequest(ctx context.Context, req *dax.SnapshotFieldKeysRequest) error

+ func (d *NopDirector) SendSnapshotShardDataRequest(ctx context.Context, req *dax.SnapshotShardDataRequest) error

+ func (d *NopDirector) SendSnapshotTableKeysRequest(ctx context.Context, req *dax.SnapshotTableKeysRequest) error

+ type StringSet map[string]struct

+ func NewStringSet() StringSet

+ func (s StringSet) Add(p string)

+ func (s StringSet) Contains(p string) bool

+ func (s StringSet) Minus(m StringSet) []string

+ func (s StringSet) Remove(p string)

+ func (s StringSet) SortedSlice() []string

+ type TableSet map[dax.TableKey]struct

+ func NewTableSet() TableSet

+ func (s TableSet) Add(t dax.TableKey)

+ func (s TableSet) Contains(t dax.TableKey) bool

+ func (s TableSet) Minus(m TableSet) dax.TableKeys

+ func (s TableSet) QualifiedSortedSlice() map[dax.TableQualifier]dax.TableIDs

+ func (s TableSet) Remove(t dax.TableKey)

+ func (s TableSet) SortedSlice() dax.TableKeys

+ type TranslateNode struct

+ Address dax.Address

+ Partitions dax.PartitionNums

+ Table dax.TableKey

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL