snapshot

Documentation

Index

• func WithMemorySnapshotStore() revent.AppOption
• type MemorySnapshotStore
  • func NewMemorySnapshotStore() *MemorySnapshotStore
  • func (m *MemorySnapshotStore) GetSnapshot(id aggregate.AggregateID) (revent.Snapshot, error)
  • func (m *MemorySnapshotStore) SaveSnapshot(id aggregate.AggregateID, snapshot revent.Snapshot) error
• type MongodbSnapshotStore
  • func NewMongoSnapshotStore(db *mongo.Database) *MongodbSnapshotStore
  • func (m *MongodbSnapshotStore) GetSnapshot(id aggregate.AggregateID) (revent.Snapshot, error)
  • func (m *MongodbSnapshotStore) SaveSnapshot(id aggregate.AggregateID, snapshot revent.Snapshot) error

Functions

func WithMemorySnapshotStore

func WithMemorySnapshotStore() revent.AppOption

Types

type MemorySnapshotStore

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

github.com/revent-dev/revent/store.SnapshotStore

func NewMemorySnapshotStore

func NewMemorySnapshotStore() *MemorySnapshotStore

func (*MemorySnapshotStore) GetSnapshot

func (m *MemorySnapshotStore) GetSnapshot(id aggregate.AggregateID) (revent.Snapshot, error)

func (*MemorySnapshotStore) SaveSnapshot

func (m *MemorySnapshotStore) SaveSnapshot(id aggregate.AggregateID, snapshot revent.Snapshot) error

type MongodbSnapshotStore

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

github.com/revent-dev/revent/store.SnapshotStore

func NewMongoSnapshotStore

func NewMongoSnapshotStore(db *mongo.Database) *MongodbSnapshotStore

func (*MongodbSnapshotStore) GetSnapshot

func (m *MongodbSnapshotStore) GetSnapshot(id aggregate.AggregateID) (revent.Snapshot, error)

func (*MongodbSnapshotStore) SaveSnapshot

func (m *MongodbSnapshotStore) SaveSnapshot(id aggregate.AggregateID, snapshot revent.Snapshot) error