sql

package
v2.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package sql is a generated GoMock package.

Package sql is a generated GoMock package.

Package sql is a generated GoMock package.

Package sql is a generated GoMock package.

Package sql is a generated GoMock package.

Package sql is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Execer 

type Execer struct {
	// contains filtered or unexported fields
}

Execer is a mock of Execer interface.

func NewExecer 

func NewExecer(ctrl *gomock.Controller) *Execer

NewExecer creates a new mock instance.

func (*Execer) EXPECT 

func (m *Execer) EXPECT() *ExecerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Execer) ExecContext 

func (m *Execer) ExecContext(arg0 context.Context, arg1 string, arg2 ...interface{}) (sql.Result, error)

ExecContext mocks base method.

type ExecerMockRecorder 

type ExecerMockRecorder struct {
	// contains filtered or unexported fields
}

ExecerMockRecorder is the mock recorder for Execer.

func (*ExecerMockRecorder) ExecContext 

func (mr *ExecerMockRecorder) ExecContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ExecContext indicates an expected call of ExecContext.

type MessageFactory 

type MessageFactory struct {
	// contains filtered or unexported fields
}

MessageFactory is a mock of MessageFactory interface.

func NewMessageFactory 

func NewMessageFactory(ctrl *gomock.Controller) *MessageFactory

NewMessageFactory creates a new mock instance.

func (*MessageFactory) CreateEventStream 

func (m *MessageFactory) CreateEventStream(arg0 *sql.Rows) (goengine.EventStream, error)

CreateEventStream mocks base method.

func (*MessageFactory) EXPECT 

func (m *MessageFactory) EXPECT() *MessageFactoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MessageFactoryMockRecorder 

type MessageFactoryMockRecorder struct {
	// contains filtered or unexported fields
}

MessageFactoryMockRecorder is the mock recorder for MessageFactory.

func (*MessageFactoryMockRecorder) CreateEventStream 

func (mr *MessageFactoryMockRecorder) CreateEventStream(arg0 interface{}) *gomock.Call

CreateEventStream indicates an expected call of CreateEventStream.

type NotificationQueuer 

type NotificationQueuer struct {
	// contains filtered or unexported fields
}

NotificationQueuer is a mock of NotificationQueuer interface.

func NewNotificationQueuer 

func NewNotificationQueuer(ctrl *gomock.Controller) *NotificationQueuer

NewNotificationQueuer creates a new mock instance.

func (*NotificationQueuer) EXPECT 

func (m *NotificationQueuer) EXPECT() *NotificationQueuerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*NotificationQueuer) Empty 

func (m *NotificationQueuer) Empty() bool

Empty mocks base method.

func (*NotificationQueuer) Next 

func (m *NotificationQueuer) Next(arg0 context.Context) (*sql.ProjectionNotification, bool)

Next mocks base method.

func (*NotificationQueuer) Open 

func (m *NotificationQueuer) Open() func()

Open mocks base method.

func (*NotificationQueuer) Queue 

func (m *NotificationQueuer) Queue(arg0 context.Context, arg1 *sql.ProjectionNotification) error

Queue mocks base method.

func (*NotificationQueuer) ReQueue 

func (m *NotificationQueuer) ReQueue(arg0 context.Context, arg1 *sql.ProjectionNotification) error

ReQueue mocks base method.

type NotificationQueuerMockRecorder 

type NotificationQueuerMockRecorder struct {
	// contains filtered or unexported fields
}

NotificationQueuerMockRecorder is the mock recorder for NotificationQueuer.

func (*NotificationQueuerMockRecorder) Empty 

func (mr *NotificationQueuerMockRecorder) Empty() *gomock.Call

Empty indicates an expected call of Empty.

func (*NotificationQueuerMockRecorder) Next 

func (mr *NotificationQueuerMockRecorder) Next(arg0 interface{}) *gomock.Call

Next indicates an expected call of Next.

func (*NotificationQueuerMockRecorder) Open 

func (mr *NotificationQueuerMockRecorder) Open() *gomock.Call

Open indicates an expected call of Open.

func (*NotificationQueuerMockRecorder) Queue 

func (mr *NotificationQueuerMockRecorder) Queue(arg0, arg1 interface{}) *gomock.Call

Queue indicates an expected call of Queue.

func (*NotificationQueuerMockRecorder) ReQueue 

func (mr *NotificationQueuerMockRecorder) ReQueue(arg0, arg1 interface{}) *gomock.Call

ReQueue indicates an expected call of ReQueue.

type PersistenceStrategy 

type PersistenceStrategy struct {
	// contains filtered or unexported fields
}

PersistenceStrategy is a mock of PersistenceStrategy interface.

func NewPersistenceStrategy 

func NewPersistenceStrategy(ctrl *gomock.Controller) *PersistenceStrategy

NewPersistenceStrategy creates a new mock instance.

func (*PersistenceStrategy) CreateSchema 

func (m *PersistenceStrategy) CreateSchema(arg0 string) []string

CreateSchema mocks base method.

func (*PersistenceStrategy) EXPECT 

func (m *PersistenceStrategy) EXPECT() *PersistenceStrategyMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*PersistenceStrategy) EventColumnNames 

func (m *PersistenceStrategy) EventColumnNames() []string

EventColumnNames mocks base method.

func (*PersistenceStrategy) GenerateTableName 

func (m *PersistenceStrategy) GenerateTableName(arg0 goengine.StreamName) (string, error)

GenerateTableName mocks base method.

func (*PersistenceStrategy) InsertColumnNames 

func (m *PersistenceStrategy) InsertColumnNames() []string

InsertColumnNames mocks base method.

func (*PersistenceStrategy) PrepareData 

func (m *PersistenceStrategy) PrepareData(arg0 []goengine.Message) ([]interface{}, error)

PrepareData mocks base method.

func (*PersistenceStrategy) PrepareSearch 

func (m *PersistenceStrategy) PrepareSearch(arg0 metadata.Matcher) ([]byte, []interface{})

PrepareSearch mocks base method.

type PersistenceStrategyMockRecorder 

type PersistenceStrategyMockRecorder struct {
	// contains filtered or unexported fields
}

PersistenceStrategyMockRecorder is the mock recorder for PersistenceStrategy.

func (*PersistenceStrategyMockRecorder) CreateSchema 

func (mr *PersistenceStrategyMockRecorder) CreateSchema(arg0 interface{}) *gomock.Call

CreateSchema indicates an expected call of CreateSchema.

func (*PersistenceStrategyMockRecorder) EventColumnNames 

func (mr *PersistenceStrategyMockRecorder) EventColumnNames() *gomock.Call

EventColumnNames indicates an expected call of EventColumnNames.

func (*PersistenceStrategyMockRecorder) GenerateTableName 

func (mr *PersistenceStrategyMockRecorder) GenerateTableName(arg0 interface{}) *gomock.Call

GenerateTableName indicates an expected call of GenerateTableName.

func (*PersistenceStrategyMockRecorder) InsertColumnNames 

func (mr *PersistenceStrategyMockRecorder) InsertColumnNames() *gomock.Call

InsertColumnNames indicates an expected call of InsertColumnNames.

func (*PersistenceStrategyMockRecorder) PrepareData 

func (mr *PersistenceStrategyMockRecorder) PrepareData(arg0 interface{}) *gomock.Call

PrepareData indicates an expected call of PrepareData.

func (*PersistenceStrategyMockRecorder) PrepareSearch 

func (mr *PersistenceStrategyMockRecorder) PrepareSearch(arg0 interface{}) *gomock.Call

PrepareSearch indicates an expected call of PrepareSearch.

type ProjectionStateSerialization 

type ProjectionStateSerialization struct {
	// contains filtered or unexported fields
}

ProjectionStateSerialization is a mock of ProjectionStateSerialization interface.

func NewProjectionStateSerialization 

func NewProjectionStateSerialization(ctrl *gomock.Controller) *ProjectionStateSerialization

NewProjectionStateSerialization creates a new mock instance.

func (*ProjectionStateSerialization) DecodeState 

func (m *ProjectionStateSerialization) DecodeState(arg0 []byte) (interface{}, error)

DecodeState mocks base method.

func (*ProjectionStateSerialization) EXPECT 

func (m *ProjectionStateSerialization) EXPECT() *ProjectionStateSerializationMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*ProjectionStateSerialization) EncodeState 

func (m *ProjectionStateSerialization) EncodeState(arg0 interface{}) ([]byte, error)

EncodeState mocks base method.

func (*ProjectionStateSerialization) Init 

func (m *ProjectionStateSerialization) Init(arg0 context.Context) (interface{}, error)

Init mocks base method.

type ProjectionStateSerializationMockRecorder 

type ProjectionStateSerializationMockRecorder struct {
	// contains filtered or unexported fields
}

ProjectionStateSerializationMockRecorder is the mock recorder for ProjectionStateSerialization.

func (*ProjectionStateSerializationMockRecorder) DecodeState 

func (mr *ProjectionStateSerializationMockRecorder) DecodeState(arg0 interface{}) *gomock.Call

DecodeState indicates an expected call of DecodeState.

func (*ProjectionStateSerializationMockRecorder) EncodeState 

func (mr *ProjectionStateSerializationMockRecorder) EncodeState(arg0 interface{}) *gomock.Call

EncodeState indicates an expected call of EncodeState.

func (*ProjectionStateSerializationMockRecorder) Init 

func (mr *ProjectionStateSerializationMockRecorder) Init(arg0 interface{}) *gomock.Call

Init indicates an expected call of Init.

type Queryer 

type Queryer struct {
	// contains filtered or unexported fields
}

Queryer is a mock of Queryer interface.

func NewQueryer 

func NewQueryer(ctrl *gomock.Controller) *Queryer

NewQueryer creates a new mock instance.

func (*Queryer) EXPECT 

func (m *Queryer) EXPECT() *QueryerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Queryer) QueryContext 

func (m *Queryer) QueryContext(arg0 context.Context, arg1 string, arg2 ...interface{}) (*sql.Rows, error)

QueryContext mocks base method.

type QueryerMockRecorder 

type QueryerMockRecorder struct {
	// contains filtered or unexported fields
}

QueryerMockRecorder is the mock recorder for Queryer.

func (*QueryerMockRecorder) QueryContext 

func (mr *QueryerMockRecorder) QueryContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryContext indicates an expected call of QueryContext.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.