mariadb

Oct 7, 2024

Changes in this version

type LockerFactory

+ Namespace string

Oct 7, 2024

Changes in this version

type Locker

+ func (l Locker) TryLock(ctx context.Context) (_ context.Context, _ bool, rErr error)

type LockerFactory

+ func (lf LockerFactory[Key]) NonBlockingLockerFor(key Key) guard.NonBlockingLocker

+ func (lf LockerFactory[Key]) Purge(ctx context.Context) error

type TaskerSchedulerLocks

+ func (lf TaskerSchedulerLocks) NonBlockingLockerFor(id tasker.ScheduleID) guard.NonBlockingLocker

Sep 29, 2024

Changes in this version

+ type Locker struct

+ Connection Connection

+ Name string

+ func (l Locker) Lock(ctx context.Context) (context.Context, error)

+ func (l Locker) Migrate(ctx context.Context) error

+ func (l Locker) Unlock(ctx context.Context) error

+ type LockerFactory struct

+ Connection Connection

+ func (lf LockerFactory[Key]) LockerFor(key Key) guard.Locker

+ func (lf LockerFactory[Key]) Migrate(ctx context.Context) error

+ type TaskerSchedulerLocks struct

+ Connection Connection

+ func (lf TaskerSchedulerLocks) LockerFor(id tasker.ScheduleStateID) guard.Locker

+ func (lf TaskerSchedulerLocks) Migrate(ctx context.Context) error

+ type TaskerSchedulerStateRepository struct

+ Connection Connection

+ func (r TaskerSchedulerStateRepository) Create(ctx context.Context, ptr *tasker.ScheduleState) error

+ func (r TaskerSchedulerStateRepository) DeleteByID(ctx context.Context, id tasker.ScheduleStateID) error

+ func (r TaskerSchedulerStateRepository) FindByID(ctx context.Context, id tasker.ScheduleStateID) (ent tasker.ScheduleState, found bool, err error)

+ func (r TaskerSchedulerStateRepository) Migrate(ctx context.Context) error

+ func (r TaskerSchedulerStateRepository) Update(ctx context.Context, ptr *tasker.ScheduleState) error

Sep 17, 2024

Changes in this version

type Repository

+ func (r Repository[ENT, ID]) Save(ctx context.Context, ptr *ENT) (rErr error)

Sep 15, 2024

Changes in this version

+ func JSON[T any](ptr *T) flsql.DTO

+ func MakeMigrator(conn Connection, namespace string, steps migration.Steps[Connection]) migration.Migrator[Connection]

+ func Timestamp(ptr *time.Time) flsql.DTO

+ type CacheRepository struct

+ Connection Connection

+ ID string

+ IDA extid.Accessor[ENT, ID]

+ IDM dtokit.MapperTo[ID, string]

+ JSONDTOM dtokit.Mapper[ENT]

+ func (r CacheRepository[ENT, ID]) BeginTx(ctx context.Context) (context.Context, error)

+ func (r CacheRepository[ENT, ID]) CommitTx(ctx context.Context) error

+ func (r CacheRepository[ENT, ID]) Entities() cache.EntityRepository[ENT, ID]

+ func (r CacheRepository[ENT, ID]) Hits() cache.HitRepository[ID]

+ func (r CacheRepository[ENT, ID]) Migrate(ctx context.Context) error

+ func (r CacheRepository[ENT, ID]) RollbackTx(ctx context.Context) error

+ type Connection struct

+ func Connect(dsn string) (Connection, error)

+ type Repository struct

+ Connection Connection

+ Mapping flsql.Mapping[Entity, ID]

+ func MakeMigrationStateRepository(conn Connection) Repository[migration.State, migration.StateID]

+ func (r Repository[Entity, ID]) BeginTx(ctx context.Context) (context.Context, error)

+ func (r Repository[Entity, ID]) CommitTx(ctx context.Context) error

+ func (r Repository[Entity, ID]) Create(ctx context.Context, ptr *Entity) (rErr error)

+ func (r Repository[Entity, ID]) DeleteAll(ctx context.Context) (rErr error)

+ func (r Repository[Entity, ID]) DeleteByID(ctx context.Context, id ID) (rErr error)

+ func (r Repository[Entity, ID]) FindAll(ctx context.Context) iterators.Iterator[Entity]

+ func (r Repository[Entity, ID]) FindByID(ctx context.Context, id ID) (Entity, bool, error)

+ func (r Repository[Entity, ID]) FindByIDs(ctx context.Context, ids ...ID) iterators.Iterator[Entity]

+ func (r Repository[Entity, ID]) RollbackTx(ctx context.Context) error

+ func (r Repository[Entity, ID]) Update(ctx context.Context, ptr *Entity) (rErr error)

+ func (r Repository[Entity, ID]) Upsert(ctx context.Context, entities ...*Entity) (rErr error)