eventsource

package

Go to main page

Versions in this module

v0

v0.0.14

Jun 8, 2021

v0.0.13

Jun 3, 2021

v0.0.12

Jun 1, 2021

Changes in this version

type AggregateBase

+ func (a *AggregateBase) MarkEventsCommitted()

v0.0.11

May 31, 2021

Changes in this version

+ type AggregateBaseSetter struct

+ func NewAggregateBaseSetter(eventCodec, snapCodec codec.Codec, idGen IdGenerator) *AggregateBaseSetter

+ func (a *AggregateBaseSetter) SetAggregateBase(agg Aggregate, aggId, aggType string, version int64)

+ type MockEventStore struct

+ func NewMockEventStore(ctrl *gomock.Controller) *MockEventStore

+ func (m *MockEventStore) Commit(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockEventStore) EXPECT() *MockEventStoreMockRecorder

+ func (m *MockEventStore) LoadEvents(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockEventStore) LoadEventsWithSnapshot(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockEventStore) SaveSnapshot(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockEventStore) SetAggregateBase(arg0 Aggregate, arg1, arg2 string, arg3 int64)

+ func (m *MockEventStore) StreamAggregates(arg0 context.Context, arg1 string, arg2 int64, arg3 AggregateFactory) (<-chan Aggregate, error)

+ func (m *MockEventStore) StreamEvents(arg0 context.Context, arg1 *StreamEventsRequest) (<-chan *Event, error)

+ func (m *MockEventStore) StreamProjections(arg0 context.Context, arg1 string, arg2 int64, arg3 ProjectionFactory) (<-chan Projection, error)

+ type MockEventStoreMockRecorder struct

+ func (mr *MockEventStoreMockRecorder) Commit(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) LoadEvents(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) LoadEventsWithSnapshot(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) SetAggregateBase(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) StreamAggregates(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventStoreMockRecorder) StreamProjections(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

v0.0.10

May 25, 2021

v0.0.9

May 24, 2021

Changes in this version

type Cursor

+ GetAggregateStream func(withSnapshot bool) (<-chan *CursorAggregate, error)

type EventStore

+ LoadEvents func(ctx context.Context, aggregate Aggregate) error

+ LoadEventsWithSnapshot func(ctx context.Context, aggregate Aggregate) error

type Storage

+ As func(dst interface{}) error

+ ListEvents func(ctx context.Context, aggId string, aggType string) ([]*Event, error)

+ ListEventsFromRevision func(ctx context.Context, aggId string, aggType string, from int64) ([]*Event, error)

type Store

+ func (e *Store) CopyWithStorage(storage Storage) *Store

+ func (e *Store) LoadEvents(ctx context.Context, agg Aggregate) error

+ func (e *Store) LoadEventsWithSnapshot(ctx context.Context, agg Aggregate) error

v0.0.8

May 24, 2021

Changes in this version

+ type EventCodec codec.Codec

+ type SnapshotCodec codec.Codec

+ type Store struct

+ func (a Store) SetAggregateBase(agg Aggregate, aggId, aggType string, version int64)

+ func (e *Store) Commit(ctx context.Context, agg Aggregate) error

+ func (e *Store) LoadEventStream(ctx context.Context, agg Aggregate) error

+ func (e *Store) LoadEventStreamWithSnapshot(ctx context.Context, agg Aggregate) error

+ func (e *Store) SaveSnapshot(ctx context.Context, agg Aggregate) error

+ func (e *Store) StreamAggregates(ctx context.Context, aggType string, aggVersion int64, ...) (<-chan Aggregate, error)

+ func (e *Store) StreamEvents(ctx context.Context, req *StreamEventsRequest) (<-chan *Event, error)

+ func (e *Store) StreamProjections(ctx context.Context, aggType string, aggVersion int64, ...) (<-chan Projection, error)

+ func (e *Store) WithStorage(storage Storage) *Store

v0.0.7

May 23, 2021

v0.0.6

May 23, 2021

v0.0.5

May 21, 2021

v0.0.4

May 17, 2021

v0.0.3

May 17, 2021

v0.0.2

May 17, 2021

v0.0.1

May 12, 2021

Changes in this version

+ var File_event_proto protoreflect.FileDescriptor

+ type Aggregate interface

+ AggBase func() *AggregateBase

+ Apply func(e *Event) error

+ Reset func()

+ SetBase func(base *AggregateBase)

+ type AggregateBase struct

+ func (a *AggregateBase) CommittedEvents() []*Event

+ func (a *AggregateBase) DecodeEventAs(eventData []byte, eventMsg interface{}) error

+ func (a *AggregateBase) ID() string

+ func (a *AggregateBase) LatestCommittedEvent() (*Event, bool)

+ func (a *AggregateBase) MustLatestCommittedEvent() *Event

+ func (a *AggregateBase) Revision() int64

+ func (a *AggregateBase) SetEvent(eventMsg EventMessage) error

+ func (a *AggregateBase) SetID(id string)

+ func (a *AggregateBase) Timestamp() int64

+ func (a *AggregateBase) Type() string

+ func (a *AggregateBase) Version() int64

+ type AggregateFactory interface

+ New func(aggType string, aggVersion int64) Aggregate

+ type Config struct

+ BufferSize int

+ EventCodec codec.Codec

+ SnapshotCodec codec.Codec

+ func DefaultConfig() *Config

+ func (c *Config) Validate() error

+ type Cursor interface

+ OpenChannel func(withSnapshot bool) (<-chan *CursorAggregate, error)

+ type CursorAggregate struct

+ AggregateID string

+ Events []*Event

+ Snapshot *Snapshot

+ type Event struct

+ AggregateId string

+ AggregateType string

+ EventData []byte

+ EventId string

+ EventType string

+ Revision int64

+ Timestamp int64

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (x *Event) Copy() *Event

+ func (x *Event) GetAggregateId() string

+ func (x *Event) GetAggregateType() string

+ func (x *Event) GetEventData() []byte

+ func (x *Event) GetEventId() string

+ func (x *Event) GetEventType() string

+ func (x *Event) GetRevision() int64

+ func (x *Event) GetTimestamp() int64

+ func (x *Event) ProtoReflect() protoreflect.Message

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ func (x *Event) Time() time.Time

+ type EventHandler interface

+ Handle func(ctx context.Context, e *Event)

+ type EventMessage interface

+ MessageType func() string

+ type EventStore interface

+ Commit func(ctx context.Context, aggregate Aggregate) error

+ LoadEventStream func(ctx context.Context, aggregate Aggregate) error

+ LoadEventStreamWithSnapshot func(ctx context.Context, aggregate Aggregate) error

+ SaveSnapshot func(ctx context.Context, aggregate Aggregate) error

+ SetAggregateBase func(agg Aggregate, aggId, aggType string, version int64)

+ StreamAggregates func(ctx context.Context, aggType string, aggVersion int64, ...) (<-chan Aggregate, error)

+ StreamEvents func(ctx context.Context, req *StreamEventsRequest) (<-chan *Event, error)

+ StreamProjections func(ctx context.Context, aggType string, aggVersion int64, ...) (<-chan Projection, error)

+ func New(cfg *Config, storage Storage) (EventStore, error)

+ type IdGenerator interface

+ GenerateId func() string

+ type MockStore struct

+ func NewDefaultMockStore(ctrl *gomock.Controller) *MockStore

+ func NewMockStore(ctrl *gomock.Controller, eventCodec, snapCodec codec.Codec, idGen IdGenerator) *MockStore

+ func (a MockStore) SetAggregateBase(agg Aggregate, aggId, aggType string, version int64)

+ func (m *MockStore) Commit(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockStore) EXPECT() *MockStoreMockRecorder

+ func (m *MockStore) LoadEventStream(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockStore) LoadEventStreamWithSnapshot(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockStore) SaveSnapshot(arg0 context.Context, arg1 Aggregate) error

+ func (m *MockStore) StreamAggregates(arg0 context.Context, arg1 string, arg2 int64, arg3 AggregateFactory) (<-chan Aggregate, error)

+ func (m *MockStore) StreamEvents(arg0 context.Context, arg1 *StreamEventsRequest) (<-chan *Event, error)

+ func (m *MockStore) StreamProjections(arg0 context.Context, arg1 string, arg2 int64, arg3 ProjectionFactory) (<-chan Projection, error)

+ type MockStoreMockRecorder struct

+ func (mr *MockStoreMockRecorder) Commit(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) LoadEventStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) LoadEventStreamWithSnapshot(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) SaveSnapshot(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) StreamAggregates(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) StreamEvents(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) StreamProjections(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type Projection interface

+ Apply func(c codec.Codec, e *Event) error

+ type ProjectionFactory interface

+ NewProjection func(id string) Projection

+ type Snapshot struct

+ AggregateId string

+ AggregateType string

+ AggregateVersion int64

+ Revision int64

+ SnapshotData []byte

+ Timestamp int64

+ type Storage interface

+ GetEventStream func(ctx context.Context, aggId string, aggType string) ([]*Event, error)

+ GetSnapshot func(ctx context.Context, aggId string, aggType string, aggVersion int64) (*Snapshot, error)

+ GetStreamFromRevision func(ctx context.Context, aggId string, aggType string, from int64) ([]*Event, error)

+ NewCursor func(ctx context.Context, aggType string, aggVersion int64) (Cursor, error)

+ SaveEvents func(ctx context.Context, es []*Event) error

+ SaveSnapshot func(ctx context.Context, snap *Snapshot) error

+ StreamEvents func(ctx context.Context, req *StreamEventsRequest) (<-chan *Event, error)

+ type StreamEventsRequest struct

+ AggregateIDs []string

+ AggregateTypes []string

+ BuffSize int

+ EventTypes []string

+ ExcludeEventTypes []string

+ type UUIDGenerator struct

+ func (u UUIDGenerator) GenerateId() string

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