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 Execer struct + func NewExecer(ctrl *gomock.Controller) *Execer + func (m *Execer) EXPECT() *ExecerMockRecorder + func (m *Execer) ExecContext(arg0 context.Context, arg1 string, arg2 ...interface{}) (sql.Result, error) + type ExecerMockRecorder struct + func (mr *ExecerMockRecorder) ExecContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + type MessageFactory struct + func NewMessageFactory(ctrl *gomock.Controller) *MessageFactory + func (m *MessageFactory) CreateEventStream(arg0 *sql.Rows) (goengine.EventStream, error) + func (m *MessageFactory) EXPECT() *MessageFactoryMockRecorder + type MessageFactoryMockRecorder struct + func (mr *MessageFactoryMockRecorder) CreateEventStream(arg0 interface{}) *gomock.Call + type NotificationQueuer struct + func NewNotificationQueuer(ctrl *gomock.Controller) *NotificationQueuer + func (m *NotificationQueuer) EXPECT() *NotificationQueuerMockRecorder + func (m *NotificationQueuer) Empty() bool + func (m *NotificationQueuer) Next(arg0 context.Context) (*sql.ProjectionNotification, bool) + func (m *NotificationQueuer) Open() func() + func (m *NotificationQueuer) Queue(arg0 context.Context, arg1 *sql.ProjectionNotification) error + func (m *NotificationQueuer) ReQueue(arg0 context.Context, arg1 *sql.ProjectionNotification) error + type NotificationQueuerMockRecorder struct + func (mr *NotificationQueuerMockRecorder) Empty() *gomock.Call + func (mr *NotificationQueuerMockRecorder) Next(arg0 interface{}) *gomock.Call + func (mr *NotificationQueuerMockRecorder) Open() *gomock.Call + func (mr *NotificationQueuerMockRecorder) Queue(arg0, arg1 interface{}) *gomock.Call + func (mr *NotificationQueuerMockRecorder) ReQueue(arg0, arg1 interface{}) *gomock.Call + type PersistenceStrategy struct + func NewPersistenceStrategy(ctrl *gomock.Controller) *PersistenceStrategy + func (m *PersistenceStrategy) CreateSchema(arg0 string) []string + func (m *PersistenceStrategy) EXPECT() *PersistenceStrategyMockRecorder + func (m *PersistenceStrategy) EventColumnNames() []string + func (m *PersistenceStrategy) GenerateTableName(arg0 goengine.StreamName) (string, error) + func (m *PersistenceStrategy) InsertColumnNames() []string + func (m *PersistenceStrategy) PrepareData(arg0 []goengine.Message) ([]interface{}, error) + func (m *PersistenceStrategy) PrepareSearch(arg0 metadata.Matcher) ([]byte, []interface{}) + type PersistenceStrategyMockRecorder struct + func (mr *PersistenceStrategyMockRecorder) CreateSchema(arg0 interface{}) *gomock.Call + func (mr *PersistenceStrategyMockRecorder) EventColumnNames() *gomock.Call + func (mr *PersistenceStrategyMockRecorder) GenerateTableName(arg0 interface{}) *gomock.Call + func (mr *PersistenceStrategyMockRecorder) InsertColumnNames() *gomock.Call + func (mr *PersistenceStrategyMockRecorder) PrepareData(arg0 interface{}) *gomock.Call + func (mr *PersistenceStrategyMockRecorder) PrepareSearch(arg0 interface{}) *gomock.Call + type ProjectionStateSerialization struct + func NewProjectionStateSerialization(ctrl *gomock.Controller) *ProjectionStateSerialization + func (m *ProjectionStateSerialization) DecodeState(arg0 []byte) (interface{}, error) + func (m *ProjectionStateSerialization) EXPECT() *ProjectionStateSerializationMockRecorder + func (m *ProjectionStateSerialization) EncodeState(arg0 interface{}) ([]byte, error) + func (m *ProjectionStateSerialization) Init(arg0 context.Context) (interface{}, error) + type ProjectionStateSerializationMockRecorder struct + func (mr *ProjectionStateSerializationMockRecorder) DecodeState(arg0 interface{}) *gomock.Call + func (mr *ProjectionStateSerializationMockRecorder) EncodeState(arg0 interface{}) *gomock.Call + func (mr *ProjectionStateSerializationMockRecorder) Init(arg0 interface{}) *gomock.Call + type Queryer struct + func NewQueryer(ctrl *gomock.Controller) *Queryer + func (m *Queryer) EXPECT() *QueryerMockRecorder + func (m *Queryer) QueryContext(arg0 context.Context, arg1 string, arg2 ...interface{}) (*sql.Rows, error) + type QueryerMockRecorder struct + func (mr *QueryerMockRecorder) QueryContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call Other modules containing this package github.com/hellofresh/goengine
Go to main page