eventsource

Documentation

Index

• Variables
• func NewULID() string
• type Aggregate
• type AggregatorMock
  • func CreateAggregatorMock() *AggregatorMock
  • func (o AggregatorMock) On(ctx context.Context, event Event) error
  • func (o AggregatorMock) SetAggregateID(id string)
• type BaseEvent
  • func (e BaseEvent) GetAggregateID() string
  • func (e BaseEvent) GetUserID() string
• type Event
• type Record
• type Repository
  • func NewRepository(store Store, serializer Serializer) Repository
• type RepositoryMock
  • func CreateRepositoryMock() *RepositoryMock
  • 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)
• type Serializer
• type SerializerMock
  • 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
• type StoreMock
  • func CreateStoreMock() *StoreMock
  • func (o StoreMock) Load(ctx context.Context, id string) (record []Record, err error)
  • func (o StoreMock) NewTransaction(ctx context.Context, records ...Record) (StoreTransaction, error)
• type StoreTransaction
• type StoreTransactionMock
  • func CreateStoreTransactionMock() *StoreTransactionMock
  • func (o StoreTransactionMock) Commit() error
  • func (o StoreTransactionMock) Rollback() error

Variables

var (
	ErrDeleted   = errors.New("Not found (was deleted)")
	ErrNoHistory = errors.New("No history found")
)

Functions

func NewULID

func NewULID() string

NewULID returns a Universally Unique Lexicographically Sortable Identifier

Types

type Aggregate

type Aggregate interface {
	On(ctx context.Context, event Event) error
	SetAggregateID(id string)
}

Aggregate is a interface

type AggregatorMock

type AggregatorMock struct {
	Mock *mock.Mock
}

AggregatorMock is a mock

func CreateAggregatorMock

func CreateAggregatorMock() *AggregatorMock

CreateAggregatorMock returns a aggregatorMock

func (AggregatorMock) On

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

On is a mock

func (AggregatorMock) SetAggregateID

func (o AggregatorMock) SetAggregateID(id string)

SetAggregateID is not implemented

type BaseEvent

type BaseEvent struct {
	AggregateID string `json:"aggregateId"`
	UserID      string `json:"userId"`
}

BaseEvent ...

func (BaseEvent) GetAggregateID

func (e BaseEvent) GetAggregateID() string

GetAggregateID ...

func (BaseEvent) GetUserID

func (e BaseEvent) GetUserID() string

GetUserID ...

type Event

type Event interface {
	GetAggregateID() string
	GetUserID() (userID string)
}

Event ...

type Record

type Record struct {
	AggregateID string `json:"aggregateId"`
	SequenceID  string `json:"sequenceId"`
	Timestamp   int64  `json:"timestamp"`
	Type        string `json:"type"`
	Data        []byte `json:"data"`
	UserID      string `json:"userId"`
}

Record is a store row

type Repository

type Repository interface {
	Save(ctx context.Context, events ...Event) error
	SaveTransaction(ctx context.Context, events ...Event) (StoreTransaction, error)
	Load(ctx context.Context, id string, aggr Aggregate) (deleted bool, err error)
}

Repository is a interface

func NewRepository

func NewRepository(store Store, serializer Serializer) Repository

NewRepository returns a new repository

type RepositoryMock

type RepositoryMock struct {
	*mock.Mock
}

RepositoryMock is a mock

func CreateRepositoryMock

func CreateRepositoryMock() *RepositoryMock

CreateRepositoryMock returns a repositoryMock

func (RepositoryMock) Load

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

Load is a mock

func (RepositoryMock) Save

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

Save is a mock

func (RepositoryMock) SaveTransaction

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

SaveTransaction is a mock

type Serializer

type Serializer interface {
	Unmarshal(data []byte, eventType string) (event Event, err error)
	Marshal(event Event) (data []byte, err error)
}

Serializer is a interface

type SerializerMock

type SerializerMock struct {
	*mock.Mock
}

SerializerMock is a mock

func CreateSerializerMock

func CreateSerializerMock() *SerializerMock

CreateSerializerMock returns a serializerMock

func (SerializerMock) Marshal

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

Marshal returns the JSON encoding of event.

func (SerializerMock) Unmarshal

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

Unmarshal parses the JSON-encoded data and returns an event

type Store

type Store interface {
	NewTransaction(ctx context.Context, records ...Record) (StoreTransaction, error)
	Load(ctx context.Context, id string) (record []Record, err error)
}

Store is a interface

type StoreMock

type StoreMock struct {
	*mock.Mock
}

StoreMock is a mock

func CreateStoreMock

func CreateStoreMock() *StoreMock

CreateStoreMock returns a storeMock

func (StoreMock) Load

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

Load is a mock

func (StoreMock) NewTransaction

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

NewTransaction is a mock

type StoreTransaction

type StoreTransaction interface {
	Commit() error
	Rollback() error
}

type StoreTransactionMock

type StoreTransactionMock struct {
	*mock.Mock
}

StoreTransactionMock is a mock

func CreateStoreTransactionMock

func CreateStoreTransactionMock() *StoreTransactionMock

CreateStoreTransactionMock returns a store transaction mock

func (StoreTransactionMock) Commit

func (o StoreTransactionMock) Commit() error

Save is a mock

func (StoreTransactionMock) Rollback

func (o StoreTransactionMock) Rollback() error

Rollback is a mock