Versions in this module Expand all Collapse all v0 v0.1.1 Feb 11, 2024 Changes in this version + const DefaultColumn + const IDColumn + const RecordIDColumn + type Collection struct + CappedDocuments int64 + CappedSize int64 + Indexes Indexes + Name string + TableName string + UUID string + func (c *Collection) Scan(src any) error + func (c Collection) Capped() bool + func (c Collection) Value() (driver.Value, error) + type CollectionCreateParams struct + CappedDocuments int64 + CappedSize int64 + DBName string + Name string + func (ccp *CollectionCreateParams) Capped() bool + type IndexInfo struct + Key []IndexKeyPair + Name string + PgIndex string + Unique bool + type IndexKeyPair struct + Descending bool + Field string + type Indexes []IndexInfo + type Placeholder int + func (p *Placeholder) Next() string + type Registry struct + func NewRegistry(u string, l *zap.Logger, sp *state.Provider) (*Registry, error) + func (r *Registry) Close() + func (r *Registry) Collect(ch chan<- prometheus.Metric) + func (r *Registry) CollectionCreate(ctx context.Context, params *CollectionCreateParams) (bool, error) + func (r *Registry) CollectionDrop(ctx context.Context, dbName, collectionName string) (bool, error) + func (r *Registry) CollectionGet(ctx context.Context, dbName, collectionName string) (*Collection, error) + func (r *Registry) CollectionList(ctx context.Context, dbName string) ([]*Collection, error) + func (r *Registry) CollectionRename(ctx context.Context, dbName, oldCollectionName, newCollectionName string) (bool, error) + func (r *Registry) DatabaseDrop(ctx context.Context, dbName string) (bool, error) + func (r *Registry) DatabaseGetExisting(ctx context.Context, dbName string) (*pgxpool.Pool, error) + func (r *Registry) DatabaseGetOrCreate(ctx context.Context, dbName string) (*pgxpool.Pool, error) + func (r *Registry) DatabaseList(ctx context.Context) ([]string, error) + func (r *Registry) Describe(ch chan<- *prometheus.Desc) + func (r *Registry) IndexesCreate(ctx context.Context, dbName, collectionName string, indexes []IndexInfo) error + func (r *Registry) IndexesDrop(ctx context.Context, dbName, collectionName string, indexNames []string) error v0.1.0 Feb 11, 2024