metadata

Mar 20, 2024

Changes in this version

type Registry

+ BatchSize int

Dec 18, 2023

Changes in this version

type Collection

+ UUID string

Nov 7, 2023

Changes in this version

+ const RecordIDColumn

type Collection

+ CappedDocuments int64

+ CappedSize int64

+ func (c Collection) Capped() bool

+ type CollectionCreateParams struct

+ CappedDocuments int64

+ CappedSize int64

+ DBName string

+ Name string

+ func (ccp *CollectionCreateParams) Capped() bool

Oct 10, 2023

Changes in this version

type Collection

+ Indexes Indexes

+ func (c *Collection) Scan(src any) error

+ func (c Collection) Value() (driver.Value, error)

+ 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

+ 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

Sep 25, 2023

Changes in this version

+ const DefaultColumn

+ const IDColumn

type Registry

+ func (r *Registry) Collect(ch chan<- prometheus.Metric)

+ func (r *Registry) CollectionCreate(ctx context.Context, dbName, collectionName string) (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) Describe(ch chan<- *prometheus.Desc)

Sep 14, 2023

Changes in this version

+ type Collection struct

+ Name string

+ TableName string

+ func (c *Collection) Marshal() *types.Document

+ func (c *Collection) Unmarshal(doc *types.Document) error

+ type Registry struct

+ func NewRegistry(u string, l *zap.Logger, sp *state.Provider) (*Registry, error)

+ func (r *Registry) Close()

+ func (r *Registry) DatabaseList(ctx context.Context) ([]string, error)