bolt

Documentation

Index

• type BoltStoreManager
  • func NewBoltStoreManager(path string) (*BoltStoreManager, error)
  • func (m *BoltStoreManager) All(start core.Version, filter fluxcore.Filter) (iter.Seq[fluxcore.Event], error)
  • func (m *BoltStoreManager) Create(id fluxcore.StoreId, metadata fluxcore.Metadata) (fluxcore.SubStore, error)
  • func (m *BoltStoreManager) Get(id fluxcore.StoreId) (fluxcore.SubStore, error)
  • func (m *BoltStoreManager) List(metadata fluxcore.Metadata) iter.Seq[fluxcore.SubStore]
  • func (m *BoltStoreManager) OnCommit(cb func(fluxcore.SubStore, []fluxcore.Event)) fluxcore.Unsubscriber
• type BoltSubStore
  • func (s *BoltSubStore) All(start core.Version) (iter.Seq[core.Event], error)
  • func (s *BoltSubStore) Append(event core.Event) error
  • func (s *BoltSubStore) Get(ctx context.Context, id string, aggregateType string, ...) (core.Iterator, error)
  • func (s *BoltSubStore) Id() fluxcore.StoreId
  • func (s *BoltSubStore) LastVersion() core.Version
  • func (s *BoltSubStore) Metadata() fluxcore.Metadata
  • func (s *BoltSubStore) Save(events []core.Event) error
  • func (s *BoltSubStore) UpdateMetadata(metadata fluxcore.Metadata) error

Types

type BoltStoreManager

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

func NewBoltStoreManager

func NewBoltStoreManager(path string) (*BoltStoreManager, error)

NewBoltStoreManager creates a new EdgeStoreManager

func (*BoltStoreManager) All

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

func (*BoltStoreManager) Create

func (m *BoltStoreManager) Create(id fluxcore.StoreId, metadata fluxcore.Metadata) (fluxcore.SubStore, error)

func (*BoltStoreManager) Get

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

func (*BoltStoreManager) List

func (m *BoltStoreManager) List(metadata fluxcore.Metadata) iter.Seq[fluxcore.SubStore]

func (*BoltStoreManager) OnCommit

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

type BoltSubStore

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

func (*BoltSubStore) All

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

All iterate over event in GlobalEvents order

func (*BoltSubStore) Append

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

func (*BoltSubStore) Get

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

Get aggregate events

func (*BoltSubStore) Id

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

func (*BoltSubStore) LastVersion

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

func (*BoltSubStore) Metadata

func (s *BoltSubStore) Metadata() fluxcore.Metadata

func (*BoltSubStore) Save

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

Save an aggregate (its events)

func (*BoltSubStore) UpdateMetadata

func (s *BoltSubStore) UpdateMetadata(metadata fluxcore.Metadata) error