Documentation ¶
Index ¶
- type DynamoDBAPI
- func (_m *DynamoDBAPI) CreateTable(ctx context.Context, params *dynamodb.CreateTableInput, ...) (*dynamodb.CreateTableOutput, error)
- func (_m *DynamoDBAPI) DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, ...) (*dynamodb.DeleteItemOutput, error)
- func (_m *DynamoDBAPI) DeleteTable(ctx context.Context, params *dynamodb.DeleteTableInput, ...) (*dynamodb.DeleteTableOutput, error)
- func (_m *DynamoDBAPI) DescribeTable(ctx context.Context, params *dynamodb.DescribeTableInput, ...) (*dynamodb.DescribeTableOutput, error)
- func (_m *DynamoDBAPI) EXPECT() *DynamoDBAPI_Expecter
- func (_m *DynamoDBAPI) GetItem(ctx context.Context, params *dynamodb.GetItemInput, ...) (*dynamodb.GetItemOutput, error)
- func (_m *DynamoDBAPI) PutItem(ctx context.Context, params *dynamodb.PutItemInput, ...) (*dynamodb.PutItemOutput, error)
- func (_m *DynamoDBAPI) Query(ctx context.Context, params *dynamodb.QueryInput, ...) (*dynamodb.QueryOutput, error)
- func (_m *DynamoDBAPI) Scan(ctx context.Context, params *dynamodb.ScanInput, ...) (*dynamodb.ScanOutput, error)
- func (_m *DynamoDBAPI) UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, ...) (*dynamodb.UpdateItemOutput, error)
- type DynamoDBAPI_CreateTable_Call
- func (_c *DynamoDBAPI_CreateTable_Call) Return(_a0 *dynamodb.CreateTableOutput, _a1 error) *DynamoDBAPI_CreateTable_Call
- func (_c *DynamoDBAPI_CreateTable_Call) Run(run func(ctx context.Context, params *dynamodb.CreateTableInput, ...)) *DynamoDBAPI_CreateTable_Call
- func (_c *DynamoDBAPI_CreateTable_Call) RunAndReturn(...) *DynamoDBAPI_CreateTable_Call
- type DynamoDBAPI_DeleteItem_Call
- func (_c *DynamoDBAPI_DeleteItem_Call) Return(_a0 *dynamodb.DeleteItemOutput, _a1 error) *DynamoDBAPI_DeleteItem_Call
- func (_c *DynamoDBAPI_DeleteItem_Call) Run(run func(ctx context.Context, params *dynamodb.DeleteItemInput, ...)) *DynamoDBAPI_DeleteItem_Call
- func (_c *DynamoDBAPI_DeleteItem_Call) RunAndReturn(...) *DynamoDBAPI_DeleteItem_Call
- type DynamoDBAPI_DeleteTable_Call
- func (_c *DynamoDBAPI_DeleteTable_Call) Return(_a0 *dynamodb.DeleteTableOutput, _a1 error) *DynamoDBAPI_DeleteTable_Call
- func (_c *DynamoDBAPI_DeleteTable_Call) Run(run func(ctx context.Context, params *dynamodb.DeleteTableInput, ...)) *DynamoDBAPI_DeleteTable_Call
- func (_c *DynamoDBAPI_DeleteTable_Call) RunAndReturn(...) *DynamoDBAPI_DeleteTable_Call
- type DynamoDBAPI_DescribeTable_Call
- func (_c *DynamoDBAPI_DescribeTable_Call) Return(_a0 *dynamodb.DescribeTableOutput, _a1 error) *DynamoDBAPI_DescribeTable_Call
- func (_c *DynamoDBAPI_DescribeTable_Call) Run(run func(ctx context.Context, params *dynamodb.DescribeTableInput, ...)) *DynamoDBAPI_DescribeTable_Call
- func (_c *DynamoDBAPI_DescribeTable_Call) RunAndReturn(...) *DynamoDBAPI_DescribeTable_Call
- type DynamoDBAPI_Expecter
- func (_e *DynamoDBAPI_Expecter) CreateTable(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_CreateTable_Call
- func (_e *DynamoDBAPI_Expecter) DeleteItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_DeleteItem_Call
- func (_e *DynamoDBAPI_Expecter) DeleteTable(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_DeleteTable_Call
- func (_e *DynamoDBAPI_Expecter) DescribeTable(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_DescribeTable_Call
- func (_e *DynamoDBAPI_Expecter) GetItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_GetItem_Call
- func (_e *DynamoDBAPI_Expecter) PutItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_PutItem_Call
- func (_e *DynamoDBAPI_Expecter) Query(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_Query_Call
- func (_e *DynamoDBAPI_Expecter) Scan(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_Scan_Call
- func (_e *DynamoDBAPI_Expecter) UpdateItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_UpdateItem_Call
- type DynamoDBAPI_GetItem_Call
- func (_c *DynamoDBAPI_GetItem_Call) Return(_a0 *dynamodb.GetItemOutput, _a1 error) *DynamoDBAPI_GetItem_Call
- func (_c *DynamoDBAPI_GetItem_Call) Run(run func(ctx context.Context, params *dynamodb.GetItemInput, ...)) *DynamoDBAPI_GetItem_Call
- func (_c *DynamoDBAPI_GetItem_Call) RunAndReturn(...) *DynamoDBAPI_GetItem_Call
- type DynamoDBAPI_PutItem_Call
- func (_c *DynamoDBAPI_PutItem_Call) Return(_a0 *dynamodb.PutItemOutput, _a1 error) *DynamoDBAPI_PutItem_Call
- func (_c *DynamoDBAPI_PutItem_Call) Run(run func(ctx context.Context, params *dynamodb.PutItemInput, ...)) *DynamoDBAPI_PutItem_Call
- func (_c *DynamoDBAPI_PutItem_Call) RunAndReturn(...) *DynamoDBAPI_PutItem_Call
- type DynamoDBAPI_Query_Call
- func (_c *DynamoDBAPI_Query_Call) Return(_a0 *dynamodb.QueryOutput, _a1 error) *DynamoDBAPI_Query_Call
- func (_c *DynamoDBAPI_Query_Call) Run(run func(ctx context.Context, params *dynamodb.QueryInput, ...)) *DynamoDBAPI_Query_Call
- func (_c *DynamoDBAPI_Query_Call) RunAndReturn(...) *DynamoDBAPI_Query_Call
- type DynamoDBAPI_Scan_Call
- type DynamoDBAPI_UpdateItem_Call
- func (_c *DynamoDBAPI_UpdateItem_Call) Return(_a0 *dynamodb.UpdateItemOutput, _a1 error) *DynamoDBAPI_UpdateItem_Call
- func (_c *DynamoDBAPI_UpdateItem_Call) Run(run func(ctx context.Context, params *dynamodb.UpdateItemInput, ...)) *DynamoDBAPI_UpdateItem_Call
- func (_c *DynamoDBAPI_UpdateItem_Call) RunAndReturn(...) *DynamoDBAPI_UpdateItem_Call
- type KinesisAPI
- func (_m *KinesisAPI) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, ...) (*kinesis.CreateStreamOutput, error)
- func (_m *KinesisAPI) DeleteStream(ctx context.Context, params *kinesis.DeleteStreamInput, ...) (*kinesis.DeleteStreamOutput, error)
- func (_m *KinesisAPI) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, ...) (*kinesis.DescribeStreamOutput, error)
- func (_m *KinesisAPI) EXPECT() *KinesisAPI_Expecter
- func (_m *KinesisAPI) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, ...) (*kinesis.GetRecordsOutput, error)
- func (_m *KinesisAPI) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, ...) (*kinesis.GetShardIteratorOutput, error)
- func (_m *KinesisAPI) ListShards(ctx context.Context, params *kinesis.ListShardsInput, ...) (*kinesis.ListShardsOutput, error)
- func (_m *KinesisAPI) PutRecords(ctx context.Context, params *kinesis.PutRecordsInput, ...) (*kinesis.PutRecordsOutput, error)
- type KinesisAPI_CreateStream_Call
- func (_c *KinesisAPI_CreateStream_Call) Return(_a0 *kinesis.CreateStreamOutput, _a1 error) *KinesisAPI_CreateStream_Call
- func (_c *KinesisAPI_CreateStream_Call) Run(run func(ctx context.Context, params *kinesis.CreateStreamInput, ...)) *KinesisAPI_CreateStream_Call
- func (_c *KinesisAPI_CreateStream_Call) RunAndReturn(...) *KinesisAPI_CreateStream_Call
- type KinesisAPI_DeleteStream_Call
- func (_c *KinesisAPI_DeleteStream_Call) Return(_a0 *kinesis.DeleteStreamOutput, _a1 error) *KinesisAPI_DeleteStream_Call
- func (_c *KinesisAPI_DeleteStream_Call) Run(run func(ctx context.Context, params *kinesis.DeleteStreamInput, ...)) *KinesisAPI_DeleteStream_Call
- func (_c *KinesisAPI_DeleteStream_Call) RunAndReturn(...) *KinesisAPI_DeleteStream_Call
- type KinesisAPI_DescribeStream_Call
- func (_c *KinesisAPI_DescribeStream_Call) Return(_a0 *kinesis.DescribeStreamOutput, _a1 error) *KinesisAPI_DescribeStream_Call
- func (_c *KinesisAPI_DescribeStream_Call) Run(run func(ctx context.Context, params *kinesis.DescribeStreamInput, ...)) *KinesisAPI_DescribeStream_Call
- func (_c *KinesisAPI_DescribeStream_Call) RunAndReturn(...) *KinesisAPI_DescribeStream_Call
- type KinesisAPI_Expecter
- func (_e *KinesisAPI_Expecter) CreateStream(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_CreateStream_Call
- func (_e *KinesisAPI_Expecter) DeleteStream(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_DeleteStream_Call
- func (_e *KinesisAPI_Expecter) DescribeStream(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_DescribeStream_Call
- func (_e *KinesisAPI_Expecter) GetRecords(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_GetRecords_Call
- func (_e *KinesisAPI_Expecter) GetShardIterator(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_GetShardIterator_Call
- func (_e *KinesisAPI_Expecter) ListShards(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_ListShards_Call
- func (_e *KinesisAPI_Expecter) PutRecords(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_PutRecords_Call
- type KinesisAPI_GetRecords_Call
- func (_c *KinesisAPI_GetRecords_Call) Return(_a0 *kinesis.GetRecordsOutput, _a1 error) *KinesisAPI_GetRecords_Call
- func (_c *KinesisAPI_GetRecords_Call) Run(run func(ctx context.Context, params *kinesis.GetRecordsInput, ...)) *KinesisAPI_GetRecords_Call
- func (_c *KinesisAPI_GetRecords_Call) RunAndReturn(...) *KinesisAPI_GetRecords_Call
- type KinesisAPI_GetShardIterator_Call
- func (_c *KinesisAPI_GetShardIterator_Call) Return(_a0 *kinesis.GetShardIteratorOutput, _a1 error) *KinesisAPI_GetShardIterator_Call
- func (_c *KinesisAPI_GetShardIterator_Call) Run(run func(ctx context.Context, params *kinesis.GetShardIteratorInput, ...)) *KinesisAPI_GetShardIterator_Call
- func (_c *KinesisAPI_GetShardIterator_Call) RunAndReturn(...) *KinesisAPI_GetShardIterator_Call
- type KinesisAPI_ListShards_Call
- func (_c *KinesisAPI_ListShards_Call) Return(_a0 *kinesis.ListShardsOutput, _a1 error) *KinesisAPI_ListShards_Call
- func (_c *KinesisAPI_ListShards_Call) Run(run func(ctx context.Context, params *kinesis.ListShardsInput, ...)) *KinesisAPI_ListShards_Call
- func (_c *KinesisAPI_ListShards_Call) RunAndReturn(...) *KinesisAPI_ListShards_Call
- type KinesisAPI_PutRecords_Call
- func (_c *KinesisAPI_PutRecords_Call) Return(_a0 *kinesis.PutRecordsOutput, _a1 error) *KinesisAPI_PutRecords_Call
- func (_c *KinesisAPI_PutRecords_Call) Run(run func(ctx context.Context, params *kinesis.PutRecordsInput, ...)) *KinesisAPI_PutRecords_Call
- func (_c *KinesisAPI_PutRecords_Call) RunAndReturn(...) *KinesisAPI_PutRecords_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamoDBAPI ¶
DynamoDBAPI is an autogenerated mock type for the DynamoDBAPI type
func NewDynamoDBAPI ¶
func NewDynamoDBAPI(t mockConstructorTestingTNewDynamoDBAPI) *DynamoDBAPI
NewDynamoDBAPI creates a new instance of DynamoDBAPI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DynamoDBAPI) CreateTable ¶
func (_m *DynamoDBAPI) CreateTable(ctx context.Context, params *dynamodb.CreateTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.CreateTableOutput, error)
CreateTable provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) DeleteItem ¶
func (_m *DynamoDBAPI) DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)
DeleteItem provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) DeleteTable ¶
func (_m *DynamoDBAPI) DeleteTable(ctx context.Context, params *dynamodb.DeleteTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteTableOutput, error)
DeleteTable provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) DescribeTable ¶
func (_m *DynamoDBAPI) DescribeTable(ctx context.Context, params *dynamodb.DescribeTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeTableOutput, error)
DescribeTable provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) EXPECT ¶
func (_m *DynamoDBAPI) EXPECT() *DynamoDBAPI_Expecter
func (*DynamoDBAPI) GetItem ¶
func (_m *DynamoDBAPI) GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)
GetItem provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) PutItem ¶
func (_m *DynamoDBAPI) PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
PutItem provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) Query ¶
func (_m *DynamoDBAPI) Query(ctx context.Context, params *dynamodb.QueryInput, optFns ...func(*dynamodb.Options)) (*dynamodb.QueryOutput, error)
Query provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) Scan ¶
func (_m *DynamoDBAPI) Scan(ctx context.Context, params *dynamodb.ScanInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)
Scan provides a mock function with given fields: ctx, params, optFns
func (*DynamoDBAPI) UpdateItem ¶
func (_m *DynamoDBAPI) UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)
UpdateItem provides a mock function with given fields: ctx, params, optFns
type DynamoDBAPI_CreateTable_Call ¶
DynamoDBAPI_CreateTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTable'
func (*DynamoDBAPI_CreateTable_Call) Return ¶
func (_c *DynamoDBAPI_CreateTable_Call) Return(_a0 *dynamodb.CreateTableOutput, _a1 error) *DynamoDBAPI_CreateTable_Call
func (*DynamoDBAPI_CreateTable_Call) Run ¶
func (_c *DynamoDBAPI_CreateTable_Call) Run(run func(ctx context.Context, params *dynamodb.CreateTableInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_CreateTable_Call
func (*DynamoDBAPI_CreateTable_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_CreateTable_Call) RunAndReturn(run func(context.Context, *dynamodb.CreateTableInput, ...func(*dynamodb.Options)) (*dynamodb.CreateTableOutput, error)) *DynamoDBAPI_CreateTable_Call
type DynamoDBAPI_DeleteItem_Call ¶
DynamoDBAPI_DeleteItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteItem'
func (*DynamoDBAPI_DeleteItem_Call) Return ¶
func (_c *DynamoDBAPI_DeleteItem_Call) Return(_a0 *dynamodb.DeleteItemOutput, _a1 error) *DynamoDBAPI_DeleteItem_Call
func (*DynamoDBAPI_DeleteItem_Call) Run ¶
func (_c *DynamoDBAPI_DeleteItem_Call) Run(run func(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_DeleteItem_Call
func (*DynamoDBAPI_DeleteItem_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_DeleteItem_Call) RunAndReturn(run func(context.Context, *dynamodb.DeleteItemInput, ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)) *DynamoDBAPI_DeleteItem_Call
type DynamoDBAPI_DeleteTable_Call ¶
DynamoDBAPI_DeleteTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTable'
func (*DynamoDBAPI_DeleteTable_Call) Return ¶
func (_c *DynamoDBAPI_DeleteTable_Call) Return(_a0 *dynamodb.DeleteTableOutput, _a1 error) *DynamoDBAPI_DeleteTable_Call
func (*DynamoDBAPI_DeleteTable_Call) Run ¶
func (_c *DynamoDBAPI_DeleteTable_Call) Run(run func(ctx context.Context, params *dynamodb.DeleteTableInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_DeleteTable_Call
func (*DynamoDBAPI_DeleteTable_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_DeleteTable_Call) RunAndReturn(run func(context.Context, *dynamodb.DeleteTableInput, ...func(*dynamodb.Options)) (*dynamodb.DeleteTableOutput, error)) *DynamoDBAPI_DeleteTable_Call
type DynamoDBAPI_DescribeTable_Call ¶
DynamoDBAPI_DescribeTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeTable'
func (*DynamoDBAPI_DescribeTable_Call) Return ¶
func (_c *DynamoDBAPI_DescribeTable_Call) Return(_a0 *dynamodb.DescribeTableOutput, _a1 error) *DynamoDBAPI_DescribeTable_Call
func (*DynamoDBAPI_DescribeTable_Call) Run ¶
func (_c *DynamoDBAPI_DescribeTable_Call) Run(run func(ctx context.Context, params *dynamodb.DescribeTableInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_DescribeTable_Call
func (*DynamoDBAPI_DescribeTable_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_DescribeTable_Call) RunAndReturn(run func(context.Context, *dynamodb.DescribeTableInput, ...func(*dynamodb.Options)) (*dynamodb.DescribeTableOutput, error)) *DynamoDBAPI_DescribeTable_Call
type DynamoDBAPI_Expecter ¶
type DynamoDBAPI_Expecter struct {
// contains filtered or unexported fields
}
func (*DynamoDBAPI_Expecter) CreateTable ¶
func (_e *DynamoDBAPI_Expecter) CreateTable(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_CreateTable_Call
CreateTable is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.CreateTableInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) DeleteItem ¶
func (_e *DynamoDBAPI_Expecter) DeleteItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_DeleteItem_Call
DeleteItem is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.DeleteItemInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) DeleteTable ¶
func (_e *DynamoDBAPI_Expecter) DeleteTable(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_DeleteTable_Call
DeleteTable is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.DeleteTableInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) DescribeTable ¶
func (_e *DynamoDBAPI_Expecter) DescribeTable(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_DescribeTable_Call
DescribeTable is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.DescribeTableInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) GetItem ¶
func (_e *DynamoDBAPI_Expecter) GetItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_GetItem_Call
GetItem is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.GetItemInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) PutItem ¶
func (_e *DynamoDBAPI_Expecter) PutItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_PutItem_Call
PutItem is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.PutItemInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) Query ¶
func (_e *DynamoDBAPI_Expecter) Query(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_Query_Call
Query is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.QueryInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) Scan ¶
func (_e *DynamoDBAPI_Expecter) Scan(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_Scan_Call
Scan is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.ScanInput
- optFns ...func(*dynamodb.Options)
func (*DynamoDBAPI_Expecter) UpdateItem ¶
func (_e *DynamoDBAPI_Expecter) UpdateItem(ctx interface{}, params interface{}, optFns ...interface{}) *DynamoDBAPI_UpdateItem_Call
UpdateItem is a helper method to define mock.On call
- ctx context.Context
- params *dynamodb.UpdateItemInput
- optFns ...func(*dynamodb.Options)
type DynamoDBAPI_GetItem_Call ¶
DynamoDBAPI_GetItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetItem'
func (*DynamoDBAPI_GetItem_Call) Return ¶
func (_c *DynamoDBAPI_GetItem_Call) Return(_a0 *dynamodb.GetItemOutput, _a1 error) *DynamoDBAPI_GetItem_Call
func (*DynamoDBAPI_GetItem_Call) Run ¶
func (_c *DynamoDBAPI_GetItem_Call) Run(run func(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_GetItem_Call
func (*DynamoDBAPI_GetItem_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_GetItem_Call) RunAndReturn(run func(context.Context, *dynamodb.GetItemInput, ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)) *DynamoDBAPI_GetItem_Call
type DynamoDBAPI_PutItem_Call ¶
DynamoDBAPI_PutItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutItem'
func (*DynamoDBAPI_PutItem_Call) Return ¶
func (_c *DynamoDBAPI_PutItem_Call) Return(_a0 *dynamodb.PutItemOutput, _a1 error) *DynamoDBAPI_PutItem_Call
func (*DynamoDBAPI_PutItem_Call) Run ¶
func (_c *DynamoDBAPI_PutItem_Call) Run(run func(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_PutItem_Call
func (*DynamoDBAPI_PutItem_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_PutItem_Call) RunAndReturn(run func(context.Context, *dynamodb.PutItemInput, ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)) *DynamoDBAPI_PutItem_Call
type DynamoDBAPI_Query_Call ¶
DynamoDBAPI_Query_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Query'
func (*DynamoDBAPI_Query_Call) Return ¶
func (_c *DynamoDBAPI_Query_Call) Return(_a0 *dynamodb.QueryOutput, _a1 error) *DynamoDBAPI_Query_Call
func (*DynamoDBAPI_Query_Call) Run ¶
func (_c *DynamoDBAPI_Query_Call) Run(run func(ctx context.Context, params *dynamodb.QueryInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_Query_Call
func (*DynamoDBAPI_Query_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_Query_Call) RunAndReturn(run func(context.Context, *dynamodb.QueryInput, ...func(*dynamodb.Options)) (*dynamodb.QueryOutput, error)) *DynamoDBAPI_Query_Call
type DynamoDBAPI_Scan_Call ¶
DynamoDBAPI_Scan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Scan'
func (*DynamoDBAPI_Scan_Call) Return ¶
func (_c *DynamoDBAPI_Scan_Call) Return(_a0 *dynamodb.ScanOutput, _a1 error) *DynamoDBAPI_Scan_Call
func (*DynamoDBAPI_Scan_Call) Run ¶
func (_c *DynamoDBAPI_Scan_Call) Run(run func(ctx context.Context, params *dynamodb.ScanInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_Scan_Call
func (*DynamoDBAPI_Scan_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_Scan_Call) RunAndReturn(run func(context.Context, *dynamodb.ScanInput, ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)) *DynamoDBAPI_Scan_Call
type DynamoDBAPI_UpdateItem_Call ¶
DynamoDBAPI_UpdateItem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateItem'
func (*DynamoDBAPI_UpdateItem_Call) Return ¶
func (_c *DynamoDBAPI_UpdateItem_Call) Return(_a0 *dynamodb.UpdateItemOutput, _a1 error) *DynamoDBAPI_UpdateItem_Call
func (*DynamoDBAPI_UpdateItem_Call) Run ¶
func (_c *DynamoDBAPI_UpdateItem_Call) Run(run func(ctx context.Context, params *dynamodb.UpdateItemInput, optFns ...func(*dynamodb.Options))) *DynamoDBAPI_UpdateItem_Call
func (*DynamoDBAPI_UpdateItem_Call) RunAndReturn ¶
func (_c *DynamoDBAPI_UpdateItem_Call) RunAndReturn(run func(context.Context, *dynamodb.UpdateItemInput, ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)) *DynamoDBAPI_UpdateItem_Call
type KinesisAPI ¶
KinesisAPI is an autogenerated mock type for the KinesisAPI type
func NewKinesisAPI ¶
func NewKinesisAPI(t mockConstructorTestingTNewKinesisAPI) *KinesisAPI
NewKinesisAPI creates a new instance of KinesisAPI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*KinesisAPI) CreateStream ¶
func (_m *KinesisAPI) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)
CreateStream provides a mock function with given fields: ctx, params, optFns
func (*KinesisAPI) DeleteStream ¶
func (_m *KinesisAPI) DeleteStream(ctx context.Context, params *kinesis.DeleteStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DeleteStreamOutput, error)
DeleteStream provides a mock function with given fields: ctx, params, optFns
func (*KinesisAPI) DescribeStream ¶
func (_m *KinesisAPI) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamOutput, error)
DescribeStream provides a mock function with given fields: ctx, params, optFns
func (*KinesisAPI) EXPECT ¶
func (_m *KinesisAPI) EXPECT() *KinesisAPI_Expecter
func (*KinesisAPI) GetRecords ¶
func (_m *KinesisAPI) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.GetRecordsOutput, error)
GetRecords provides a mock function with given fields: ctx, params, optFns
func (*KinesisAPI) GetShardIterator ¶
func (_m *KinesisAPI) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, optFns ...func(*kinesis.Options)) (*kinesis.GetShardIteratorOutput, error)
GetShardIterator provides a mock function with given fields: ctx, params, optFns
func (*KinesisAPI) ListShards ¶
func (_m *KinesisAPI) ListShards(ctx context.Context, params *kinesis.ListShardsInput, optFns ...func(*kinesis.Options)) (*kinesis.ListShardsOutput, error)
ListShards provides a mock function with given fields: ctx, params, optFns
func (*KinesisAPI) PutRecords ¶
func (_m *KinesisAPI) PutRecords(ctx context.Context, params *kinesis.PutRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.PutRecordsOutput, error)
PutRecords provides a mock function with given fields: ctx, params, optFns
type KinesisAPI_CreateStream_Call ¶
KinesisAPI_CreateStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateStream'
func (*KinesisAPI_CreateStream_Call) Return ¶
func (_c *KinesisAPI_CreateStream_Call) Return(_a0 *kinesis.CreateStreamOutput, _a1 error) *KinesisAPI_CreateStream_Call
func (*KinesisAPI_CreateStream_Call) Run ¶
func (_c *KinesisAPI_CreateStream_Call) Run(run func(ctx context.Context, params *kinesis.CreateStreamInput, optFns ...func(*kinesis.Options))) *KinesisAPI_CreateStream_Call
func (*KinesisAPI_CreateStream_Call) RunAndReturn ¶
func (_c *KinesisAPI_CreateStream_Call) RunAndReturn(run func(context.Context, *kinesis.CreateStreamInput, ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)) *KinesisAPI_CreateStream_Call
type KinesisAPI_DeleteStream_Call ¶
KinesisAPI_DeleteStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteStream'
func (*KinesisAPI_DeleteStream_Call) Return ¶
func (_c *KinesisAPI_DeleteStream_Call) Return(_a0 *kinesis.DeleteStreamOutput, _a1 error) *KinesisAPI_DeleteStream_Call
func (*KinesisAPI_DeleteStream_Call) Run ¶
func (_c *KinesisAPI_DeleteStream_Call) Run(run func(ctx context.Context, params *kinesis.DeleteStreamInput, optFns ...func(*kinesis.Options))) *KinesisAPI_DeleteStream_Call
func (*KinesisAPI_DeleteStream_Call) RunAndReturn ¶
func (_c *KinesisAPI_DeleteStream_Call) RunAndReturn(run func(context.Context, *kinesis.DeleteStreamInput, ...func(*kinesis.Options)) (*kinesis.DeleteStreamOutput, error)) *KinesisAPI_DeleteStream_Call
type KinesisAPI_DescribeStream_Call ¶
KinesisAPI_DescribeStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeStream'
func (*KinesisAPI_DescribeStream_Call) Return ¶
func (_c *KinesisAPI_DescribeStream_Call) Return(_a0 *kinesis.DescribeStreamOutput, _a1 error) *KinesisAPI_DescribeStream_Call
func (*KinesisAPI_DescribeStream_Call) Run ¶
func (_c *KinesisAPI_DescribeStream_Call) Run(run func(ctx context.Context, params *kinesis.DescribeStreamInput, optFns ...func(*kinesis.Options))) *KinesisAPI_DescribeStream_Call
func (*KinesisAPI_DescribeStream_Call) RunAndReturn ¶
func (_c *KinesisAPI_DescribeStream_Call) RunAndReturn(run func(context.Context, *kinesis.DescribeStreamInput, ...func(*kinesis.Options)) (*kinesis.DescribeStreamOutput, error)) *KinesisAPI_DescribeStream_Call
type KinesisAPI_Expecter ¶
type KinesisAPI_Expecter struct {
// contains filtered or unexported fields
}
func (*KinesisAPI_Expecter) CreateStream ¶
func (_e *KinesisAPI_Expecter) CreateStream(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_CreateStream_Call
CreateStream is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.CreateStreamInput
- optFns ...func(*kinesis.Options)
func (*KinesisAPI_Expecter) DeleteStream ¶
func (_e *KinesisAPI_Expecter) DeleteStream(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_DeleteStream_Call
DeleteStream is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.DeleteStreamInput
- optFns ...func(*kinesis.Options)
func (*KinesisAPI_Expecter) DescribeStream ¶
func (_e *KinesisAPI_Expecter) DescribeStream(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_DescribeStream_Call
DescribeStream is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.DescribeStreamInput
- optFns ...func(*kinesis.Options)
func (*KinesisAPI_Expecter) GetRecords ¶
func (_e *KinesisAPI_Expecter) GetRecords(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_GetRecords_Call
GetRecords is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.GetRecordsInput
- optFns ...func(*kinesis.Options)
func (*KinesisAPI_Expecter) GetShardIterator ¶
func (_e *KinesisAPI_Expecter) GetShardIterator(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_GetShardIterator_Call
GetShardIterator is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.GetShardIteratorInput
- optFns ...func(*kinesis.Options)
func (*KinesisAPI_Expecter) ListShards ¶
func (_e *KinesisAPI_Expecter) ListShards(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_ListShards_Call
ListShards is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.ListShardsInput
- optFns ...func(*kinesis.Options)
func (*KinesisAPI_Expecter) PutRecords ¶
func (_e *KinesisAPI_Expecter) PutRecords(ctx interface{}, params interface{}, optFns ...interface{}) *KinesisAPI_PutRecords_Call
PutRecords is a helper method to define mock.On call
- ctx context.Context
- params *kinesis.PutRecordsInput
- optFns ...func(*kinesis.Options)
type KinesisAPI_GetRecords_Call ¶
KinesisAPI_GetRecords_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecords'
func (*KinesisAPI_GetRecords_Call) Return ¶
func (_c *KinesisAPI_GetRecords_Call) Return(_a0 *kinesis.GetRecordsOutput, _a1 error) *KinesisAPI_GetRecords_Call
func (*KinesisAPI_GetRecords_Call) Run ¶
func (_c *KinesisAPI_GetRecords_Call) Run(run func(ctx context.Context, params *kinesis.GetRecordsInput, optFns ...func(*kinesis.Options))) *KinesisAPI_GetRecords_Call
func (*KinesisAPI_GetRecords_Call) RunAndReturn ¶
func (_c *KinesisAPI_GetRecords_Call) RunAndReturn(run func(context.Context, *kinesis.GetRecordsInput, ...func(*kinesis.Options)) (*kinesis.GetRecordsOutput, error)) *KinesisAPI_GetRecords_Call
type KinesisAPI_GetShardIterator_Call ¶
KinesisAPI_GetShardIterator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShardIterator'
func (*KinesisAPI_GetShardIterator_Call) Return ¶
func (_c *KinesisAPI_GetShardIterator_Call) Return(_a0 *kinesis.GetShardIteratorOutput, _a1 error) *KinesisAPI_GetShardIterator_Call
func (*KinesisAPI_GetShardIterator_Call) Run ¶
func (_c *KinesisAPI_GetShardIterator_Call) Run(run func(ctx context.Context, params *kinesis.GetShardIteratorInput, optFns ...func(*kinesis.Options))) *KinesisAPI_GetShardIterator_Call
func (*KinesisAPI_GetShardIterator_Call) RunAndReturn ¶
func (_c *KinesisAPI_GetShardIterator_Call) RunAndReturn(run func(context.Context, *kinesis.GetShardIteratorInput, ...func(*kinesis.Options)) (*kinesis.GetShardIteratorOutput, error)) *KinesisAPI_GetShardIterator_Call
type KinesisAPI_ListShards_Call ¶
KinesisAPI_ListShards_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListShards'
func (*KinesisAPI_ListShards_Call) Return ¶
func (_c *KinesisAPI_ListShards_Call) Return(_a0 *kinesis.ListShardsOutput, _a1 error) *KinesisAPI_ListShards_Call
func (*KinesisAPI_ListShards_Call) Run ¶
func (_c *KinesisAPI_ListShards_Call) Run(run func(ctx context.Context, params *kinesis.ListShardsInput, optFns ...func(*kinesis.Options))) *KinesisAPI_ListShards_Call
func (*KinesisAPI_ListShards_Call) RunAndReturn ¶
func (_c *KinesisAPI_ListShards_Call) RunAndReturn(run func(context.Context, *kinesis.ListShardsInput, ...func(*kinesis.Options)) (*kinesis.ListShardsOutput, error)) *KinesisAPI_ListShards_Call
type KinesisAPI_PutRecords_Call ¶
KinesisAPI_PutRecords_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRecords'
func (*KinesisAPI_PutRecords_Call) Return ¶
func (_c *KinesisAPI_PutRecords_Call) Return(_a0 *kinesis.PutRecordsOutput, _a1 error) *KinesisAPI_PutRecords_Call
func (*KinesisAPI_PutRecords_Call) Run ¶
func (_c *KinesisAPI_PutRecords_Call) Run(run func(ctx context.Context, params *kinesis.PutRecordsInput, optFns ...func(*kinesis.Options))) *KinesisAPI_PutRecords_Call
func (*KinesisAPI_PutRecords_Call) RunAndReturn ¶
func (_c *KinesisAPI_PutRecords_Call) RunAndReturn(run func(context.Context, *kinesis.PutRecordsInput, ...func(*kinesis.Options)) (*kinesis.PutRecordsOutput, error)) *KinesisAPI_PutRecords_Call