Versions in this module Expand all Collapse all v0 v0.0.1 Jun 15, 2026 Changes in this version + const DatabaseID + const IDColumn + var ErrCollectionPathConflict = errors.New("dalgo2ingitdb: root-collections.yaml entry conflicts with auto-registration") + func AccessValue(row recordset.Row, rs recordset.Recordset, ...) (any, error) + func AllColumnNames(rs recordset.Recordset) []string + func ApplyFormulasToRead(data map[string]any, cols map[string]*ingitdb.ColumnDef, ...) (map[string]any, error) + func BuildRecordset(colDef *ingitdb.CollectionDef, records []KeyedStored) recordset.Recordset + func CollectionForKey(def *ingitdb.Definition, id string) (*ingitdb.CollectionDef, string, error) + func NewDatabase(projectPath string, reader ingitdb.CollectionsReader) (dal.DB, error) + func NewRecordsetReader(rs recordset.Recordset) dal.RecordsetReader + func RowData(row recordset.Row, rs recordset.Recordset, collectionID, recordKey string, ...) (map[string]any, error) + func RowKey(row recordset.Row, rs recordset.Recordset) string + func StoredColumnNames(rs recordset.Recordset) []string + func ValidateDelete(def *ingitdb.Definition, parentCollection, parentKey string) error + func ValidateWrite(def *ingitdb.Definition, operation, collectionID string, ...) error + type CSVParseOptions struct + Fields []string + KeyColumn string + type Database struct + func (db *Database) Adapter() dal.Adapter + func (db *Database) AlterCollection(ctx context.Context, name string, ops ...ddl.AlterOp) error + func (db *Database) CreateCollection(_ context.Context, c dbschema.CollectionDef, opts ...ddl.Option) error + func (db *Database) DescribeCollection(_ context.Context, ref *dal.CollectionRef) (*dbschema.CollectionDef, error) + func (db *Database) DropCollection(_ context.Context, name string, opts ...ddl.Option) error + func (db *Database) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error) + func (db *Database) ExecuteQueryToRecordsetReader(_ context.Context, _ dal.Query, _ ...recordset.Option) (dal.RecordsetReader, error) + func (db *Database) Exists(ctx context.Context, key *dal.Key) (bool, error) + func (db *Database) Get(ctx context.Context, record dal.Record) error + func (db *Database) GetMulti(ctx context.Context, records []dal.Record) error + func (db *Database) ID() string + func (db *Database) ListCollections(_ context.Context, _ *dal.Key) ([]dal.CollectionRef, error) + func (db *Database) ListConstraints(_ context.Context, _ *dal.CollectionRef) ([]dbschema.ConstraintDef, error) + func (db *Database) ListIndexes(_ context.Context, _ *dal.CollectionRef) ([]dbschema.IndexDef, error) + func (db *Database) ListReferrers(_ context.Context, _ *dal.CollectionRef) ([]dbschema.Referrer, error) + func (db *Database) RunReadonlyTransaction(ctx context.Context, f dal.ROTxWorker, options ...dal.TransactionOption) error + func (db *Database) RunReadwriteTransaction(ctx context.Context, f dal.RWTxWorker, options ...dal.TransactionOption) error + func (db *Database) Schema() dal.Schema + func (db *Database) SupportsTransactionalDDL() bool + type KeyedStored struct + Key string + Stored map[string]any + type ParsedRecord struct + Data map[string]any + Key string + Position int + func ParseBatchCSV(r io.Reader, opts CSVParseOptions) ([]ParsedRecord, error) + func ParseBatchINGR(r io.Reader) ([]ParsedRecord, error) + func ParseBatchJSONL(r io.Reader) ([]ParsedRecord, error) + func ParseBatchYAMLStream(r io.Reader) ([]ParsedRecord, error)
Go to main page