mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-08-28 10:54:59 +00:00
9e67f1dddd
* slowly making a serverless systemAPI for ClusterNodes() * implemented some methods for fb_database_info * fixed linting * fixed comments
58 lines
1.2 KiB
Go
58 lines
1.2 KiB
Go
package queryer
|
|
|
|
import (
|
|
"context"
|
|
|
|
featurebase "github.com/featurebasedb/featurebase/v3"
|
|
"github.com/featurebasedb/featurebase/v3/dax"
|
|
)
|
|
|
|
// systemAPI is an implementation of the systemAPI.
|
|
type systemAPI struct {
|
|
featurebase.NopSystemAPI
|
|
controller dax.Controller
|
|
qdbid dax.QualifiedDatabaseID
|
|
}
|
|
|
|
func newSystemAPI(c dax.Controller, qdbid dax.QualifiedDatabaseID) *systemAPI {
|
|
return &systemAPI{
|
|
controller: c,
|
|
qdbid: qdbid,
|
|
}
|
|
}
|
|
|
|
// ClusterNodes returns a list of featurebase.ClusterNodes
|
|
// with length of the minimum number of workers
|
|
func (s *systemAPI) ClusterNodes() []featurebase.ClusterNode {
|
|
|
|
ctx := context.Background()
|
|
|
|
qdb, err := s.controller.DatabaseByID(ctx, s.qdbid)
|
|
if err != nil {
|
|
return []featurebase.ClusterNode{}
|
|
}
|
|
out := make([]featurebase.ClusterNode, qdb.Options.WorkersMin)
|
|
return out
|
|
}
|
|
|
|
func (s *systemAPI) PlatformDescription() string {
|
|
return "Serverless"
|
|
}
|
|
|
|
func (s *systemAPI) ClusterName() string {
|
|
return "Serverless"
|
|
}
|
|
|
|
func (s *systemAPI) ClusterNodeCount() int {
|
|
ctx := context.Background()
|
|
|
|
qdb, err := s.controller.DatabaseByID(ctx, s.qdbid)
|
|
if err != nil {
|
|
return -1
|
|
}
|
|
return qdb.Options.WorkersMin
|
|
}
|
|
|
|
func (s *systemAPI) ClusterState() string {
|
|
return "NORMAL"
|
|
}
|