evercoresqlite

package
v0.0.28 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 24, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EmbeddedSqliteMigrations embed.FS

Functions

func MigrateDown 

func MigrateDown(db *sql.DB) error

func MigrateUp 

func MigrateUp(db *sql.DB) error

func WrapError 

func WrapError(msg string, err error) error

func WrapErrorf 

func WrapErrorf(msg string, err error, args ...any) error

Types

type AddAggregateWithNaturalKeyParams 

type AddAggregateWithNaturalKeyParams struct {
	AggregateTypeID int64
	NaturalKey      sql.NullString
}

type AddEventParams 

type AddEventParams struct {
	AggregateID int64
	Sequence    int64
	EventTypeID int64
	State       string
	EventTime   time.Time
	Reference   string
}

type AddSnapshotParams 

type AddSnapshotParams struct {
	AggregateID int64
	Sequence    int64
	State       string
}

type Aggregate 

type Aggregate struct {
	ID              int64
	AggregateTypeID int64
	NaturalKey      sql.NullString
}

type AggregateType 

type AggregateType struct {
	ID   int64
	Name string
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Event 

type Event struct {
	ID          int64
	AggregateID int64
	Sequence    int64
	EventTypeID int64
	State       string
	EventTime   time.Time
	Reference   string
}

type EventType 

type EventType struct {
	ID   int64
	Name string
}

type GetAggregateByIdParams 

type GetAggregateByIdParams struct {
	AggregateTypeID int64
	AggregateID     int64
}

type GetAggregateByIdRow 

type GetAggregateByIdRow struct {
	ID         int64
	NaturalKey sql.NullString
}

type GetAggregateIdByNaturalKeyParams 

type GetAggregateIdByNaturalKeyParams struct {
	AggregateTypeID int64
	NaturalKey      sql.NullString
}

type GetEventsForAggregateParams 

type GetEventsForAggregateParams struct {
	AggregateID   int64
	AfterSequence int64
}

type GetEventsForAggregateRow 

type GetEventsForAggregateRow struct {
	Sequence  int64
	EventType string
	State     string
	EventTime time.Time
	Reference string
}

type GetMostRecentSnapshotRow 

type GetMostRecentSnapshotRow struct {
	AggregateID int64
	Sequence    int64
	State       string
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AddAggregate 

func (q *Queries) AddAggregate(ctx context.Context, aggregateTypeID int64) (int64, error)

Aggregate Queries

func (*Queries) AddAggregateType 

func (q *Queries) AddAggregateType(ctx context.Context, aggregateTypeName string) (int64, error)

Aggregate Type Queries

func (*Queries) AddAggregateWithNaturalKey 

func (q *Queries) AddAggregateWithNaturalKey(ctx context.Context, arg AddAggregateWithNaturalKeyParams) (int64, error)

func (*Queries) AddEvent 

func (q *Queries) AddEvent(ctx context.Context, arg AddEventParams) error

Event Queries

func (*Queries) AddEventType 

func (q *Queries) AddEventType(ctx context.Context, eventName string) (int64, error)

Event Type Queries

func (*Queries) AddSnapshot 

func (q *Queries) AddSnapshot(ctx context.Context, arg AddSnapshotParams) error

func (*Queries) GetAggregateById 

func (q *Queries) GetAggregateById(ctx context.Context, arg GetAggregateByIdParams) (GetAggregateByIdRow, error)

func (*Queries) GetAggregateIdByNaturalKey 

func (q *Queries) GetAggregateIdByNaturalKey(ctx context.Context, arg GetAggregateIdByNaturalKeyParams) (int64, error)

func (*Queries) GetAggregateTypeIdByName 

func (q *Queries) GetAggregateTypeIdByName(ctx context.Context, aggregateTypeName string) (int64, error)

func (*Queries) GetAggregateTypes 

func (q *Queries) GetAggregateTypes(ctx context.Context) ([]AggregateType, error)

func (*Queries) GetEventTypeIdByName 

func (q *Queries) GetEventTypeIdByName(ctx context.Context, eventName string) (int64, error)

func (*Queries) GetEventTypes 

func (q *Queries) GetEventTypes(ctx context.Context) ([]EventType, error)

func (*Queries) GetEventsForAggregate 

func (q *Queries) GetEventsForAggregate(ctx context.Context, arg GetEventsForAggregateParams) ([]GetEventsForAggregateRow, error)

func (*Queries) GetMostRecentSnapshot 

func (q *Queries) GetMostRecentSnapshot(ctx context.Context, aggregateID int64) (GetMostRecentSnapshotRow, error)

func (*Queries) WithTx 

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type Snapshot 

type Snapshot struct {
	ID          int64
	AggregateID int64
	Sequence    int64
	State       string
}

type SqliteStorageEngine 

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

func NewSqliteStorageEngine 

func NewSqliteStorageEngine(db *sql.DB) *SqliteStorageEngine

Creates a new Sqlite3 backed storage engine.

func NewSqliteStorageEngineWithConnection 

func NewSqliteStorageEngineWithConnection(connectionString string) (*SqliteStorageEngine, error)

Creates a new Sqlite backed storage engine connecting to the connection string.

func (*SqliteStorageEngine) GetAggregateById 

func (s *SqliteStorageEngine) GetAggregateById(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, aggregateId int64) (int64, *string, error)

func (*SqliteStorageEngine) GetAggregateByKey 

func (s *SqliteStorageEngine) GetAggregateByKey(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, naturalKey string) (int64, error)

func (*SqliteStorageEngine) GetAggregateTypeId 

func (s *SqliteStorageEngine) GetAggregateTypeId(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateTypeName string) (int64, error)

func (*SqliteStorageEngine) GetAggregateTypes 

func (s *SqliteStorageEngine) GetAggregateTypes(tx evercore.StorageEngineTxInfo, ctx context.Context) ([]evercore.IdNamePair, error)

func (*SqliteStorageEngine) GetEventTypeId 

func (s *SqliteStorageEngine) GetEventTypeId(tx evercore.StorageEngineTxInfo, ctx context.Context, name string) (int64, error)

func (*SqliteStorageEngine) GetEventTypes 

func (s *SqliteStorageEngine) GetEventTypes(tx evercore.StorageEngineTxInfo, ctx context.Context) ([]evercore.IdNamePair, error)

func (*SqliteStorageEngine) GetEventsForAggregate 

func (s *SqliteStorageEngine) GetEventsForAggregate(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateId int64, afterSequence int64) ([]evercore.SerializedEvent, error)

func (*SqliteStorageEngine) GetMaxKeyLength 

func (stor *SqliteStorageEngine) GetMaxKeyLength() int

func (*SqliteStorageEngine) GetOrCreateAggregateByKey 

func (s *SqliteStorageEngine) GetOrCreateAggregateByKey(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, naturalKey string) (bool, int64, error)

func (*SqliteStorageEngine) GetSnapshotForAggregate 

func (s *SqliteStorageEngine) GetSnapshotForAggregate(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateId int64) (*evercore.Snapshot, error)

func (*SqliteStorageEngine) GetTransactionInfo 

func (s *SqliteStorageEngine) GetTransactionInfo() (evercore.StorageEngineTxInfo, error)

func (*SqliteStorageEngine) NewAggregate 

func (s *SqliteStorageEngine) NewAggregate(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64) (int64, error)

func (*SqliteStorageEngine) NewAggregateWithKey 

func (s *SqliteStorageEngine) NewAggregateWithKey(tx evercore.StorageEngineTxInfo, ctx context.Context, aggregateTypeId int64, naturalKey string) (int64, error)

func (*SqliteStorageEngine) WriteState 

func (s *SqliteStorageEngine) WriteState(tx evercore.StorageEngineTxInfo, ctx context.Context, events []evercore.StorageEngineEvent, snapshots evercore.SnapshotSlice) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.