The highest tagged major version is
Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type DummyMessage
- type 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
- 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
- type EventStreamMockRecorder
- type Message
- type MessageMockRecorder
- type MessagePayloadConverter
- type MessagePayloadConverterMockRecorder
- type MessagePayloadFactory
- type MessagePayloadFactoryMockRecorder
- type MessagePayloadResolver
- type MessagePayloadResolverMockRecorder
- type Query
- type QueryMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DummyMessage ¶
type DummyMessage struct {
// contains filtered or unexported fields
}
DummyMessage a simple goengine.Message implementation used for testing
func NewDummyMessage ¶
func NewDummyMessage(id goengine.UUID, payload interface{}, meta metadata.Metadata, time time.Time) *DummyMessage
NewDummyMessage returns a new DummyMessage
func (*DummyMessage) CreatedAt ¶
func (d *DummyMessage) CreatedAt() time.Time
CreatedAt returns the created time of the message
func (*DummyMessage) Metadata ¶
func (d *DummyMessage) Metadata() metadata.Metadata
Metadata return the message metadata
func (*DummyMessage) Payload ¶
func (d *DummyMessage) Payload() interface{}
Payload returns the payload of the message
func (*DummyMessage) UUID ¶
func (d *DummyMessage) UUID() goengine.UUID
UUID returns the identifier of this message
func (*DummyMessage) WithMetadata ¶
func (d *DummyMessage) WithMetadata(key string, value interface{}) goengine.Message
WithMetadata Returns new instance of the message with key and value added to metadata
type EventStore ¶
type EventStore struct {
// contains filtered or unexported fields
}
EventStore is a mock of EventStore interface
func NewEventStore ¶
func NewEventStore(ctrl *gomock.Controller) *EventStore
NewEventStore creates a new mock instance
func (*EventStore) AppendTo ¶
func (m *EventStore) AppendTo(arg0 context.Context, arg1 goengine.StreamName, arg2 []goengine.Message) error
AppendTo mocks base method
func (*EventStore) Create ¶
func (m *EventStore) Create(arg0 context.Context, arg1 goengine.StreamName) error
Create mocks base method
func (*EventStore) EXPECT ¶
func (m *EventStore) EXPECT() *EventStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*EventStore) HasStream ¶
func (m *EventStore) HasStream(arg0 context.Context, arg1 goengine.StreamName) bool
HasStream mocks base method
func (*EventStore) Load ¶
func (m *EventStore) Load(arg0 context.Context, arg1 goengine.StreamName, arg2 int64, arg3 *uint, arg4 metadata.Matcher) (goengine.EventStream, error)
Load mocks base method
type EventStoreMockRecorder ¶
type EventStoreMockRecorder struct {
// contains filtered or unexported fields
}
EventStoreMockRecorder is the mock recorder for EventStore
func (*EventStoreMockRecorder) AppendTo ¶
func (mr *EventStoreMockRecorder) AppendTo(arg0, arg1, arg2 interface{}) *gomock.Call
AppendTo indicates an expected call of AppendTo
func (*EventStoreMockRecorder) Create ¶
func (mr *EventStoreMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call
Create indicates an expected call of Create
func (*EventStoreMockRecorder) HasStream ¶
func (mr *EventStoreMockRecorder) HasStream(arg0, arg1 interface{}) *gomock.Call
HasStream indicates an expected call of HasStream
func (*EventStoreMockRecorder) Load ¶
func (mr *EventStoreMockRecorder) Load(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
Load indicates an expected call of Load
type EventStream ¶
type EventStream struct {
// contains filtered or unexported fields
}
EventStream is a mock of EventStream interface
func NewEventStream ¶
func NewEventStream(ctrl *gomock.Controller) *EventStream
NewEventStream creates a new mock instance
func (*EventStream) EXPECT ¶
func (m *EventStream) EXPECT() *EventStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type EventStreamMockRecorder ¶
type EventStreamMockRecorder struct {
// contains filtered or unexported fields
}
EventStreamMockRecorder is the mock recorder for EventStream
func (*EventStreamMockRecorder) Close ¶
func (mr *EventStreamMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*EventStreamMockRecorder) Err ¶
func (mr *EventStreamMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*EventStreamMockRecorder) Message ¶
func (mr *EventStreamMockRecorder) Message() *gomock.Call
Message indicates an expected call of Message
func (*EventStreamMockRecorder) Next ¶
func (mr *EventStreamMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message is a mock of Message interface
func NewMessage ¶
func NewMessage(ctrl *gomock.Controller) *Message
NewMessage creates a new mock instance
func (*Message) EXPECT ¶
func (m *Message) EXPECT() *MessageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MessageMockRecorder ¶
type MessageMockRecorder struct {
// contains filtered or unexported fields
}
MessageMockRecorder is the mock recorder for Message
func (*MessageMockRecorder) CreatedAt ¶
func (mr *MessageMockRecorder) CreatedAt() *gomock.Call
CreatedAt indicates an expected call of CreatedAt
func (*MessageMockRecorder) Metadata ¶
func (mr *MessageMockRecorder) Metadata() *gomock.Call
Metadata indicates an expected call of Metadata
func (*MessageMockRecorder) Payload ¶
func (mr *MessageMockRecorder) Payload() *gomock.Call
Payload indicates an expected call of Payload
func (*MessageMockRecorder) UUID ¶
func (mr *MessageMockRecorder) UUID() *gomock.Call
UUID indicates an expected call of UUID
func (*MessageMockRecorder) WithMetadata ¶
func (mr *MessageMockRecorder) WithMetadata(arg0, arg1 interface{}) *gomock.Call
WithMetadata indicates an expected call of WithMetadata
type MessagePayloadConverter ¶
type MessagePayloadConverter struct {
// contains filtered or unexported fields
}
MessagePayloadConverter is a mock of MessagePayloadConverter interface
func NewMessagePayloadConverter ¶
func NewMessagePayloadConverter(ctrl *gomock.Controller) *MessagePayloadConverter
NewMessagePayloadConverter creates a new mock instance
func (*MessagePayloadConverter) ConvertPayload ¶
func (m *MessagePayloadConverter) ConvertPayload(arg0 interface{}) (string, []byte, error)
ConvertPayload mocks base method
func (*MessagePayloadConverter) EXPECT ¶
func (m *MessagePayloadConverter) EXPECT() *MessagePayloadConverterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MessagePayloadConverterMockRecorder ¶
type MessagePayloadConverterMockRecorder struct {
// contains filtered or unexported fields
}
MessagePayloadConverterMockRecorder is the mock recorder for MessagePayloadConverter
func (*MessagePayloadConverterMockRecorder) ConvertPayload ¶
func (mr *MessagePayloadConverterMockRecorder) ConvertPayload(arg0 interface{}) *gomock.Call
ConvertPayload indicates an expected call of ConvertPayload
type MessagePayloadFactory ¶
type MessagePayloadFactory struct {
// contains filtered or unexported fields
}
MessagePayloadFactory is a mock of MessagePayloadFactory interface
func NewMessagePayloadFactory ¶
func NewMessagePayloadFactory(ctrl *gomock.Controller) *MessagePayloadFactory
NewMessagePayloadFactory creates a new mock instance
func (*MessagePayloadFactory) CreatePayload ¶
func (m *MessagePayloadFactory) CreatePayload(arg0 string, arg1 interface{}) (interface{}, error)
CreatePayload mocks base method
func (*MessagePayloadFactory) EXPECT ¶
func (m *MessagePayloadFactory) EXPECT() *MessagePayloadFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MessagePayloadFactoryMockRecorder ¶
type MessagePayloadFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MessagePayloadFactoryMockRecorder is the mock recorder for MessagePayloadFactory
func (*MessagePayloadFactoryMockRecorder) CreatePayload ¶
func (mr *MessagePayloadFactoryMockRecorder) CreatePayload(arg0, arg1 interface{}) *gomock.Call
CreatePayload indicates an expected call of CreatePayload
type MessagePayloadResolver ¶
type MessagePayloadResolver struct {
// contains filtered or unexported fields
}
MessagePayloadResolver is a mock of MessagePayloadResolver interface
func NewMessagePayloadResolver ¶
func NewMessagePayloadResolver(ctrl *gomock.Controller) *MessagePayloadResolver
NewMessagePayloadResolver creates a new mock instance
func (*MessagePayloadResolver) EXPECT ¶
func (m *MessagePayloadResolver) EXPECT() *MessagePayloadResolverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MessagePayloadResolver) ResolveName ¶
func (m *MessagePayloadResolver) ResolveName(arg0 interface{}) (string, error)
ResolveName mocks base method
type MessagePayloadResolverMockRecorder ¶
type MessagePayloadResolverMockRecorder struct {
// contains filtered or unexported fields
}
MessagePayloadResolverMockRecorder is the mock recorder for MessagePayloadResolver
func (*MessagePayloadResolverMockRecorder) ResolveName ¶
func (mr *MessagePayloadResolverMockRecorder) ResolveName(arg0 interface{}) *gomock.Call
ResolveName indicates an expected call of ResolveName
type Query ¶
type Query struct {
// contains filtered or unexported fields
}
Query is a mock of Query interface
func (*Query) EXPECT ¶
func (m *Query) EXPECT() *QueryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type QueryMockRecorder ¶
type QueryMockRecorder struct {
// contains filtered or unexported fields
}
QueryMockRecorder is the mock recorder for Query
func (*QueryMockRecorder) Handlers ¶
func (mr *QueryMockRecorder) Handlers() *gomock.Call
Handlers indicates an expected call of Handlers
func (*QueryMockRecorder) Init ¶
func (mr *QueryMockRecorder) Init(arg0 interface{}) *gomock.Call
Init indicates an expected call of Init
Source Files
Directories