sqlite

Jun 11, 2026

Changes in this version

type SqliteGetEvents

+ func (s *SqliteGetEvents) GetLatestByCriteria(ctx context.Context, req *eventstore.GetLatestByCriteriaRequest) (*eventstore.GetLatestByCriteriaResponse, error)

Jun 5, 2026

Changes in this version

type BoundaryPools

+ func OpenBoundaryPoolsWithConfig(ctx context.Context, sqliteCfg config.SqliteConfig, ...) (*BoundaryPools, error)

+ type SqliteEventNotifier struct

+ func NewSqliteEventNotifier(interval time.Duration) *SqliteEventNotifier

+ func (n *SqliteEventNotifier) Notify(boundary string)

+ func (n *SqliteEventNotifier) Signal(boundary string) eventstore.EventSignal

May 29, 2026

Changes in this version

+ func InitializeSqliteDatabase(ctx context.Context, sqliteCfg config.SqliteConfig, ...) (eventstore.EventsSaver, eventstore.EventsRetriever, eventstore.LockProvider, ...)

+ type BoundaryPools struct

+ Boundary string

+ Read *sqlitex.Pool

+ Write *sqlitex.Pool

+ func OpenBoundaryPools(ctx context.Context, dir, boundary, adminBoundary string) (*BoundaryPools, error)

+ func (b *BoundaryPools) Close() error

+ type SqliteAdminDB struct

+ func NewSqliteAdminDB(pools map[string]*BoundaryPools, adminBoundary string, logger logging.Logger) *SqliteAdminDB

+ func (a *SqliteAdminDB) CreateBoundaryIndex(ctx context.Context, boundary, name string, fields []common.IndexField, ...) error

+ func (a *SqliteAdminDB) DeleteUser(id string) error

+ func (a *SqliteAdminDB) DropBoundaryIndex(ctx context.Context, boundary, name string) error

+ func (a *SqliteAdminDB) GetEventsCount(boundary string) (int, error)

+ func (a *SqliteAdminDB) GetProjectorLastPosition(projectorName string) (*eventstore.Position, error)

+ func (a *SqliteAdminDB) GetUserById(id string) (eventstore.User, error)

+ func (a *SqliteAdminDB) GetUserByUsername(username string) (eventstore.User, error)

+ func (a *SqliteAdminDB) GetUsersCount() (uint32, error)

+ func (a *SqliteAdminDB) ListAdminUsers() ([]*eventstore.User, error)

+ func (a *SqliteAdminDB) SaveEventCount(count int, boundary string) error

+ func (a *SqliteAdminDB) SaveUsersCount(count uint32) error

+ func (a *SqliteAdminDB) UpdateProjectorPosition(name string, position *eventstore.Position) error

+ func (a *SqliteAdminDB) UpsertUser(user eventstore.User) error

+ type SqliteEventPublishing struct

+ func NewSqliteEventPublishing(pools map[string]*BoundaryPools, logger logging.Logger) *SqliteEventPublishing

+ func (p *SqliteEventPublishing) GetLastPublishedEventPosition(ctx context.Context, boundary string) (eventstore.Position, error)

+ func (p *SqliteEventPublishing) InsertLastPublishedEvent(ctx context.Context, boundary string, transactionID, globalID int64) error

+ type SqliteGetEvents struct

+ func NewSqliteGetEvents(pools map[string]*BoundaryPools, logger logging.Logger) *SqliteGetEvents

+ func (s *SqliteGetEvents) Get(ctx context.Context, req *eventstore.GetEventsRequest) (*eventstore.GetEventsResponse, error)

+ type SqliteSaveEvents struct

+ func NewSqliteSaveEvents(pools map[string]*BoundaryPools, logger logging.Logger) *SqliteSaveEvents

+ func (s *SqliteSaveEvents) Save(ctx context.Context, events []eventstore.EventWithMapTags, boundary string, ...) (transactionID string, globalID int64, err error)

Feb 17, 2026

Changes in this version

+ type SQLiteGetEvents struct

+ func NewSQLiteGetEvents(db *sql.DB, logger *logging.Logger) *SQLiteGetEvents

+ func (s *SQLiteGetEvents) Get(ctx context.Context, req *orisun.GetEventsRequest) (*orisun.GetEventsResponse, error)

+ type SQLiteLockProvider struct

+ func NewSQLiteLockProvider(db *sql.DB, logger logging.Logger) *SQLiteLockProvider

+ func (m *SQLiteLockProvider) Lock(ctx context.Context, lockName string) error

+ type SQLiteSaveEvents struct

+ func NewSQLiteSaveEvents(db *sql.DB, logger *logging.Logger) *SQLiteSaveEvents

+ func (s *SQLiteSaveEvents) Save(ctx context.Context, events *[]orisun.EventWithMapTags, boundary string, ...) (transactionID string, globalID uint64, err error)