dynamodb

Mar 19, 2019

Changes in this version

+ type IndexInput struct

+ IndexName string

+ PartitionKey string

+ PartitionKeyValue interface{}

+ SortKey string

+ SortKeyValue interface{}

type Repo

+ func (r *Repo) FindWithFilterUsingIndex(ctx context.Context, indexInput IndexInput, filterQuery string, ...) ([]eh.Entity, error)

Mar 5, 2019

Changes in this version

type EventStore

+ func (s *EventStore) LoadAll(ctx context.Context) ([]eh.Event, error)

Jan 22, 2019

Changes in this version

type EventStore

+ func NewEventStoreWithDB(config *EventStoreConfig, db *dynamo.DB) *EventStore

+ func (s *EventStore) TableName(ctx context.Context) string

type Repo

+ func (r *Repo) FindWithFilter(ctx context.Context, expr string, args ...interface{}) ([]eh.Entity, error)

Oct 3, 2018

Changes in this version

+ var ErrCouldNotClearDB = errors.New("could not clear database")

+ var ErrCouldNotDialDB = errors.New("could not dial database")

+ var ErrCouldNotMarshalEvent = errors.New("could not marshal event")

+ var ErrCouldNotSaveAggregate = errors.New("could not save aggregate")

+ var ErrCouldNotUnmarshalEvent = errors.New("could not unmarshal event")

+ var ErrModelNotSet = errors.New("model not set")

+ type EventStore struct

+ func NewEventStore(config *EventStoreConfig) (*EventStore, error)

+ func (s *EventStore) CreateTable(ctx context.Context) error

+ func (s *EventStore) DeleteTable(ctx context.Context) error

+ func (s *EventStore) Load(ctx context.Context, id eh.UUID) ([]eh.Event, error)

+ func (s *EventStore) RenameEvent(ctx context.Context, from, to eh.EventType) error

+ func (s *EventStore) Replace(ctx context.Context, event eh.Event) error

+ func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersion int) error

+ type EventStoreConfig struct

+ Endpoint string

+ Region string

+ TablePrefix string

+ type Repo struct

+ func NewRepo(config *RepoConfig) (*Repo, error)

+ func (r *Repo) Find(ctx context.Context, id eh.UUID) (eh.Entity, error)

+ func (r *Repo) FindAll(ctx context.Context) ([]eh.Entity, error)

+ func (r *Repo) Parent() eh.ReadRepo

+ func (r *Repo) Remove(ctx context.Context, id eh.UUID) error

+ func (r *Repo) Save(ctx context.Context, entity eh.Entity) error

+ func (r *Repo) SetEntityFactory(f func() eh.Entity)

+ type RepoConfig struct

+ Endpoint string

+ Region string

+ TableName string