memory

package

v0.0.1 Latest Latest Go to latest Published: Oct 5, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/legitbiz/spry

Links

Open Source Insights

Documentation ¶

Index ¶

func GetEventsAfter(events []storage.EventRecord, last uuid.UUID) []storage.EventRecord
func InMemoryStorage() storage.Storage
type IdLinks
type InMemoryCommandStore
- func (store *InMemoryCommandStore) Add(ctx context.Context, actorName string, command storage.CommandRecord) error
type InMemoryEventStore
type InMemoryMapStore
type InMemorySnapshotStore
- func (store *InMemorySnapshotStore) Add(ctx context.Context, actorName string, snapshot storage.Snapshot, ...) error
- func (store *InMemorySnapshotStore) Fetch(ctx context.Context, actorName string, actorId uuid.UUID) (storage.Snapshot, error)
type InMemoryTxProvider

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetEventsAfter ¶

func GetEventsAfter(events []storage.EventRecord, last uuid.UUID) []storage.EventRecord

func InMemoryStorage ¶

func InMemoryStorage() storage.Storage

Types ¶

type IdLinks ¶

type IdLinks map[string]map[uuid.UUID]storage.AggregatedIds

type InMemoryCommandStore ¶

type InMemoryCommandStore struct {
	Commands map[uuid.UUID][]storage.CommandRecord
}

func (*InMemoryCommandStore) Add ¶

func (store *InMemoryCommandStore) Add(
	ctx context.Context,
	actorName string,
	command storage.CommandRecord) error

type InMemoryEventStore ¶

type InMemoryEventStore struct {
	Events map[uuid.UUID][]storage.EventRecord
}

func (*InMemoryEventStore) Add ¶

func (store *InMemoryEventStore) Add(ctx context.Context, events []storage.EventRecord) error

func (*InMemoryEventStore) FetchAggregatedSince ¶

func (store *InMemoryEventStore) FetchAggregatedSince(
	ctx context.Context,
	actorName string,
	actorId uuid.UUID,
	eventUUID uuid.UUID,
	idMap storage.LastEventMap,
	types storage.TypeMap) ([]storage.EventRecord, error)

func (*InMemoryEventStore) FetchSince ¶

func (store *InMemoryEventStore) FetchSince(
	ctx context.Context,
	actorName string,
	actorId uuid.UUID,
	eventUUID uuid.UUID,
	types storage.TypeMap) ([]storage.EventRecord, error)

type InMemoryMapStore ¶

type InMemoryMapStore struct {
	IdMap   map[string]uuid.UUID
	LinkMap IdLinks
}

func (*InMemoryMapStore) AddId ¶

func (maps *InMemoryMapStore) AddId(ctx context.Context, actorName string, ids spry.Identifiers, uid uuid.UUID) error

func (*InMemoryMapStore) AddLink ¶

func (maps *InMemoryMapStore) AddLink(ctx context.Context, parentType string, parentId uuid.UUID, childType string, childId uuid.UUID) error

func (*InMemoryMapStore) GetId ¶

func (maps *InMemoryMapStore) GetId(ctx context.Context, actorName string, ids spry.Identifiers) (uuid.UUID, error)

func (*InMemoryMapStore) GetIdMap ¶

func (maps *InMemoryMapStore) GetIdMap(
	ctx context.Context,
	actorName string,
	uid uuid.UUID) (storage.AggregateIdMap, error)

type InMemorySnapshotStore ¶

type InMemorySnapshotStore struct {
	Snapshots map[uuid.UUID][]storage.Snapshot
}

func (*InMemorySnapshotStore) Add ¶

func (store *InMemorySnapshotStore) Add(ctx context.Context, actorName string, snapshot storage.Snapshot, allowPartition bool) error

func (*InMemorySnapshotStore) Fetch ¶

func (store *InMemorySnapshotStore) Fetch(ctx context.Context, actorName string, actorId uuid.UUID) (storage.Snapshot, error)

type InMemoryTxProvider ¶

type InMemoryTxProvider struct {
}

func (InMemoryTxProvider) Commit ¶

func (provider InMemoryTxProvider) Commit(ctx context.Context) error

func (InMemoryTxProvider) GetTransaction ¶

func (provider InMemoryTxProvider) GetTransaction(ctx context.Context) (storage.NoOpTx, error)

func (InMemoryTxProvider) Rollback ¶

func (provider InMemoryTxProvider) Rollback(ctx context.Context) error

Source Files ¶

View all Source files

inmemory.go

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