neosync_benthos_dynamodb

Documentation

Index

• func RegisterDynamoDbInput(env *service.Environment) error
• func RegisterDynamoDbOutput(env *service.Environment) error
• type MockdynamoDBAPIV2
  • func NewMockdynamoDBAPIV2(t interface{ ... }) *MockdynamoDBAPIV2
  • func (_m *MockdynamoDBAPIV2) DescribeTable(ctx context.Context, params *dynamodb.DescribeTableInput, ...) (*dynamodb.DescribeTableOutput, error)
  • func (_m *MockdynamoDBAPIV2) EXPECT() *MockdynamoDBAPIV2_Expecter
  • func (_m *MockdynamoDBAPIV2) ExecuteStatement(ctx context.Context, params *dynamodb.ExecuteStatementInput, ...) (*dynamodb.ExecuteStatementOutput, error)
• type MockdynamoDBAPIV2_DescribeTable_Call
  • func (_c *MockdynamoDBAPIV2_DescribeTable_Call) Return(_a0 *dynamodb.DescribeTableOutput, _a1 error) *MockdynamoDBAPIV2_DescribeTable_Call
  • func (_c *MockdynamoDBAPIV2_DescribeTable_Call) Run(run func(ctx context.Context, params *dynamodb.DescribeTableInput, ...)) *MockdynamoDBAPIV2_DescribeTable_Call
  • func (_c *MockdynamoDBAPIV2_DescribeTable_Call) RunAndReturn(...) *MockdynamoDBAPIV2_DescribeTable_Call
• type MockdynamoDBAPIV2_ExecuteStatement_Call
  • func (_c *MockdynamoDBAPIV2_ExecuteStatement_Call) Return(_a0 *dynamodb.ExecuteStatementOutput, _a1 error) *MockdynamoDBAPIV2_ExecuteStatement_Call
  • func (_c *MockdynamoDBAPIV2_ExecuteStatement_Call) Run(run func(ctx context.Context, params *dynamodb.ExecuteStatementInput, ...)) *MockdynamoDBAPIV2_ExecuteStatement_Call
  • func (_c *MockdynamoDBAPIV2_ExecuteStatement_Call) RunAndReturn(...) *MockdynamoDBAPIV2_ExecuteStatement_Call
• type MockdynamoDBAPIV2_Expecter
  • func (_e *MockdynamoDBAPIV2_Expecter) DescribeTable(ctx interface{}, params interface{}, optFns ...interface{}) *MockdynamoDBAPIV2_DescribeTable_Call
  • func (_e *MockdynamoDBAPIV2_Expecter) ExecuteStatement(ctx interface{}, params interface{}, optFns ...interface{}) *MockdynamoDBAPIV2_ExecuteStatement_Call

Functions

func RegisterDynamoDbInput

func RegisterDynamoDbInput(env *service.Environment) error

func RegisterDynamoDbOutput

func RegisterDynamoDbOutput(env *service.Environment) error

Types

type MockdynamoDBAPIV2

type MockdynamoDBAPIV2 struct {
	mock.Mock
}

MockdynamoDBAPIV2 is an autogenerated mock type for the dynamoDBAPIV2 type

func NewMockdynamoDBAPIV2

func NewMockdynamoDBAPIV2(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockdynamoDBAPIV2

NewMockdynamoDBAPIV2 creates a new instance of MockdynamoDBAPIV2. 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 (*MockdynamoDBAPIV2) DescribeTable

func (_m *MockdynamoDBAPIV2) 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 (*MockdynamoDBAPIV2) EXPECT

func (_m *MockdynamoDBAPIV2) EXPECT() *MockdynamoDBAPIV2_Expecter

func (*MockdynamoDBAPIV2) ExecuteStatement

func (_m *MockdynamoDBAPIV2) ExecuteStatement(ctx context.Context, params *dynamodb.ExecuteStatementInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ExecuteStatementOutput, error)

ExecuteStatement provides a mock function with given fields: ctx, params, optFns

type MockdynamoDBAPIV2_DescribeTable_Call

type MockdynamoDBAPIV2_DescribeTable_Call struct {
	*mock.Call
}

MockdynamoDBAPIV2_DescribeTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeTable'

func (*MockdynamoDBAPIV2_DescribeTable_Call) Return

func (_c *MockdynamoDBAPIV2_DescribeTable_Call) Return(_a0 *dynamodb.DescribeTableOutput, _a1 error) *MockdynamoDBAPIV2_DescribeTable_Call

func (*MockdynamoDBAPIV2_DescribeTable_Call) Run

func (_c *MockdynamoDBAPIV2_DescribeTable_Call) Run(run func(ctx context.Context, params *dynamodb.DescribeTableInput, optFns ...func(*dynamodb.Options))) *MockdynamoDBAPIV2_DescribeTable_Call

func (*MockdynamoDBAPIV2_DescribeTable_Call) RunAndReturn

func (_c *MockdynamoDBAPIV2_DescribeTable_Call) RunAndReturn(run func(context.Context, *dynamodb.DescribeTableInput, ...func(*dynamodb.Options)) (*dynamodb.DescribeTableOutput, error)) *MockdynamoDBAPIV2_DescribeTable_Call

type MockdynamoDBAPIV2_ExecuteStatement_Call

type MockdynamoDBAPIV2_ExecuteStatement_Call struct {
	*mock.Call
}

MockdynamoDBAPIV2_ExecuteStatement_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteStatement'

func (*MockdynamoDBAPIV2_ExecuteStatement_Call) Return

func (_c *MockdynamoDBAPIV2_ExecuteStatement_Call) Return(_a0 *dynamodb.ExecuteStatementOutput, _a1 error) *MockdynamoDBAPIV2_ExecuteStatement_Call

func (*MockdynamoDBAPIV2_ExecuteStatement_Call) Run

func (_c *MockdynamoDBAPIV2_ExecuteStatement_Call) Run(run func(ctx context.Context, params *dynamodb.ExecuteStatementInput, optFns ...func(*dynamodb.Options))) *MockdynamoDBAPIV2_ExecuteStatement_Call

func (*MockdynamoDBAPIV2_ExecuteStatement_Call) RunAndReturn

func (_c *MockdynamoDBAPIV2_ExecuteStatement_Call) RunAndReturn(run func(context.Context, *dynamodb.ExecuteStatementInput, ...func(*dynamodb.Options)) (*dynamodb.ExecuteStatementOutput, error)) *MockdynamoDBAPIV2_ExecuteStatement_Call

type MockdynamoDBAPIV2_Expecter

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

func (*MockdynamoDBAPIV2_Expecter) DescribeTable

func (_e *MockdynamoDBAPIV2_Expecter) DescribeTable(ctx interface{}, params interface{}, optFns ...interface{}) *MockdynamoDBAPIV2_DescribeTable_Call

DescribeTable is a helper method to define mock.On call

• ctx context.Context
• params *dynamodb.DescribeTableInput
• optFns ...func(*dynamodb.Options)

func (*MockdynamoDBAPIV2_Expecter) ExecuteStatement

func (_e *MockdynamoDBAPIV2_Expecter) ExecuteStatement(ctx interface{}, params interface{}, optFns ...interface{}) *MockdynamoDBAPIV2_ExecuteStatement_Call

ExecuteStatement is a helper method to define mock.On call

• ctx context.Context
• params *dynamodb.ExecuteStatementInput
• optFns ...func(*dynamodb.Options)