neosync_benthos_sql

May 20, 2024

Changes in this version

+ func RegisterPooledSqlInsertOutput(env *service.Environment, dbprovider DbPoolProvider, isRetry bool) error

+ func RegisterPooledSqlRawInput(env *service.Environment, dbprovider DbPoolProvider, ...) error

+ func RegisterPooledSqlUpdateOutput(env *service.Environment, dbprovider DbPoolProvider) error

+ type DbPoolProvider interface

+ GetDb func(driver, dsn string) (SqlDbtx, error)

+ type MockSqlDbtx struct

+ func NewMockSqlDbtx(t interface{ ... }) *MockSqlDbtx

+ func (_m *MockSqlDbtx) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ func (_m *MockSqlDbtx) Close() error

+ func (_m *MockSqlDbtx) EXPECT() *MockSqlDbtx_Expecter

+ func (_m *MockSqlDbtx) ExecContext(_a0 context.Context, _a1 string, _a2 ...interface{}) (sql.Result, error)

+ func (_m *MockSqlDbtx) PrepareContext(_a0 context.Context, _a1 string) (*sql.Stmt, error)

+ func (_m *MockSqlDbtx) QueryContext(_a0 context.Context, _a1 string, _a2 ...interface{}) (*sql.Rows, error)

+ func (_m *MockSqlDbtx) QueryRowContext(_a0 context.Context, _a1 string, _a2 ...interface{}) *sql.Row

+ type MockSqlDbtx_BeginTx_Call struct

+ func (_c *MockSqlDbtx_BeginTx_Call) Return(_a0 *sql.Tx, _a1 error) *MockSqlDbtx_BeginTx_Call

+ func (_c *MockSqlDbtx_BeginTx_Call) Run(run func(ctx context.Context, opts *sql.TxOptions)) *MockSqlDbtx_BeginTx_Call

+ func (_c *MockSqlDbtx_BeginTx_Call) RunAndReturn(run func(context.Context, *sql.TxOptions) (*sql.Tx, error)) *MockSqlDbtx_BeginTx_Call

+ type MockSqlDbtx_Close_Call struct

+ func (_c *MockSqlDbtx_Close_Call) Return(_a0 error) *MockSqlDbtx_Close_Call

+ func (_c *MockSqlDbtx_Close_Call) Run(run func()) *MockSqlDbtx_Close_Call

+ func (_c *MockSqlDbtx_Close_Call) RunAndReturn(run func() error) *MockSqlDbtx_Close_Call

+ type MockSqlDbtx_ExecContext_Call struct

+ func (_c *MockSqlDbtx_ExecContext_Call) Return(_a0 sql.Result, _a1 error) *MockSqlDbtx_ExecContext_Call

+ func (_c *MockSqlDbtx_ExecContext_Call) Run(run func(_a0 context.Context, _a1 string, _a2 ...interface{})) *MockSqlDbtx_ExecContext_Call

+ func (_c *MockSqlDbtx_ExecContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (sql.Result, error)) *MockSqlDbtx_ExecContext_Call

+ type MockSqlDbtx_Expecter struct

+ func (_e *MockSqlDbtx_Expecter) BeginTx(ctx interface{}, opts interface{}) *MockSqlDbtx_BeginTx_Call

+ func (_e *MockSqlDbtx_Expecter) Close() *MockSqlDbtx_Close_Call

+ func (_e *MockSqlDbtx_Expecter) ExecContext(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MockSqlDbtx_ExecContext_Call

+ func (_e *MockSqlDbtx_Expecter) PrepareContext(_a0 interface{}, _a1 interface{}) *MockSqlDbtx_PrepareContext_Call

+ func (_e *MockSqlDbtx_Expecter) QueryContext(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MockSqlDbtx_QueryContext_Call

+ func (_e *MockSqlDbtx_Expecter) QueryRowContext(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MockSqlDbtx_QueryRowContext_Call

+ type MockSqlDbtx_PrepareContext_Call struct

+ func (_c *MockSqlDbtx_PrepareContext_Call) Return(_a0 *sql.Stmt, _a1 error) *MockSqlDbtx_PrepareContext_Call

+ func (_c *MockSqlDbtx_PrepareContext_Call) Run(run func(_a0 context.Context, _a1 string)) *MockSqlDbtx_PrepareContext_Call

+ func (_c *MockSqlDbtx_PrepareContext_Call) RunAndReturn(run func(context.Context, string) (*sql.Stmt, error)) *MockSqlDbtx_PrepareContext_Call

+ type MockSqlDbtx_QueryContext_Call struct

+ func (_c *MockSqlDbtx_QueryContext_Call) Return(_a0 *sql.Rows, _a1 error) *MockSqlDbtx_QueryContext_Call

+ func (_c *MockSqlDbtx_QueryContext_Call) Run(run func(_a0 context.Context, _a1 string, _a2 ...interface{})) *MockSqlDbtx_QueryContext_Call

+ func (_c *MockSqlDbtx_QueryContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (*sql.Rows, error)) *MockSqlDbtx_QueryContext_Call

+ type MockSqlDbtx_QueryRowContext_Call struct

+ func (_c *MockSqlDbtx_QueryRowContext_Call) Return(_a0 *sql.Row) *MockSqlDbtx_QueryRowContext_Call

+ func (_c *MockSqlDbtx_QueryRowContext_Call) Run(run func(_a0 context.Context, _a1 string, _a2 ...interface{})) *MockSqlDbtx_QueryRowContext_Call

+ func (_c *MockSqlDbtx_QueryRowContext_Call) RunAndReturn(run func(context.Context, string, ...interface{}) *sql.Row) *MockSqlDbtx_QueryRowContext_Call

+ type SqlDbtx interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ Close func() error