eventsource

Mar 1, 2021

Changes in this version

+ var ErrNotificationFailed = errors.New("Failed to send notification")

Dec 3, 2020

Changes in this version

type NotificationService

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

type NotificationServiceMock

+ func (ns NotificationServiceMock) SendWithContext(ctx context.Context, record Record) error

Sep 22, 2020

Changes in this version

type Repository

+ UnmarshalRecords func(records []Record) (events []Event, err error)

type RepositoryMock

+ func (r RepositoryMock) UnmarshalRecords(records []Record) ([]Event, error)

type StoreTransaction

+ GetRecords func() []Record

type StoreTransactionMock

+ func (o StoreTransactionMock) GetRecords() []Record

Jun 4, 2020

Changes in this version

type Repository

+ LoadEvents func(ctx context.Context, opts ...QueryOption) (events []Event, err error)

type RepositoryMock

+ func (r RepositoryMock) LoadEvents(ctx context.Context, opts ...QueryOption) ([]Event, error)

type Store

+ Load func(ctx context.Context, opts ...QueryOption) ([]Record, error)

type StoreMock

+ func (o StoreMock) Load(ctx context.Context, opts ...QueryOption) (record []Record, err error)

May 4, 2020

Changes in this version

type NotificationService

+ Send func(record Record) error

type NotificationServiceMock

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

type Repository

+ AddNotificationService func(service NotificationService)

type RepositoryMock

+ func (r RepositoryMock) AddNotificationService(service NotificationService)

Mar 27, 2020

Changes in this version

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

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

+ func GetType(e Event) reflect.Type

+ func GetTypeName(e Event) string

+ func NewULID() string

+ 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

+ SequenceID string

+ Timestamp int64

+ UserID string

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

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

+ func (e BaseEvent) GetAggregateID() string

+ func (e BaseEvent) GetSequenceID() string

+ func (e BaseEvent) GetTimestamp() int64

+ func (e BaseEvent) GetUserID() string

+ type Event interface

+ GetAggregateID func() string

+ GetSequenceID func() string

+ GetTimestamp func() int64

+ GetUserID func() string

+ SetSequenceID func(string)

+ SetTimestamp func(int64)

+ type NotificationService interface

+ SendNotification func(record Record) error

+ type NotificationServiceMock struct

+ func CreateNotificationServiceMock() *NotificationServiceMock

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

+ type QueryOption func(opt interface{})

+ type Record struct

+ AggregateID string

+ Data []byte

+ SequenceID string

+ Timestamp int64

+ Type string

+ UserID string

+ type Repository interface

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

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

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

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

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

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

+ SetNotificationService func(notificationService NotificationService)

+ Store func() Store

+ func NewRepository(store Store, serializer Serializer) Repository

+ type RepositoryMock struct

+ func CreateRepositoryMock() *RepositoryMock

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

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

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

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

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

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

+ func (r RepositoryMock) SetNotificationService(ns NotificationService)

+ func (r RepositoryMock) Store() Store

+ 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

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

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

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

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

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

+ type StoreMock struct

+ func CreateStoreMock() *StoreMock

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

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

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

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

+ 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