metadata

Mar 20, 2024

Changes in this version

type Registry

+ BatchSize int

Dec 18, 2023

Changes in this version

type Settings

+ UUID string

Nov 7, 2023

Changes in this version

+ const RecordIDColumn

type Collection

+ func (c Collection) Capped() bool

+ type CollectionCreateParams struct

+ CappedDocuments int64

+ CappedSize int64

+ DBName string

+ Name string

+ func (ccp *CollectionCreateParams) Capped() bool

type Settings

+ CappedDocuments int64

+ CappedSize int64

Sep 14, 2023

Changes in this version

+ type IndexInfo struct

+ Key []IndexKeyPair

+ Name string

+ Unique bool

+ type IndexKeyPair struct

+ Descending bool

+ Field 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, toDrop []string) error

+ type Settings struct

+ Indexes []IndexInfo

+ func (s *Settings) Scan(src any) error

+ func (s Settings) Value() (driver.Value, error)

Aug 28, 2023

Changes in this version

type Registry

+ func (r *Registry) CollectionRename(ctx context.Context, dbName, oldCollectionName, newCollectionName string) (bool, error)

Jul 31, 2023

Changes in this version

+ const DefaultColumn

+ const IDColumn

+ type Collection struct

+ Name string

+ Settings []byte

+ TableName string

type Registry

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

+ func (r *Registry) CollectionGet(ctx context.Context, dbName string, collectionName string) (*Collection, error)

+ func (r *Registry) Describe(ch chan<- *prometheus.Desc)

Jun 19, 2023

Changes in this version

+ type Registry struct

+ func NewRegistry(dir string, l *zap.Logger) (*Registry, error)

+ func (r *Registry) Close()

+ func (r *Registry) CollectionCreate(ctx context.Context, dbName string, collectionName string) (bool, error)

+ func (r *Registry) CollectionDrop(ctx context.Context, dbName string, collectionName string) (bool, error)

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

+ func (r *Registry) CollectionToTable(collectionName string) string

+ func (r *Registry) DatabaseDrop(ctx context.Context, dbName string) bool

+ func (r *Registry) DatabaseGetExisting(ctx context.Context, dbName string) *sql.DB

+ func (r *Registry) DatabaseGetOrCreate(ctx context.Context, dbName string) (*sql.DB, error)

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