Documentation ¶
Index ¶
- type DBPool
- type DBPool_Exec_Call
- func (_c *DBPool_Exec_Call) Return(_a0 pgconn.CommandTag, _a1 error) *DBPool_Exec_Call
- func (_c *DBPool_Exec_Call) Run(run func(ctx context.Context, sql string, arguments ...interface{})) *DBPool_Exec_Call
- func (_c *DBPool_Exec_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)) *DBPool_Exec_Call
- type DBPool_Expecter
- type DBPool_QueryRow_Call
- func (_c *DBPool_QueryRow_Call) Return(_a0 pgx.Row) *DBPool_QueryRow_Call
- func (_c *DBPool_QueryRow_Call) Run(run func(ctx context.Context, sql string, args ...interface{})) *DBPool_QueryRow_Call
- func (_c *DBPool_QueryRow_Call) RunAndReturn(run func(context.Context, string, ...interface{}) pgx.Row) *DBPool_QueryRow_Call
- type KafkaClient
- type KafkaClient_Close_Call
- type KafkaClient_Expecter
- type KafkaClient_Flush_Call
- type KafkaClient_Produce_Call
- func (_c *KafkaClient_Produce_Call) Return() *KafkaClient_Produce_Call
- func (_c *KafkaClient_Produce_Call) Run(run func(ctx context.Context, r *kgo.Record, promise func(*kgo.Record, error))) *KafkaClient_Produce_Call
- func (_c *KafkaClient_Produce_Call) RunAndReturn(run func(context.Context, *kgo.Record, func(*kgo.Record, error))) *KafkaClient_Produce_Call
- type RPCClient
- func (_m *RPCClient) ABCIQuery(ctx context.Context, path string, data bytes.HexBytes) (*coretypes.ResultABCIQuery, error)
- func (_m *RPCClient) Block(ctx context.Context, height *int64) (*coretypes.ResultBlock, error)
- func (_m *RPCClient) BlockResults(ctx context.Context, height *int64) (*coretypes.ResultBlockResults, error)
- func (_m *RPCClient) EXPECT() *RPCClient_Expecter
- func (_m *RPCClient) Header(ctx context.Context, height *int64) (*coretypes.ResultHeader, error)
- func (_m *RPCClient) Status(ctx context.Context) (*coretypes.ResultStatus, error)
- type RPCClient_ABCIQuery_Call
- func (_c *RPCClient_ABCIQuery_Call) Return(_a0 *coretypes.ResultABCIQuery, _a1 error) *RPCClient_ABCIQuery_Call
- func (_c *RPCClient_ABCIQuery_Call) Run(run func(ctx context.Context, path string, data bytes.HexBytes)) *RPCClient_ABCIQuery_Call
- func (_c *RPCClient_ABCIQuery_Call) RunAndReturn(...) *RPCClient_ABCIQuery_Call
- type RPCClient_BlockResults_Call
- func (_c *RPCClient_BlockResults_Call) Return(_a0 *coretypes.ResultBlockResults, _a1 error) *RPCClient_BlockResults_Call
- func (_c *RPCClient_BlockResults_Call) Run(run func(ctx context.Context, height *int64)) *RPCClient_BlockResults_Call
- func (_c *RPCClient_BlockResults_Call) RunAndReturn(run func(context.Context, *int64) (*coretypes.ResultBlockResults, error)) *RPCClient_BlockResults_Call
- type RPCClient_Block_Call
- func (_c *RPCClient_Block_Call) Return(_a0 *coretypes.ResultBlock, _a1 error) *RPCClient_Block_Call
- func (_c *RPCClient_Block_Call) Run(run func(ctx context.Context, height *int64)) *RPCClient_Block_Call
- func (_c *RPCClient_Block_Call) RunAndReturn(run func(context.Context, *int64) (*coretypes.ResultBlock, error)) *RPCClient_Block_Call
- type RPCClient_Expecter
- func (_e *RPCClient_Expecter) ABCIQuery(ctx interface{}, path interface{}, data interface{}) *RPCClient_ABCIQuery_Call
- func (_e *RPCClient_Expecter) Block(ctx interface{}, height interface{}) *RPCClient_Block_Call
- func (_e *RPCClient_Expecter) BlockResults(ctx interface{}, height interface{}) *RPCClient_BlockResults_Call
- func (_e *RPCClient_Expecter) Header(ctx interface{}, height interface{}) *RPCClient_Header_Call
- func (_e *RPCClient_Expecter) Status(ctx interface{}) *RPCClient_Status_Call
- type RPCClient_Header_Call
- func (_c *RPCClient_Header_Call) Return(_a0 *coretypes.ResultHeader, _a1 error) *RPCClient_Header_Call
- func (_c *RPCClient_Header_Call) Run(run func(ctx context.Context, height *int64)) *RPCClient_Header_Call
- func (_c *RPCClient_Header_Call) RunAndReturn(run func(context.Context, *int64) (*coretypes.ResultHeader, error)) *RPCClient_Header_Call
- type RPCClient_Status_Call
- func (_c *RPCClient_Status_Call) Return(_a0 *coretypes.ResultStatus, _a1 error) *RPCClient_Status_Call
- func (_c *RPCClient_Status_Call) Run(run func(ctx context.Context)) *RPCClient_Status_Call
- func (_c *RPCClient_Status_Call) RunAndReturn(run func(context.Context) (*coretypes.ResultStatus, error)) *RPCClient_Status_Call
- type RowInterface
- type RowInterface_Expecter
- type RowInterface_Scan_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBPool ¶
DBPool is an autogenerated mock type for the DBPool type
func NewDBPool ¶
NewDBPool creates a new instance of DBPool. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DBPool) EXPECT ¶
func (_m *DBPool) EXPECT() *DBPool_Expecter
type DBPool_Exec_Call ¶
DBPool_Exec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Exec'
func (*DBPool_Exec_Call) Return ¶
func (_c *DBPool_Exec_Call) Return(_a0 pgconn.CommandTag, _a1 error) *DBPool_Exec_Call
func (*DBPool_Exec_Call) Run ¶
func (_c *DBPool_Exec_Call) Run(run func(ctx context.Context, sql string, arguments ...interface{})) *DBPool_Exec_Call
func (*DBPool_Exec_Call) RunAndReturn ¶
func (_c *DBPool_Exec_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)) *DBPool_Exec_Call
type DBPool_Expecter ¶
type DBPool_Expecter struct {
// contains filtered or unexported fields
}
func (*DBPool_Expecter) Exec ¶
func (_e *DBPool_Expecter) Exec(ctx interface{}, sql interface{}, arguments ...interface{}) *DBPool_Exec_Call
Exec is a helper method to define mock.On call
- ctx context.Context
- sql string
- arguments ...interface{}
func (*DBPool_Expecter) QueryRow ¶
func (_e *DBPool_Expecter) QueryRow(ctx interface{}, sql interface{}, args ...interface{}) *DBPool_QueryRow_Call
QueryRow is a helper method to define mock.On call
- ctx context.Context
- sql string
- args ...interface{}
type DBPool_QueryRow_Call ¶
DBPool_QueryRow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryRow'
func (*DBPool_QueryRow_Call) Return ¶
func (_c *DBPool_QueryRow_Call) Return(_a0 pgx.Row) *DBPool_QueryRow_Call
func (*DBPool_QueryRow_Call) Run ¶
func (_c *DBPool_QueryRow_Call) Run(run func(ctx context.Context, sql string, args ...interface{})) *DBPool_QueryRow_Call
func (*DBPool_QueryRow_Call) RunAndReturn ¶
func (_c *DBPool_QueryRow_Call) RunAndReturn(run func(context.Context, string, ...interface{}) pgx.Row) *DBPool_QueryRow_Call
type KafkaClient ¶
KafkaClient is an autogenerated mock type for the KafkaClient type
func NewKafkaClient ¶
func NewKafkaClient(t interface { mock.TestingT Cleanup(func()) }) *KafkaClient
NewKafkaClient creates a new instance of KafkaClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*KafkaClient) Close ¶
func (_m *KafkaClient) Close()
Close provides a mock function with given fields:
func (*KafkaClient) EXPECT ¶
func (_m *KafkaClient) EXPECT() *KafkaClient_Expecter
type KafkaClient_Close_Call ¶
KafkaClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*KafkaClient_Close_Call) Return ¶
func (_c *KafkaClient_Close_Call) Return() *KafkaClient_Close_Call
func (*KafkaClient_Close_Call) Run ¶
func (_c *KafkaClient_Close_Call) Run(run func()) *KafkaClient_Close_Call
func (*KafkaClient_Close_Call) RunAndReturn ¶
func (_c *KafkaClient_Close_Call) RunAndReturn(run func()) *KafkaClient_Close_Call
type KafkaClient_Expecter ¶
type KafkaClient_Expecter struct {
// contains filtered or unexported fields
}
func (*KafkaClient_Expecter) Close ¶
func (_e *KafkaClient_Expecter) Close() *KafkaClient_Close_Call
Close is a helper method to define mock.On call
func (*KafkaClient_Expecter) Flush ¶
func (_e *KafkaClient_Expecter) Flush(ctx interface{}) *KafkaClient_Flush_Call
Flush is a helper method to define mock.On call
- ctx context.Context
func (*KafkaClient_Expecter) Produce ¶
func (_e *KafkaClient_Expecter) Produce(ctx interface{}, r interface{}, promise interface{}) *KafkaClient_Produce_Call
Produce is a helper method to define mock.On call
- ctx context.Context
- r *kgo.Record
- promise func(*kgo.Record , error)
type KafkaClient_Flush_Call ¶
KafkaClient_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'
func (*KafkaClient_Flush_Call) Return ¶
func (_c *KafkaClient_Flush_Call) Return(_a0 error) *KafkaClient_Flush_Call
func (*KafkaClient_Flush_Call) Run ¶
func (_c *KafkaClient_Flush_Call) Run(run func(ctx context.Context)) *KafkaClient_Flush_Call
func (*KafkaClient_Flush_Call) RunAndReturn ¶
func (_c *KafkaClient_Flush_Call) RunAndReturn(run func(context.Context) error) *KafkaClient_Flush_Call
type KafkaClient_Produce_Call ¶
KafkaClient_Produce_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Produce'
func (*KafkaClient_Produce_Call) Return ¶
func (_c *KafkaClient_Produce_Call) Return() *KafkaClient_Produce_Call
func (*KafkaClient_Produce_Call) Run ¶
func (_c *KafkaClient_Produce_Call) Run(run func(ctx context.Context, r *kgo.Record, promise func(*kgo.Record, error))) *KafkaClient_Produce_Call
func (*KafkaClient_Produce_Call) RunAndReturn ¶
func (_c *KafkaClient_Produce_Call) RunAndReturn(run func(context.Context, *kgo.Record, func(*kgo.Record, error))) *KafkaClient_Produce_Call
type RPCClient ¶
RPCClient is an autogenerated mock type for the RPCClient type
func NewRPCClient ¶
NewRPCClient creates a new instance of RPCClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*RPCClient) ABCIQuery ¶ added in v0.1.10
func (_m *RPCClient) ABCIQuery(ctx context.Context, path string, data bytes.HexBytes) (*coretypes.ResultABCIQuery, error)
ABCIQuery provides a mock function with given fields: ctx, path, data
func (*RPCClient) BlockResults ¶
func (_m *RPCClient) BlockResults(ctx context.Context, height *int64) (*coretypes.ResultBlockResults, error)
BlockResults provides a mock function with given fields: ctx, height
func (*RPCClient) EXPECT ¶
func (_m *RPCClient) EXPECT() *RPCClient_Expecter
type RPCClient_ABCIQuery_Call ¶ added in v0.1.10
RPCClient_ABCIQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ABCIQuery'
func (*RPCClient_ABCIQuery_Call) Return ¶ added in v0.1.10
func (_c *RPCClient_ABCIQuery_Call) Return(_a0 *coretypes.ResultABCIQuery, _a1 error) *RPCClient_ABCIQuery_Call
func (*RPCClient_ABCIQuery_Call) Run ¶ added in v0.1.10
func (_c *RPCClient_ABCIQuery_Call) Run(run func(ctx context.Context, path string, data bytes.HexBytes)) *RPCClient_ABCIQuery_Call
func (*RPCClient_ABCIQuery_Call) RunAndReturn ¶ added in v0.1.10
func (_c *RPCClient_ABCIQuery_Call) RunAndReturn(run func(context.Context, string, bytes.HexBytes) (*coretypes.ResultABCIQuery, error)) *RPCClient_ABCIQuery_Call
type RPCClient_BlockResults_Call ¶
RPCClient_BlockResults_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BlockResults'
func (*RPCClient_BlockResults_Call) Return ¶
func (_c *RPCClient_BlockResults_Call) Return(_a0 *coretypes.ResultBlockResults, _a1 error) *RPCClient_BlockResults_Call
func (*RPCClient_BlockResults_Call) Run ¶
func (_c *RPCClient_BlockResults_Call) Run(run func(ctx context.Context, height *int64)) *RPCClient_BlockResults_Call
func (*RPCClient_BlockResults_Call) RunAndReturn ¶
func (_c *RPCClient_BlockResults_Call) RunAndReturn(run func(context.Context, *int64) (*coretypes.ResultBlockResults, error)) *RPCClient_BlockResults_Call
type RPCClient_Block_Call ¶
RPCClient_Block_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Block'
func (*RPCClient_Block_Call) Return ¶
func (_c *RPCClient_Block_Call) Return(_a0 *coretypes.ResultBlock, _a1 error) *RPCClient_Block_Call
func (*RPCClient_Block_Call) Run ¶
func (_c *RPCClient_Block_Call) Run(run func(ctx context.Context, height *int64)) *RPCClient_Block_Call
func (*RPCClient_Block_Call) RunAndReturn ¶
func (_c *RPCClient_Block_Call) RunAndReturn(run func(context.Context, *int64) (*coretypes.ResultBlock, error)) *RPCClient_Block_Call
type RPCClient_Expecter ¶
type RPCClient_Expecter struct {
// contains filtered or unexported fields
}
func (*RPCClient_Expecter) ABCIQuery ¶ added in v0.1.10
func (_e *RPCClient_Expecter) ABCIQuery(ctx interface{}, path interface{}, data interface{}) *RPCClient_ABCIQuery_Call
ABCIQuery is a helper method to define mock.On call
- ctx context.Context
- path string
- data bytes.HexBytes
func (*RPCClient_Expecter) Block ¶
func (_e *RPCClient_Expecter) Block(ctx interface{}, height interface{}) *RPCClient_Block_Call
Block is a helper method to define mock.On call
- ctx context.Context
- height *int64
func (*RPCClient_Expecter) BlockResults ¶
func (_e *RPCClient_Expecter) BlockResults(ctx interface{}, height interface{}) *RPCClient_BlockResults_Call
BlockResults is a helper method to define mock.On call
- ctx context.Context
- height *int64
func (*RPCClient_Expecter) Header ¶
func (_e *RPCClient_Expecter) Header(ctx interface{}, height interface{}) *RPCClient_Header_Call
Header is a helper method to define mock.On call
- ctx context.Context
- height *int64
func (*RPCClient_Expecter) Status ¶
func (_e *RPCClient_Expecter) Status(ctx interface{}) *RPCClient_Status_Call
Status is a helper method to define mock.On call
- ctx context.Context
type RPCClient_Header_Call ¶
RPCClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'
func (*RPCClient_Header_Call) Return ¶
func (_c *RPCClient_Header_Call) Return(_a0 *coretypes.ResultHeader, _a1 error) *RPCClient_Header_Call
func (*RPCClient_Header_Call) Run ¶
func (_c *RPCClient_Header_Call) Run(run func(ctx context.Context, height *int64)) *RPCClient_Header_Call
func (*RPCClient_Header_Call) RunAndReturn ¶
func (_c *RPCClient_Header_Call) RunAndReturn(run func(context.Context, *int64) (*coretypes.ResultHeader, error)) *RPCClient_Header_Call
type RPCClient_Status_Call ¶
RPCClient_Status_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Status'
func (*RPCClient_Status_Call) Return ¶
func (_c *RPCClient_Status_Call) Return(_a0 *coretypes.ResultStatus, _a1 error) *RPCClient_Status_Call
func (*RPCClient_Status_Call) Run ¶
func (_c *RPCClient_Status_Call) Run(run func(ctx context.Context)) *RPCClient_Status_Call
func (*RPCClient_Status_Call) RunAndReturn ¶
func (_c *RPCClient_Status_Call) RunAndReturn(run func(context.Context) (*coretypes.ResultStatus, error)) *RPCClient_Status_Call
type RowInterface ¶
RowInterface is an autogenerated mock type for the RowInterface type
func NewRowInterface ¶
func NewRowInterface(t interface { mock.TestingT Cleanup(func()) }) *RowInterface
NewRowInterface creates a new instance of RowInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*RowInterface) EXPECT ¶
func (_m *RowInterface) EXPECT() *RowInterface_Expecter
func (*RowInterface) Scan ¶
func (_m *RowInterface) Scan(dest ...interface{}) error
Scan provides a mock function with given fields: dest
type RowInterface_Expecter ¶
type RowInterface_Expecter struct {
// contains filtered or unexported fields
}
func (*RowInterface_Expecter) Scan ¶
func (_e *RowInterface_Expecter) Scan(dest ...interface{}) *RowInterface_Scan_Call
Scan is a helper method to define mock.On call
- dest ...interface{}
type RowInterface_Scan_Call ¶
RowInterface_Scan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Scan'
func (*RowInterface_Scan_Call) Return ¶
func (_c *RowInterface_Scan_Call) Return(_a0 error) *RowInterface_Scan_Call
func (*RowInterface_Scan_Call) Run ¶
func (_c *RowInterface_Scan_Call) Run(run func(dest ...interface{})) *RowInterface_Scan_Call
func (*RowInterface_Scan_Call) RunAndReturn ¶
func (_c *RowInterface_Scan_Call) RunAndReturn(run func(...interface{}) error) *RowInterface_Scan_Call