boltdb

package

v3.26.0 Latest Latest Go to latest Published: Dec 12, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Package boltdb contains the boltdb implementation of the Schemar interfaces.

This section is empty.

View Source

var SchemarBuckets []boltdb.Bucket = []boltdb.Bucket{
	bucketSchemar,
}

SchemarBuckets defines the buckets used by this package. It can be called during setup to create the buckets ahead of time.

This section is empty.

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

func NewSchemar(db *boltdb.DB, logger logger.Logger) *Schemar

NewSchemar returns a new instance of Schemar with default values.

func (s *Schemar) CreateField(ctx context.Context, qtid dax.QualifiedTableID, fld *dax.Field) error

CreateField creates the field provided in the given table. If a field with the same name already exists then an error is returned.

func (s *Schemar) CreateTable(ctx context.Context, qtbl *dax.QualifiedTable) error

CreateTable creates the table provided. If a table with the same name already exists then an error is returned.

func (s *Schemar) DropField(ctx context.Context, qtid dax.QualifiedTableID, fldName dax.FieldName) error

DropField removes the field from the table.

func (s *Schemar) DropTable(ctx context.Context, qtid dax.QualifiedTableID) error

DropTable drops the given table. If the named/IDed table does not exist then an error is returned.

func (s *Schemar) Table(ctx context.Context, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error)

Table returns the TableInfo for the given table. An error is returned if the table does not exist.

func (s *Schemar) TableID(ctx context.Context, qual dax.TableQualifier, name dax.TableName) (dax.QualifiedTableID, error)

func (s *Schemar) Tables(ctx context.Context, qual dax.TableQualifier, ids ...dax.TableID) ([]*dax.QualifiedTable, error)

Tables returns a list of Table for all existing tables. If one or more table names is provided, then only those will be included in the output.