sql

package

Go to main page

Versions in this module

v0

v0.11.0

Aug 25, 2021

v0.10.0

Sep 4, 2019

Changes in this version

type NotificationQueuer

+ func (m *NotificationQueuer) Close()

type NotificationQueuerMockRecorder

+ func (mr *NotificationQueuerMockRecorder) Close() *gomock.Call

v0.9.0

Mar 1, 2019

Changes in this version

type PersistenceStrategy

+ func (m *PersistenceStrategy) ColumnNames() []string

type PersistenceStrategyMockRecorder

+ func (mr *PersistenceStrategyMockRecorder) ColumnNames() *gomock.Call

v0.3.5

Aug 26, 2020

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/v2

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