memory

package module

Go to main page

Versions in this module

v0

v0.7.1

May 6, 2026

Changes in this version

+ type ApplyFunc func(base []byte, delta spi.SchemaDelta) ([]byte, error)

+ type Clock interface

+ Now func() time.Time

type EntityStore

+ func (s *EntityStore) CountByState(ctx context.Context, modelRef spi.ModelRef, states []string) (map[string]int64, error)

type ModelStore

+ func (s *ModelStore) ExtendSchema(ctx context.Context, ref spi.ModelRef, delta spi.SchemaDelta) error

+ type Option func(*StoreFactory)

+ func WithApplyFunc(fn ApplyFunc) Option

+ func WithClock(c Clock) Option

type StoreFactory

+ func (f *StoreFactory) SetApplyFunc(fn func(base []byte, delta spi.SchemaDelta) ([]byte, error))

+ type TestClock struct

+ func NewTestClock() *TestClock

+ func (c *TestClock) Advance(d time.Duration)

+ func (c *TestClock) Now() time.Time

v0.1.0

Apr 15, 2026

Changes in this version

+ type AsyncSearchStore struct

+ func NewAsyncSearchStore() *AsyncSearchStore

+ func (s *AsyncSearchStore) Cancel(ctx context.Context, jobID string) error

+ func (s *AsyncSearchStore) CreateJob(ctx context.Context, job *spi.SearchJob) error

+ func (s *AsyncSearchStore) DeleteJob(ctx context.Context, jobID string) error

+ func (s *AsyncSearchStore) GetJob(ctx context.Context, jobID string) (*spi.SearchJob, error)

+ func (s *AsyncSearchStore) GetResultIDs(ctx context.Context, jobID string, offset, limit int) ([]string, int, error)

+ func (s *AsyncSearchStore) ReapExpired(ctx context.Context, ttl time.Duration) (int, error)

+ func (s *AsyncSearchStore) SaveResults(ctx context.Context, jobID string, entityIDs []string) error

+ func (s *AsyncSearchStore) UpdateJobStatus(ctx context.Context, jobID string, status string, resultCount int, ...) error

+ type EntityStore struct

+ func (s *EntityStore) CompareAndSave(ctx context.Context, entity *spi.Entity, expectedTxID string) (int64, error)

+ func (s *EntityStore) Count(ctx context.Context, modelRef spi.ModelRef) (int64, error)

+ func (s *EntityStore) Delete(ctx context.Context, entityID string) error

+ func (s *EntityStore) DeleteAll(ctx context.Context, modelRef spi.ModelRef) error

+ func (s *EntityStore) Exists(ctx context.Context, entityID string) (bool, error)

+ func (s *EntityStore) Get(ctx context.Context, entityID string) (*spi.Entity, error)

+ func (s *EntityStore) GetAll(ctx context.Context, modelRef spi.ModelRef) ([]*spi.Entity, error)

+ func (s *EntityStore) GetAllAsAt(ctx context.Context, modelRef spi.ModelRef, asAt time.Time) ([]*spi.Entity, error)

+ func (s *EntityStore) GetAsAt(ctx context.Context, entityID string, asAt time.Time) (*spi.Entity, error)

+ func (s *EntityStore) GetVersionHistory(ctx context.Context, entityID string) ([]spi.EntityVersion, error)

+ func (s *EntityStore) Save(ctx context.Context, entity *spi.Entity) (int64, error)

+ func (s *EntityStore) SaveAll(ctx context.Context, entities iter.Seq[*spi.Entity]) ([]int64, error)

+ type KeyValueStore struct

+ func (s *KeyValueStore) Delete(ctx context.Context, namespace string, key string) error

+ func (s *KeyValueStore) Get(ctx context.Context, namespace string, key string) ([]byte, error)

+ func (s *KeyValueStore) List(ctx context.Context, namespace string) (map[string][]byte, error)

+ func (s *KeyValueStore) Put(ctx context.Context, namespace string, key string, value []byte) error

+ type MessageStore struct

+ func (s *MessageStore) Delete(_ context.Context, id string) error

+ func (s *MessageStore) DeleteBatch(ctx context.Context, ids []string) error

+ func (s *MessageStore) Get(_ context.Context, id string) (spi.MessageHeader, spi.MessageMetaData, io.ReadCloser, error)

+ func (s *MessageStore) Save(_ context.Context, id string, header spi.MessageHeader, ...) error

+ type ModelStore struct

+ func (s *ModelStore) Delete(ctx context.Context, modelRef spi.ModelRef) error

+ func (s *ModelStore) Get(ctx context.Context, modelRef spi.ModelRef) (*spi.ModelDescriptor, error)

+ func (s *ModelStore) GetAll(ctx context.Context) ([]spi.ModelRef, error)

+ func (s *ModelStore) IsLocked(ctx context.Context, modelRef spi.ModelRef) (bool, error)

+ func (s *ModelStore) Lock(ctx context.Context, modelRef spi.ModelRef) error

+ func (s *ModelStore) Save(ctx context.Context, desc *spi.ModelDescriptor) error

+ func (s *ModelStore) SetChangeLevel(ctx context.Context, modelRef spi.ModelRef, level spi.ChangeLevel) error

+ func (s *ModelStore) Unlock(ctx context.Context, modelRef spi.ModelRef) error

+ type StateMachineAuditStore struct

+ func (s *StateMachineAuditStore) GetEvents(ctx context.Context, entityID string) ([]spi.StateMachineEvent, error)

+ func (s *StateMachineAuditStore) GetEventsByTransaction(ctx context.Context, entityID string, transactionID string) ([]spi.StateMachineEvent, error)

+ func (s *StateMachineAuditStore) Record(ctx context.Context, entityID string, event spi.StateMachineEvent) error

+ type StoreFactory struct

+ func NewStoreFactory() *StoreFactory

+ func (f *StoreFactory) AsyncSearchStore(_ context.Context) (spi.AsyncSearchStore, error)

+ func (f *StoreFactory) Close() error

+ func (f *StoreFactory) EntityStore(ctx context.Context) (spi.EntityStore, error)

+ func (f *StoreFactory) GetTransactionManager() spi.TransactionManager

+ func (f *StoreFactory) KeyValueStore(ctx context.Context) (spi.KeyValueStore, error)

+ func (f *StoreFactory) MessageStore(ctx context.Context) (spi.MessageStore, error)

+ func (f *StoreFactory) ModelStore(ctx context.Context) (spi.ModelStore, error)

+ func (f *StoreFactory) NewTransactionManager(uuids spi.UUIDGenerator) *TransactionManager

+ func (f *StoreFactory) StateMachineAuditStore(ctx context.Context) (spi.StateMachineAuditStore, error)

+ func (f *StoreFactory) TransactionManager(ctx context.Context) (spi.TransactionManager, error)

+ func (f *StoreFactory) WorkflowStore(ctx context.Context) (spi.WorkflowStore, error)

+ type TransactionManager struct

+ func (m *TransactionManager) Begin(ctx context.Context) (string, context.Context, error)

+ func (m *TransactionManager) Commit(ctx context.Context, txID string) error

+ func (m *TransactionManager) CommittedLogLen() int

+ func (m *TransactionManager) GetSubmitTime(_ context.Context, txID string) (time.Time, error)

+ func (m *TransactionManager) Join(ctx context.Context, txID string) (context.Context, error)

+ func (m *TransactionManager) ReleaseSavepoint(_ context.Context, txID string, savepointID string) error

+ func (m *TransactionManager) Rollback(ctx context.Context, txID string) error

+ func (m *TransactionManager) RollbackToSavepoint(_ context.Context, txID string, savepointID string) error

+ func (m *TransactionManager) Savepoint(_ context.Context, txID string) (string, error)

+ type WorkflowStore struct

+ func (s *WorkflowStore) Delete(ctx context.Context, modelRef spi.ModelRef) error

+ func (s *WorkflowStore) Get(ctx context.Context, modelRef spi.ModelRef) ([]spi.WorkflowDefinition, error)

+ func (s *WorkflowStore) Save(ctx context.Context, modelRef spi.ModelRef, workflows []spi.WorkflowDefinition) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL