eventsource

Mar 3, 2020

Changes in this version

type Repository

+ Store func() Store

type RepositoryMock

+ func (r RepositoryMock) Store() Store

Feb 13, 2020

Changes in this version

+ type NotificationService interface

+ SendNotification func(record Record) error

+ type NotificationServiceMock struct

+ func CreateNotificationServiceMock() *NotificationServiceMock

+ func (ns NotificationServiceMock) SendNotification(record Record) error

type Repository

+ SetNotificationService func(notificationService NotificationService)

type RepositoryMock

+ func (r RepositoryMock) SetNotificationService(ns NotificationService)

Jan 25, 2019

Changes in this version

+ func GetType(e Event) reflect.Type

+ func GetTypeName(e Event) string

type Repository

+ GetEventsBySequenceIDAndType func(ctx context.Context, sequenceID string, eventType Event, limit int) (events []Event, err error)

type RepositoryMock

+ func (r RepositoryMock) GetEventsBySequenceIDAndType(ctx context.Context, sequenceID string, eventType Event, limit int) ([]Event, error)

type Store

+ LoadBySequenceIDAndType func(ctx context.Context, sequenceID string, eventType string, limit int) (records []Record, err error)

type StoreMock

+ func (o StoreMock) LoadBySequenceIDAndType(ctx context.Context, sequenceID string, eventType string, limit int) (record []Record, err error)

Dec 7, 2018

Changes in this version

type BaseEvent

+ SequenceID string

+ Timestamp int64

+ func (e *BaseEvent) SetSequenceID(sequenceID string)

+ func (e *BaseEvent) SetTimestamp(timestamp int64)

+ func (e BaseEvent) GetSequenceID() string

+ func (e BaseEvent) GetTimestamp() int64

type Event

+ GetSequenceID func() string

+ GetTimestamp func() int64

+ SetSequenceID func(string)

+ SetTimestamp func(int64)

+ type EventRecord struct

+ Event Event

+ Record Record

type Repository

+ GetEventsBySequenceID func(ctx context.Context, sequenceID string) (events []Event, err error)

+ GetEventsByTimestamp func(ctx context.Context, timestamp int64) (events []Event, err error)

type RepositoryMock

+ func (r RepositoryMock) GetEventsBySequenceID(ctx context.Context, sequenceID string) ([]Event, error)

+ func (r RepositoryMock) GetEventsByTimestamp(ctx context.Context, timestamp int64) ([]Event, error)

type Store

+ LoadByAggregate func(ctx context.Context, aggregateID string) (record []Record, err error)

+ LoadBySequenceID func(ctx context.Context, sequenceID string) (record []Record, err error)

+ LoadByTimestamp func(ctx context.Context, timestamp int64) (record []Record, err error)

type StoreMock

+ func (o StoreMock) LoadByAggregate(ctx context.Context, aggregateID string) (record []Record, err error)

+ func (o StoreMock) LoadBySequenceID(ctx context.Context, sequenceID string) (record []Record, err error)

+ func (o StoreMock) LoadByTimestamp(ctx context.Context, timestamp int64) (record []Record, err error)

Nov 19, 2018

Changes in this version

type Repository

+ SaveTransaction func(ctx context.Context, events ...Event) (StoreTransaction, error)

type RepositoryMock

+ func (r RepositoryMock) SaveTransaction(ctx context.Context, events ...Event) (StoreTransaction, error)

type Store

+ NewTransaction func(ctx context.Context, records ...Record) (StoreTransaction, error)

type StoreMock

+ func (o StoreMock) NewTransaction(ctx context.Context, records ...Record) (StoreTransaction, error)

+ type StoreTransaction interface

+ Commit func() error

+ Rollback func() error

+ type StoreTransactionMock struct

+ func CreateStoreTransactionMock() *StoreTransactionMock

+ func (o StoreTransactionMock) Commit() error

+ func (o StoreTransactionMock) Rollback() error

Nov 6, 2018

Changes in this version

+ func NewULID() string

Nov 5, 2018

Changes in this version

+ var ErrDeleted = errors.New("Not found (was deleted)")

+ var ErrNoHistory = errors.New("No history found")

+ type Aggregate interface

+ On func(ctx context.Context, event Event) error

+ SetAggregateID func(id string)

+ type AggregatorMock struct

+ Mock *mock.Mock

+ func CreateAggregatorMock() *AggregatorMock

+ func (o AggregatorMock) On(ctx context.Context, event Event) error

+ func (o AggregatorMock) SetAggregateID(id string)

+ type BaseEvent struct

+ AggregateID string

+ UserID string

+ func (e BaseEvent) GetAggregateID() string

+ func (e BaseEvent) GetUserID() string

+ type Event interface

+ GetAggregateID func() string

+ GetUserID func() (userID string)

+ type EventOnSave interface

+ OnSave func(Record) error

+ type EventOnSaveWithContext interface

+ OnSave func(context.Context, Record) error

+ type Record struct

+ AggregateID string

+ Data []byte

+ SequenceID string

+ Timestamp time.Time

+ Type string

+ UserID string

+ type Repository interface

+ Load func(id string, aggr Aggregate) (deleted bool, err error)

+ LoadWithContext func(ctx context.Context, id string, aggr Aggregate) (deleted bool, err error)

+ Save func(events ...Event) (err error)

+ SaveWithContext func(ctx context.Context, events ...Event) (err error)

+ func NewRepository(store Store, serializer Serializer) Repository

+ type RepositoryMock struct

+ func CreateRepositoryMock() *RepositoryMock

+ func (r RepositoryMock) Load(id string, aggr Aggregate) (deleted bool, err error)

+ func (r RepositoryMock) LoadWithContext(ctx context.Context, id string, aggr Aggregate) (deleted bool, err error)

+ func (r RepositoryMock) Save(events ...Event) (err error)

+ func (r RepositoryMock) SaveWithContext(ctx context.Context, events ...Event) (err error)

+ type Serializer interface

+ Marshal func(event Event) (data []byte, err error)

+ Unmarshal func(data []byte, eventType string) (event Event, err error)

+ type SerializerMock struct

+ func CreateSerializerMock() *SerializerMock

+ func (o SerializerMock) Marshal(event Event) (data []byte, err error)

+ func (o SerializerMock) Unmarshal(data []byte, eventType string) (event Event, err error)

+ type Store interface

+ Load func(id string) (record []Record, err error)

+ LoadWithContext func(ctx context.Context, id string) (record []Record, err error)

+ Save func(record Record) error

+ SaveWithContext func(ctx context.Context, record Record) error

+ type StoreMock struct

+ func CreateStoreMock() *StoreMock

+ func (o StoreMock) Load(id string) (record []Record, err error)

+ func (o StoreMock) LoadWithContext(ctx context.Context, id string) (record []Record, err error)

+ func (o StoreMock) Save(record Record) error

+ func (o StoreMock) SaveWithContext(ctx context.Context, record Record) error