Versions in this module Expand all Collapse all v2 v2.1.0 Sep 15, 2022 v2.0.0 Sep 14, 2021 Changes in this version + type DummyMessage struct + func NewDummyMessage(id goengine.UUID, payload interface{}, meta metadata.Metadata, time time.Time) *DummyMessage + func (d *DummyMessage) CreatedAt() time.Time + func (d *DummyMessage) Metadata() metadata.Metadata + func (d *DummyMessage) Payload() interface{} + func (d *DummyMessage) UUID() goengine.UUID + func (d *DummyMessage) WithMetadata(key string, value interface{}) goengine.Message + type EventStore struct + func NewEventStore(ctrl *gomock.Controller) *EventStore + func (m *EventStore) AppendTo(arg0 context.Context, arg1 goengine.StreamName, arg2 []goengine.Message) error + func (m *EventStore) Create(arg0 context.Context, arg1 goengine.StreamName) error + func (m *EventStore) EXPECT() *EventStoreMockRecorder + func (m *EventStore) HasStream(arg0 context.Context, arg1 goengine.StreamName) bool + func (m *EventStore) Load(arg0 context.Context, arg1 goengine.StreamName, arg2 int64, arg3 *uint, ...) (goengine.EventStream, error) + type EventStoreMockRecorder struct + func (mr *EventStoreMockRecorder) AppendTo(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *EventStoreMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call + func (mr *EventStoreMockRecorder) HasStream(arg0, arg1 interface{}) *gomock.Call + func (mr *EventStoreMockRecorder) Load(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + type EventStream struct + func NewEventStream(ctrl *gomock.Controller) *EventStream + func (m *EventStream) Close() error + func (m *EventStream) EXPECT() *EventStreamMockRecorder + func (m *EventStream) Err() error + func (m *EventStream) Message() (goengine.Message, int64, error) + func (m *EventStream) Next() bool + type EventStreamMockRecorder struct + func (mr *EventStreamMockRecorder) Close() *gomock.Call + func (mr *EventStreamMockRecorder) Err() *gomock.Call + func (mr *EventStreamMockRecorder) Message() *gomock.Call + func (mr *EventStreamMockRecorder) Next() *gomock.Call + type Message struct + func NewMessage(ctrl *gomock.Controller) *Message + func (m *Message) CreatedAt() time.Time + func (m *Message) EXPECT() *MessageMockRecorder + func (m *Message) Metadata() metadata.Metadata + func (m *Message) Payload() interface{} + func (m *Message) UUID() uuid.UUID + func (m *Message) WithMetadata(arg0 string, arg1 interface{}) goengine.Message + type MessageMockRecorder struct + func (mr *MessageMockRecorder) CreatedAt() *gomock.Call + func (mr *MessageMockRecorder) Metadata() *gomock.Call + func (mr *MessageMockRecorder) Payload() *gomock.Call + func (mr *MessageMockRecorder) UUID() *gomock.Call + func (mr *MessageMockRecorder) WithMetadata(arg0, arg1 interface{}) *gomock.Call + type MessagePayloadConverter struct + func NewMessagePayloadConverter(ctrl *gomock.Controller) *MessagePayloadConverter + func (m *MessagePayloadConverter) ConvertPayload(arg0 interface{}) (string, []byte, error) + func (m *MessagePayloadConverter) EXPECT() *MessagePayloadConverterMockRecorder + type MessagePayloadConverterMockRecorder struct + func (mr *MessagePayloadConverterMockRecorder) ConvertPayload(arg0 interface{}) *gomock.Call + type MessagePayloadFactory struct + func NewMessagePayloadFactory(ctrl *gomock.Controller) *MessagePayloadFactory + func (m *MessagePayloadFactory) CreatePayload(arg0 string, arg1 interface{}) (interface{}, error) + func (m *MessagePayloadFactory) EXPECT() *MessagePayloadFactoryMockRecorder + type MessagePayloadFactoryMockRecorder struct + func (mr *MessagePayloadFactoryMockRecorder) CreatePayload(arg0, arg1 interface{}) *gomock.Call + type MessagePayloadResolver struct + func NewMessagePayloadResolver(ctrl *gomock.Controller) *MessagePayloadResolver + func (m *MessagePayloadResolver) EXPECT() *MessagePayloadResolverMockRecorder + func (m *MessagePayloadResolver) ResolveName(arg0 interface{}) (string, error) + type MessagePayloadResolverMockRecorder struct + func (mr *MessagePayloadResolverMockRecorder) ResolveName(arg0 interface{}) *gomock.Call + type Query struct + func NewQuery(ctrl *gomock.Controller) *Query + func (m *Query) EXPECT() *QueryMockRecorder + func (m *Query) Handlers() map[string]goengine.MessageHandler + func (m *Query) Init(arg0 context.Context) (interface{}, error) + type QueryMockRecorder struct + func (mr *QueryMockRecorder) Handlers() *gomock.Call + func (mr *QueryMockRecorder) Init(arg0 interface{}) *gomock.Call Other modules containing this package github.com/hellofresh/goengine
Go to main page