puzzledb

May 21, 2024

Changes in this version

type Server

+ func (server *Server) IsTLSEnabled() bool

May 18, 2024

Changes in this version

+ const ConfigTLS

type Server

+ func (server *Server) SetTLSConfig(tlsConfig *std_tls.Config)

+ func (server *Server) TLSConfig() (*std_tls.Config, bool)

Dec 30, 2023

Changes in this version

+ const ConfigAuth

type PluginManager

+ func (mgr *PluginManager) AuthenticatorServices() ([]auth.Service, error)

+ func (mgr *PluginManager) EnabledAuthenticatorServices() []auth.Service

Nov 14, 2023

Changes in this version

type Config

+ UsedConfigFile func() string

type PluginManager

+ func (mgr *PluginManager) EnabledKvCacheStoreServices() []kvcache.Service

Sep 30, 2023

Changes in this version

+ const ConfigPprof

+ const PackageName

Aug 29, 2023

Changes in this version

+ const ConfigAPI

+ const ConfigDefault

+ const ConfigEnabled

+ const ConfigGrpc

+ const ConfigLevel

+ const ConfigLogger

+ const ConfigPlugins

+ const ConfigPort

+ const ConfigQuery

+ const ConfigTracer

+ func NewGrpcServiceWith(server *Server) *gRPCService

type PluginManager

+ func (mgr *PluginManager) DefaultKvCacheStoreService() (kvcache.Service, error)

+ func (mgr *PluginManager) DefaultTracingService() (tracer.Service, error)

+ func (mgr *PluginManager) EnabledTracingServices() []tracer.Service

+ func (mgr *PluginManager) KvCacheStoreServices() ([]kvcache.Service, error)

+ func (mgr *PluginManager) MetricsServices() ([]metrics.Service, error)

+ func (mgr *PluginManager) TracingServices() ([]tracer.Service, error)

May 7, 2023

Changes in this version

+ const DefaultGrpcPort

+ const DefaultPrometheusConnectionTimeout

+ const DefaultPrometheusPort

+ var ErrInvalid = errors.New("invalid")

+ func NewConfigWithFile(confFile string) (config.Config, error)

+ func NewConfigWithPaths(paths ...string) (config.Config, error)

+ func NewDefaultConfig() (config.Config, error)

+ type Client struct

+ Conn *grpc.ClientConn

+ Host string

+ Port int

+ func NewClient() *Client

+ func (client *Client) Check() (bool, error)

+ func (client *Client) Close() error

+ func (client *Client) CreateDatabase(name string) error

+ func (client *Client) GetConfig(name string) (string, error)

+ func (client *Client) GetMetric(name string) (string, error)

+ func (client *Client) GetVersion() (string, error)

+ func (client *Client) ListConfig() ([]string, error)

+ func (client *Client) ListDatabases() ([]string, error)

+ func (client *Client) ListMetric() ([]string, error)

+ func (client *Client) Open() error

+ func (client *Client) RemoveDatabase(name string) error

+ func (client *Client) SetHost(host string)

+ func (client *Client) SetPort(port int)

type Config

+ func NewConfigWith(config config.Config) *Config

+ func (conf *Config) GetBool(paths ...string) (bool, error)

+ func (conf *Config) QueryPortConfig(name string) (int, error)

+ type GrpcServer struct

+ Addr string

+ Port int

+ func NewGrpcServerWith(server *Server) *GrpcServer

+ func (server *GrpcServer) Check(context.Context, *pb.HealthCheckRequest) (*pb.HealthCheckResponse, error)

+ func (server *GrpcServer) CreateDatabase(ctx context.Context, req *pb.CreateDatabaseRequest) (*pb.StatusResponse, error)

+ func (server *GrpcServer) EnabledConfig() (bool, error)

+ func (server *GrpcServer) GetConfig(ctx context.Context, req *pb.GetConfigRequest) (*pb.GetConfigResponse, error)

+ func (server *GrpcServer) GetMetric(ctx context.Context, req *pb.GetMetricRequest) (*pb.GetMetricResponse, error)

+ func (server *GrpcServer) GetVersion(context.Context, *pb.GetVersionRequest) (*pb.GetVersionResponse, error)

+ func (server *GrpcServer) ListCollections(context.Context, *pb.ListCollectionsRequest) (*pb.ListCollectionsResponse, error)

+ func (server *GrpcServer) ListConfig(context.Context, *pb.ListConfigRequest) (*pb.ListConfigResponse, error)

+ func (server *GrpcServer) ListDatabases(context.Context, *pb.ListDatabasesRequest) (*pb.ListDatabasesResponse, error)

+ func (server *GrpcServer) ListMetric(context.Context, *pb.ListMetricRequest) (*pb.ListMetricResponse, error)

+ func (server *GrpcServer) PortConfig() (int, error)

+ func (server *GrpcServer) RemoveDatabase(ctx context.Context, req *pb.RemoveDatabaseRequest) (*pb.StatusResponse, error)

+ func (server *GrpcServer) SetPort(port int)

+ func (server *GrpcServer) Start() error

+ func (server *GrpcServer) Stop() error

+ type PluginManager struct

+ func NewPluginManagerWith(mgr *plugins.Manager) *PluginManager

+ func (mgr *PluginManager) CoordinatorServices() []coordinator.Service

+ func (mgr *PluginManager) DefaultCoordinatorService() (coordinator.Service, error)

+ func (mgr *PluginManager) DefaultDocumentCoderService() (document.Service, error)

+ func (mgr *PluginManager) DefaultKeyCoderService() (key.Service, error)

+ func (mgr *PluginManager) DefaultKvStoreService() (kv.Service, error)

+ func (mgr *PluginManager) DefaultStoreService() (store.Service, error)

+ func (mgr *PluginManager) DocumentCoderServices() []document.Service

+ func (mgr *PluginManager) DocumentStoreServices() []store.Service

+ func (mgr *PluginManager) EnabledCoordinatorServices() []coordinator.Service

+ func (mgr *PluginManager) EnabledDocumentCoderServices() []document.Service

+ func (mgr *PluginManager) EnabledDocumentStoreServices() []store.Service

+ func (mgr *PluginManager) EnabledKeyCoderServices() []key.Service

+ func (mgr *PluginManager) EnabledKvStoreServices() []kv.Service

+ func (mgr *PluginManager) KeyCoderServices() []key.Service

+ func (mgr *PluginManager) KvStoreServices() []kv.Service

+ func (mgr *PluginManager) QueryServices() []query.Service

+ func (mgr *PluginManager) RemoveDisabledServices(services []plugins.Service) []plugins.Service

+ type PrometheusExporter struct

+ Addr string

+ Port int

+ func NewPrometheusExporterWith(server *Server) *PrometheusExporter

+ func (server *PrometheusExporter) EnabledConfig() (bool, error)

+ func (server *PrometheusExporter) PortConfig() (int, error)

+ func (server *PrometheusExporter) SetPort(port int)

+ func (server *PrometheusExporter) Start() error

+ func (server *PrometheusExporter) Stop() error

+ type Tracer struct

+ func NewTracerWith(server *Server) *Tracer

+ func (t *Tracer) DefaultConfig() (string, error)

+ func (t *Tracer) EnabledConfig(name string) (bool, error)

+ func (t *Tracer) EndpointConfig(name string) (string, error)

+ func (t *Tracer) Start() error

+ func (t *Tracer) Stop() error

+ func (t *Tracer) Tracer() tracer.Tracer

Apr 9, 2023

Changes in this version

+ const ProductName

+ const Version

+ var ErrNotFound = errors.New("not found")

+ type Config interface

+ Get func(name ...string) (any, error)

+ GetInt func(name ...string) (int, error)

+ GetString func(name ...string) (string, error)

+ String func() string

+ func NewConfig() (Config, error)

+ func NewConfigWithPath(path string) (Config, error)

+ func NewConfigWithString(config string) (Config, error)

+ type Server struct

+ func NewServer() *Server

+ func NewServerWithConfig(config Config) *Server

+ func (server *Server) LoadPlugins() error

+ func (server *Server) Restart() error

+ func (server *Server) SetConfig(config Config)

+ func (server *Server) Start() error

+ func (server *Server) Stop() error

+ type ServerConfig struct

+ func NewServerConfigWith(config Config) *ServerConfig

+ func (conf *ServerConfig) Port(name string) (int, error)

+ func (conf *ServerConfig) String() string