Documentation
¶
Index ¶
- type Config
- type DataSourceStatus
- type Node
- func (n *Node) DataSourceStatus(ctx context.Context, name string) (string, error)
- func (n *Node) Error() string
- func (n *Node) IsReady() bool
- func (n *Node) LastSeen() time.Time
- func (n *Node) LoadDataSource(ctx context.Context, name string) error
- func (n *Node) RegisterObjectStorage(ctx context.Context, info storage.SecretInfo) error
- func (n *Node) RegisteredStorages(ctx context.Context) ([]StorageInfo, error)
- func (n *Node) Start(ctx context.Context)
- func (n *Node) Stop()
- func (n *Node) UnloadDataSource(ctx context.Context, name string) error
- func (n *Node) UnregisterObjectStorage(ctx context.Context, name string) error
- func (n *Node) Version() string
- type NodeCommonConfig
- type NodeConfig
- type NodeStatus
- type Service
- type Source
- func (*Source) AsModule() bool
- func (s *Source) Attach(ctx context.Context, pool *db.Pool) error
- func (*Source) Catalog(ctx context.Context) cs.Source
- func (s *Source) ClusterVersion(ctx context.Context) string
- func (s *Source) DataSourceStatus(ctx context.Context, name string) ([]DataSourceStatus, error)
- func (*Source) Engine() engines.Engine
- func (*Source) IsReadonly() bool
- func (s *Source) LoadDataSource(ctx context.Context, name string) error
- func (*Source) Name() string
- func (s *Source) Nodes(ctx context.Context) ([]NodeStatus, error)
- func (s *Source) RegisterObjectStorage(ctx context.Context, info storage.SecretInfo) error
- func (s *Source) RegisteredObjectStorages(ctx context.Context) ([]StorageInfo, error)
- func (s *Source) UnloadDataSource(ctx context.Context, name string) error
- func (s *Source) UnregisterObjectStorage(ctx context.Context, name string) error
- type SourceConfig
- type StorageInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataSourceStatus ¶
type Node ¶
type Node struct {
// contains filtered or unexported fields
}
func (*Node) DataSourceStatus ¶
func (*Node) RegisterObjectStorage ¶ added in v0.1.25
func (*Node) RegisteredStorages ¶
func (n *Node) RegisteredStorages(ctx context.Context) ([]StorageInfo, error)
func (*Node) UnloadDataSource ¶
func (*Node) UnregisterObjectStorage ¶ added in v0.1.25
type NodeCommonConfig ¶
type NodeConfig ¶
type NodeStatus ¶
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func NewSource ¶
func NewSource(config SourceConfig) *Source
func (*Source) DataSourceStatus ¶
func (*Source) IsReadonly ¶
func (*Source) LoadDataSource ¶
func (*Source) RegisterObjectStorage ¶ added in v0.1.25
func (*Source) RegisteredObjectStorages ¶ added in v0.1.25
func (s *Source) RegisteredObjectStorages(ctx context.Context) ([]StorageInfo, error)
func (*Source) UnloadDataSource ¶
type SourceConfig ¶
Click to show internal directories.
Click to hide internal directories.