duckdb

Documentation

Index

• type DuckDBStorage
  • func NewDuckDBStorage(path string, options ...DuckDBStorageOption) (*DuckDBStorage, error)
  • func (d *DuckDBStorage) Close() error
  • func (s *DuckDBStorage) CreateOrUpdateComponents(components []smd.Component) error
  • func (s *DuckDBStorage) CreateOrUpdateRedfishEndpoints(endpoints []smd.RedfishEndpoint) error
  • func (d *DuckDBStorage) DeleteBMC(bmcID uuid.UUID) error
  • func (d *DuckDBStorage) DeleteCollection(id uuid.UUID) error
  • func (s *DuckDBStorage) DeleteComponentByXname(xname string) error
  • func (s *DuckDBStorage) DeleteComponents() error
  • func (d *DuckDBStorage) DeleteComputeNode(nodeID uuid.UUID) error
  • func (s *DuckDBStorage) DeleteRedfishEndpointByID(id string) error
  • func (d *DuckDBStorage) FindCollectionsByNode(nodeID xnames.NodeXname) ([]*nodes.NodeCollection, error)
  • func (d *DuckDBStorage) GetBMC(bmcID uuid.UUID) (nodes.BMC, error)
  • func (d *DuckDBStorage) GetCollection(id uuid.UUID) (*nodes.NodeCollection, error)
  • func (s *DuckDBStorage) GetComponentByNID(nid int) (smd.Component, error)
  • func (s *DuckDBStorage) GetComponentByUID(uid uuid.UUID) (smd.Component, error)
  • func (s *DuckDBStorage) GetComponentByXname(xname string) (smd.Component, error)
  • func (s *DuckDBStorage) GetComponents() ([]smd.Component, error)
  • func (d *DuckDBStorage) GetComputeNode(nodeID uuid.UUID) (nodes.ComputeNode, error)
  • func (s *DuckDBStorage) GetRedfishEndpointByID(id string) (smd.RedfishEndpoint, error)
  • func (s *DuckDBStorage) GetRedfishEndpoints() ([]smd.RedfishEndpoint, error)
  • func (d *DuckDBStorage) LookupBMCByMACAddress(mac string) (nodes.BMC, error)
  • func (d *DuckDBStorage) LookupBMCByXName(xname string) (nodes.BMC, error)
  • func (d *DuckDBStorage) LookupComputeNodeByMACAddress(mac string) (nodes.ComputeNode, error)
  • func (d *DuckDBStorage) LookupComputeNodeByXName(xname string) (nodes.ComputeNode, error)
  • func (s *DuckDBStorage) QueryComponents(xname string, params map[string]string) ([]smd.Component, error)
  • func (d *DuckDBStorage) RestoreParquet(path string) error
  • func (d *DuckDBStorage) SaveBMC(bmcID uuid.UUID, bmc nodes.BMC) error
  • func (d *DuckDBStorage) SaveCollection(collection *nodes.NodeCollection) error
  • func (d *DuckDBStorage) SaveComputeNode(nodeID uuid.UUID, node nodes.ComputeNode) error
  • func (d *DuckDBStorage) SearchComputeNodes(opts ...storage.NodeSearchOption) ([]nodes.ComputeNode, error)
  • func (d *DuckDBStorage) Shutdown(ctx context.Context)
  • func (d *DuckDBStorage) SnapshotParquet(ctx context.Context, path string) error
  • func (d *DuckDBStorage) UpdateBMC(bmcID uuid.UUID, bmc nodes.BMC) error
  • func (d *DuckDBStorage) UpdateCollection(collection *nodes.NodeCollection) error
  • func (s *DuckDBStorage) UpdateComponentData(xnames []string, data map[string]interface{}) error
  • func (d *DuckDBStorage) UpdateComputeNode(nodeID uuid.UUID, node nodes.ComputeNode) error
• type DuckDBStorageOption
  • func WithCreateSnapshotDir(create bool) DuckDBStorageOption
  • func WithInitTables(init bool) DuckDBStorageOption
  • func WithRestore(path string) DuckDBStorageOption
  • func WithSnapshotFrequency(frequency time.Duration) DuckDBStorageOption
  • func WithSnapshotPath(path string) DuckDBStorageOption

Types

type DuckDBStorage

type DuckDBStorage struct {
	// contains filtered or unexported fields
}

func NewDuckDBStorage

func NewDuckDBStorage(path string, options ...DuckDBStorageOption) (*DuckDBStorage, error)

func (*DuckDBStorage) Close

func (d *DuckDBStorage) Close() error

func (*DuckDBStorage) CreateOrUpdateComponents

func (s *DuckDBStorage) CreateOrUpdateComponents(components []smd.Component) error

func (*DuckDBStorage) CreateOrUpdateRedfishEndpoints

func (s *DuckDBStorage) CreateOrUpdateRedfishEndpoints(endpoints []smd.RedfishEndpoint) error

func (*DuckDBStorage) DeleteBMC

func (d *DuckDBStorage) DeleteBMC(bmcID uuid.UUID) error

func (*DuckDBStorage) DeleteCollection

func (d *DuckDBStorage) DeleteCollection(id uuid.UUID) error

func (*DuckDBStorage) DeleteComponentByXname

func (s *DuckDBStorage) DeleteComponentByXname(xname string) error

func (*DuckDBStorage) DeleteComponents

func (s *DuckDBStorage) DeleteComponents() error

func (*DuckDBStorage) DeleteComputeNode

func (d *DuckDBStorage) DeleteComputeNode(nodeID uuid.UUID) error

func (*DuckDBStorage) DeleteRedfishEndpointByID

func (s *DuckDBStorage) DeleteRedfishEndpointByID(id string) error

func (*DuckDBStorage) FindCollectionsByNode

func (d *DuckDBStorage) FindCollectionsByNode(nodeID xnames.NodeXname) ([]*nodes.NodeCollection, error)

func (*DuckDBStorage) GetBMC

func (d *DuckDBStorage) GetBMC(bmcID uuid.UUID) (nodes.BMC, error)

func (*DuckDBStorage) GetCollection

func (d *DuckDBStorage) GetCollection(id uuid.UUID) (*nodes.NodeCollection, error)

func (*DuckDBStorage) GetComponentByNID

func (s *DuckDBStorage) GetComponentByNID(nid int) (smd.Component, error)

func (*DuckDBStorage) GetComponentByUID

func (s *DuckDBStorage) GetComponentByUID(uid uuid.UUID) (smd.Component, error)

func (*DuckDBStorage) GetComponentByXname

func (s *DuckDBStorage) GetComponentByXname(xname string) (smd.Component, error)

func (*DuckDBStorage) GetComponents

func (s *DuckDBStorage) GetComponents() ([]smd.Component, error)

func (*DuckDBStorage) GetComputeNode

func (d *DuckDBStorage) GetComputeNode(nodeID uuid.UUID) (nodes.ComputeNode, error)

func (*DuckDBStorage) GetRedfishEndpointByID

func (s *DuckDBStorage) GetRedfishEndpointByID(id string) (smd.RedfishEndpoint, error)

func (*DuckDBStorage) GetRedfishEndpoints

func (s *DuckDBStorage) GetRedfishEndpoints() ([]smd.RedfishEndpoint, error)

func (*DuckDBStorage) LookupBMCByMACAddress

func (d *DuckDBStorage) LookupBMCByMACAddress(mac string) (nodes.BMC, error)

func (*DuckDBStorage) LookupBMCByXName

func (d *DuckDBStorage) LookupBMCByXName(xname string) (nodes.BMC, error)

func (*DuckDBStorage) LookupComputeNodeByMACAddress

func (d *DuckDBStorage) LookupComputeNodeByMACAddress(mac string) (nodes.ComputeNode, error)

func (*DuckDBStorage) LookupComputeNodeByXName

func (d *DuckDBStorage) LookupComputeNodeByXName(xname string) (nodes.ComputeNode, error)

func (*DuckDBStorage) QueryComponents

func (s *DuckDBStorage) QueryComponents(xname string, params map[string]string) ([]smd.Component, error)

func (*DuckDBStorage) RestoreParquet

func (d *DuckDBStorage) RestoreParquet(path string) error

func (*DuckDBStorage) SaveBMC

func (d *DuckDBStorage) SaveBMC(bmcID uuid.UUID, bmc nodes.BMC) error

func (*DuckDBStorage) SaveCollection

func (d *DuckDBStorage) SaveCollection(collection *nodes.NodeCollection) error

func (*DuckDBStorage) SaveComputeNode

func (d *DuckDBStorage) SaveComputeNode(nodeID uuid.UUID, node nodes.ComputeNode) error

func (*DuckDBStorage) SearchComputeNodes

func (d *DuckDBStorage) SearchComputeNodes(opts ...storage.NodeSearchOption) ([]nodes.ComputeNode, error)

func (*DuckDBStorage) Shutdown

func (d *DuckDBStorage) Shutdown(ctx context.Context)

Shutdown initiates the shutdown process

func (*DuckDBStorage) SnapshotParquet

func (d *DuckDBStorage) SnapshotParquet(ctx context.Context, path string) error

func (*DuckDBStorage) UpdateBMC

func (d *DuckDBStorage) UpdateBMC(bmcID uuid.UUID, bmc nodes.BMC) error

func (*DuckDBStorage) UpdateCollection

func (d *DuckDBStorage) UpdateCollection(collection *nodes.NodeCollection) error

func (*DuckDBStorage) UpdateComponentData

func (s *DuckDBStorage) UpdateComponentData(xnames []string, data map[string]interface{}) error

func (*DuckDBStorage) UpdateComputeNode

func (d *DuckDBStorage) UpdateComputeNode(nodeID uuid.UUID, node nodes.ComputeNode) error

type DuckDBStorageOption

type DuckDBStorageOption interface {
	// contains filtered or unexported methods
}

func WithCreateSnapshotDir

func WithCreateSnapshotDir(create bool) DuckDBStorageOption

func WithInitTables

func WithInitTables(init bool) DuckDBStorageOption

func WithRestore

func WithRestore(path string) DuckDBStorageOption

func WithSnapshotFrequency

func WithSnapshotFrequency(frequency time.Duration) DuckDBStorageOption

func WithSnapshotPath

func WithSnapshotPath(path string) DuckDBStorageOption