memory

Documentation

Index

• type InMemoryStoreManager
  • func NewInMemoryStoreManager() *InMemoryStoreManager
  • func (m *InMemoryStoreManager) All(start core.Version) (iter.Seq[fluxcore.Event], error)
  • func (m *InMemoryStoreManager) Create(id fluxcore.StoreId, metadata map[string]string) (fluxcore.SubStore, error)
  • func (m *InMemoryStoreManager) Get(id fluxcore.StoreId) (fluxcore.SubStore, error)
  • func (m *InMemoryStoreManager) List(metadata map[string]string) iter.Seq[fluxcore.SubStore]
  • func (m *InMemoryStoreManager) OnCommit(cb func(fluxcore.SubStore, []fluxcore.Event)) fluxcore.Unsubscriber
  • func (m *InMemoryStoreManager) Tx() *transaction
• type InMemorySubStore
  • func (s *InMemorySubStore) All(start core.Version) (iter.Seq[core.Event], error)
  • func (s *InMemorySubStore) Append(event core.Event) error
  • func (s *InMemorySubStore) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)
  • func (s *InMemorySubStore) Id() fluxcore.StoreId
  • func (s *InMemorySubStore) LastVersion() core.Version
  • func (s *InMemorySubStore) Metadata() map[string]string
  • func (s *InMemorySubStore) Save(events []core.Event) error
  • func (s *InMemorySubStore) UpdateMetadata(metadata map[string]string) error

Types

type InMemoryStoreManager

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

func NewInMemoryStoreManager

func NewInMemoryStoreManager() *InMemoryStoreManager

func (*InMemoryStoreManager) All

func (m *InMemoryStoreManager) All(start core.Version) (iter.Seq[fluxcore.Event], error)

func (*InMemoryStoreManager) Create

func (m *InMemoryStoreManager) Create(id fluxcore.StoreId, metadata map[string]string) (fluxcore.SubStore, error)

func (*InMemoryStoreManager) Get

func (m *InMemoryStoreManager) Get(id fluxcore.StoreId) (fluxcore.SubStore, error)

func (*InMemoryStoreManager) List

func (m *InMemoryStoreManager) List(metadata map[string]string) iter.Seq[fluxcore.SubStore]

func (*InMemoryStoreManager) OnCommit

func (m *InMemoryStoreManager) OnCommit(cb func(fluxcore.SubStore, []fluxcore.Event)) fluxcore.Unsubscriber

func (*InMemoryStoreManager) Tx

func (m *InMemoryStoreManager) Tx() *transaction

type InMemorySubStore

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

func (*InMemorySubStore) All

func (s *InMemorySubStore) All(start core.Version) (iter.Seq[core.Event], error)

func (*InMemorySubStore) Append

func (s *InMemorySubStore) Append(event core.Event) error

func (*InMemorySubStore) Get

func (s *InMemorySubStore) Get(ctx context.Context, id string, aggregateType string, afterVersion core.Version) (core.Iterator, error)

func (*InMemorySubStore) Id

func (s *InMemorySubStore) Id() fluxcore.StoreId

func (*InMemorySubStore) LastVersion

func (s *InMemorySubStore) LastVersion() core.Version

func (*InMemorySubStore) Metadata

func (s *InMemorySubStore) Metadata() map[string]string

func (*InMemorySubStore) Save

func (s *InMemorySubStore) Save(events []core.Event) error

func (*InMemorySubStore) UpdateMetadata

func (s *InMemorySubStore) UpdateMetadata(metadata map[string]string) error