dynamodbmock

README

DynamoDB Client

Usage

// main.go
package main

import (
	"context"
	"fmt"

	"github.com/aws/aws-sdk-go-v2/config"
	"github.com/aws/aws-sdk-go-v2/service/dynamodb"
)

type dynamodbClient interface {
	ListTables(ctx context.Context, params *dynamodb.ListTablesInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListTablesOutput, error)
}

func main() {
	cfg, _ := config.LoadDefaultConfig(context.Background())
	client := dynamodb.NewFromConfig(cfg)

	tables, _ := getTables(context.Background(), client)
	fmt.Printf("%#v", tables)
}

func getTables(ctx context.Context, c dynamodbClient) ([]string, error) {
	tables, err := c.ListTables(ctx, &dynamodb.ListTablesInput{})
	if err != nil {
		return nil, err
	}
	return tables.TableNames, nil
}

// main_test.go
package main

import (
	"context"
	"testing"

	"github.com/aws/aws-sdk-go-v2/service/dynamodb"
	"github.com/gvre/awsmock-v2/dynamodbmock"
	"github.com/stretchr/testify/mock"
)

func TestGetTables(t *testing.T) {
	tableNames := []string{
		"t1",
		"t2",
	}
	client := new(dynamodbmock.Client)
	client.On("ListTables", mock.Anything, mock.Anything, mock.Anything).Return(&dynamodb.ListTablesOutput{
		TableNames: tableNames,
	}, nil)

	tables, _ := getTables(context.Background(), client)

	if ntables, nTableNames := len(tables), len(tableNames); ntables != nTableNames {
		t.Errorf("Invalid number of tables, got: %v, want: %v", ntables, nTableNames)
	}
}

Documentation

Index

• type Client
  • func (c *Client) BatchExecuteStatement(ctx context.Context, params *dynamodb.BatchExecuteStatementInput, ...) (*dynamodb.BatchExecuteStatementOutput, error)
  • func (c *Client) BatchGetItem(ctx context.Context, params *dynamodb.BatchGetItemInput, ...) (*dynamodb.BatchGetItemOutput, error)
  • func (c *Client) BatchWriteItem(ctx context.Context, params *dynamodb.BatchWriteItemInput, ...) (*dynamodb.BatchWriteItemOutput, error)
  • func (c *Client) CreateBackup(ctx context.Context, params *dynamodb.CreateBackupInput, ...) (*dynamodb.CreateBackupOutput, error)
  • func (c *Client) CreateGlobalTable(ctx context.Context, params *dynamodb.CreateGlobalTableInput, ...) (*dynamodb.CreateGlobalTableOutput, error)
  • func (c *Client) CreateTable(ctx context.Context, params *dynamodb.CreateTableInput, ...) (*dynamodb.CreateTableOutput, error)
  • func (c *Client) DeleteBackup(ctx context.Context, params *dynamodb.DeleteBackupInput, ...) (*dynamodb.DeleteBackupOutput, error)
  • func (c *Client) DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, ...) (*dynamodb.DeleteItemOutput, error)
  • func (c *Client) DeleteTable(ctx context.Context, params *dynamodb.DeleteTableInput, ...) (*dynamodb.DeleteTableOutput, error)
  • func (c *Client) DescribeBackup(ctx context.Context, params *dynamodb.DescribeBackupInput, ...) (*dynamodb.DescribeBackupOutput, error)
  • func (c *Client) DescribeContinuousBackups(ctx context.Context, params *dynamodb.DescribeContinuousBackupsInput, ...) (*dynamodb.DescribeContinuousBackupsOutput, error)
  • func (c *Client) DescribeContributorInsights(ctx context.Context, params *dynamodb.DescribeContributorInsightsInput, ...) (*dynamodb.DescribeContributorInsightsOutput, error)
  • func (c *Client) DescribeEndpoints(ctx context.Context, params *dynamodb.DescribeEndpointsInput, ...) (*dynamodb.DescribeEndpointsOutput, error)
  • func (c *Client) DescribeExport(ctx context.Context, params *dynamodb.DescribeExportInput, ...) (*dynamodb.DescribeExportOutput, error)
  • func (c *Client) DescribeGlobalTable(ctx context.Context, params *dynamodb.DescribeGlobalTableInput, ...) (*dynamodb.DescribeGlobalTableOutput, error)
  • func (c *Client) DescribeGlobalTableSettings(ctx context.Context, params *dynamodb.DescribeGlobalTableSettingsInput, ...) (*dynamodb.DescribeGlobalTableSettingsOutput, error)
  • func (c *Client) DescribeKinesisStreamingDestination(ctx context.Context, params *dynamodb.DescribeKinesisStreamingDestinationInput, ...) (*dynamodb.DescribeKinesisStreamingDestinationOutput, error)
  • func (c *Client) DescribeLimits(ctx context.Context, params *dynamodb.DescribeLimitsInput, ...) (*dynamodb.DescribeLimitsOutput, error)
  • func (c *Client) DescribeTable(ctx context.Context, params *dynamodb.DescribeTableInput, ...) (*dynamodb.DescribeTableOutput, error)
  • func (c *Client) DescribeTableReplicaAutoScaling(ctx context.Context, params *dynamodb.DescribeTableReplicaAutoScalingInput, ...) (*dynamodb.DescribeTableReplicaAutoScalingOutput, error)
  • func (c *Client) DescribeTimeToLive(ctx context.Context, params *dynamodb.DescribeTimeToLiveInput, ...) (*dynamodb.DescribeTimeToLiveOutput, error)
  • func (c *Client) DisableKinesisStreamingDestination(ctx context.Context, params *dynamodb.DisableKinesisStreamingDestinationInput, ...) (*dynamodb.DisableKinesisStreamingDestinationOutput, error)
  • func (c *Client) EnableKinesisStreamingDestination(ctx context.Context, params *dynamodb.EnableKinesisStreamingDestinationInput, ...) (*dynamodb.EnableKinesisStreamingDestinationOutput, error)
  • func (c *Client) ExecuteStatement(ctx context.Context, params *dynamodb.ExecuteStatementInput, ...) (*dynamodb.ExecuteStatementOutput, error)
  • func (c *Client) ExecuteTransaction(ctx context.Context, params *dynamodb.ExecuteTransactionInput, ...) (*dynamodb.ExecuteTransactionOutput, error)
  • func (c *Client) ExportTableToPointInTime(ctx context.Context, params *dynamodb.ExportTableToPointInTimeInput, ...) (*dynamodb.ExportTableToPointInTimeOutput, error)
  • func (c *Client) GetItem(ctx context.Context, params *dynamodb.GetItemInput, ...) (*dynamodb.GetItemOutput, error)
  • func (c *Client) ListBackups(ctx context.Context, params *dynamodb.ListBackupsInput, ...) (*dynamodb.ListBackupsOutput, error)
  • func (c *Client) ListContributorInsights(ctx context.Context, params *dynamodb.ListContributorInsightsInput, ...) (*dynamodb.ListContributorInsightsOutput, error)
  • func (c *Client) ListExports(ctx context.Context, params *dynamodb.ListExportsInput, ...) (*dynamodb.ListExportsOutput, error)
  • func (c *Client) ListGlobalTables(ctx context.Context, params *dynamodb.ListGlobalTablesInput, ...) (*dynamodb.ListGlobalTablesOutput, error)
  • func (c *Client) ListTables(ctx context.Context, params *dynamodb.ListTablesInput, ...) (*dynamodb.ListTablesOutput, error)
  • func (c *Client) ListTagsOfResource(ctx context.Context, params *dynamodb.ListTagsOfResourceInput, ...) (*dynamodb.ListTagsOfResourceOutput, error)
  • func (c *Client) PutItem(ctx context.Context, params *dynamodb.PutItemInput, ...) (*dynamodb.PutItemOutput, error)
  • func (c *Client) Query(ctx context.Context, params *dynamodb.QueryInput, ...) (*dynamodb.QueryOutput, error)
  • func (c *Client) RestoreTableFromBackup(ctx context.Context, params *dynamodb.RestoreTableFromBackupInput, ...) (*dynamodb.RestoreTableFromBackupOutput, error)
  • func (c *Client) RestoreTableToPointInTime(ctx context.Context, params *dynamodb.RestoreTableToPointInTimeInput, ...) (*dynamodb.RestoreTableToPointInTimeOutput, error)
  • func (c *Client) Scan(ctx context.Context, params *dynamodb.ScanInput, ...) (*dynamodb.ScanOutput, error)
  • func (c *Client) TagResource(ctx context.Context, params *dynamodb.TagResourceInput, ...) (*dynamodb.TagResourceOutput, error)
  • func (c *Client) TransactGetItems(ctx context.Context, params *dynamodb.TransactGetItemsInput, ...) (*dynamodb.TransactGetItemsOutput, error)
  • func (c *Client) TransactWriteItems(ctx context.Context, params *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error)
  • func (c *Client) UntagResource(ctx context.Context, params *dynamodb.UntagResourceInput, ...) (*dynamodb.UntagResourceOutput, error)
  • func (c *Client) UpdateContinuousBackups(ctx context.Context, params *dynamodb.UpdateContinuousBackupsInput, ...) (*dynamodb.UpdateContinuousBackupsOutput, error)
  • func (c *Client) UpdateContributorInsights(ctx context.Context, params *dynamodb.UpdateContributorInsightsInput, ...) (*dynamodb.UpdateContributorInsightsOutput, error)
  • func (c *Client) UpdateGlobalTable(ctx context.Context, params *dynamodb.UpdateGlobalTableInput, ...) (*dynamodb.UpdateGlobalTableOutput, error)
  • func (c *Client) UpdateGlobalTableSettings(ctx context.Context, params *dynamodb.UpdateGlobalTableSettingsInput, ...) (*dynamodb.UpdateGlobalTableSettingsOutput, error)
  • func (c *Client) UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, ...) (*dynamodb.UpdateItemOutput, error)
  • func (c *Client) UpdateTable(ctx context.Context, params *dynamodb.UpdateTableInput, ...) (*dynamodb.UpdateTableOutput, error)
  • func (c *Client) UpdateTableReplicaAutoScaling(ctx context.Context, params *dynamodb.UpdateTableReplicaAutoScalingInput, ...) (*dynamodb.UpdateTableReplicaAutoScalingOutput, error)
  • func (c *Client) UpdateTimeToLive(ctx context.Context, params *dynamodb.UpdateTimeToLiveInput, ...) (*dynamodb.UpdateTimeToLiveOutput, error)

Types

type Client

type Client struct {
	mock.Mock
}

Client provides the API client to mock operations call for Amazon DynamoDB Service.

func (*Client) BatchExecuteStatement

func (c *Client) BatchExecuteStatement(ctx context.Context, params *dynamodb.BatchExecuteStatementInput, optFns ...func(*dynamodb.Options)) (*dynamodb.BatchExecuteStatementOutput, error)

BatchExecuteStatement mock.

func (*Client) BatchGetItem

func (c *Client) BatchGetItem(ctx context.Context, params *dynamodb.BatchGetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.BatchGetItemOutput, error)

BatchGetItem mock.

func (*Client) BatchWriteItem

func (c *Client) BatchWriteItem(ctx context.Context, params *dynamodb.BatchWriteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.BatchWriteItemOutput, error)

BatchWriteItem mock.

func (*Client) CreateBackup

func (c *Client) CreateBackup(ctx context.Context, params *dynamodb.CreateBackupInput, optFns ...func(*dynamodb.Options)) (*dynamodb.CreateBackupOutput, error)

CreateBackup mock.

func (*Client) CreateGlobalTable

func (c *Client) CreateGlobalTable(ctx context.Context, params *dynamodb.CreateGlobalTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.CreateGlobalTableOutput, error)

CreateGlobalTable mock.

func (*Client) CreateTable

func (c *Client) CreateTable(ctx context.Context, params *dynamodb.CreateTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.CreateTableOutput, error)

CreateTable mock.

func (*Client) DeleteBackup

func (c *Client) DeleteBackup(ctx context.Context, params *dynamodb.DeleteBackupInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteBackupOutput, error)

DeleteBackup mock.

func (*Client) DeleteItem

func (c *Client) DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)

DeleteItem mock.

func (*Client) DeleteTable

func (c *Client) DeleteTable(ctx context.Context, params *dynamodb.DeleteTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteTableOutput, error)

DeleteTable mock.

func (*Client) DescribeBackup

func (c *Client) DescribeBackup(ctx context.Context, params *dynamodb.DescribeBackupInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeBackupOutput, error)

DescribeBackup mock.

func (*Client) DescribeContinuousBackups

func (c *Client) DescribeContinuousBackups(ctx context.Context, params *dynamodb.DescribeContinuousBackupsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeContinuousBackupsOutput, error)

DescribeContinuousBackups mock.

func (*Client) DescribeContributorInsights

func (c *Client) DescribeContributorInsights(ctx context.Context, params *dynamodb.DescribeContributorInsightsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeContributorInsightsOutput, error)

DescribeContributorInsights mock.

func (*Client) DescribeEndpoints

func (c *Client) DescribeEndpoints(ctx context.Context, params *dynamodb.DescribeEndpointsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeEndpointsOutput, error)

DescribeEndpoints mock.

func (*Client) DescribeExport

func (c *Client) DescribeExport(ctx context.Context, params *dynamodb.DescribeExportInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeExportOutput, error)

DescribeExport mock.

func (*Client) DescribeGlobalTable

func (c *Client) DescribeGlobalTable(ctx context.Context, params *dynamodb.DescribeGlobalTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeGlobalTableOutput, error)

DescribeGlobalTable mock.

func (*Client) DescribeGlobalTableSettings

func (c *Client) DescribeGlobalTableSettings(ctx context.Context, params *dynamodb.DescribeGlobalTableSettingsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeGlobalTableSettingsOutput, error)

DescribeGlobalTableSettings mock.

func (*Client) DescribeKinesisStreamingDestination

func (c *Client) DescribeKinesisStreamingDestination(ctx context.Context, params *dynamodb.DescribeKinesisStreamingDestinationInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeKinesisStreamingDestinationOutput, error)

DescribeKinesisStreamingDestination mock.

func (*Client) DescribeLimits

func (c *Client) DescribeLimits(ctx context.Context, params *dynamodb.DescribeLimitsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeLimitsOutput, error)

DescribeLimits mock.

func (*Client) DescribeTable

func (c *Client) DescribeTable(ctx context.Context, params *dynamodb.DescribeTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeTableOutput, error)

DescribeTable mock.

func (*Client) DescribeTableReplicaAutoScaling

func (c *Client) DescribeTableReplicaAutoScaling(ctx context.Context, params *dynamodb.DescribeTableReplicaAutoScalingInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeTableReplicaAutoScalingOutput, error)

DescribeTableReplicaAutoScaling mock.

func (*Client) DescribeTimeToLive

func (c *Client) DescribeTimeToLive(ctx context.Context, params *dynamodb.DescribeTimeToLiveInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeTimeToLiveOutput, error)

DescribeTimeToLive mock.

func (*Client) DisableKinesisStreamingDestination

func (c *Client) DisableKinesisStreamingDestination(ctx context.Context, params *dynamodb.DisableKinesisStreamingDestinationInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DisableKinesisStreamingDestinationOutput, error)

DisableKinesisStreamingDestination mock.

func (*Client) EnableKinesisStreamingDestination

func (c *Client) EnableKinesisStreamingDestination(ctx context.Context, params *dynamodb.EnableKinesisStreamingDestinationInput, optFns ...func(*dynamodb.Options)) (*dynamodb.EnableKinesisStreamingDestinationOutput, error)

EnableKinesisStreamingDestination mock.

func (*Client) ExecuteStatement

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

ExecuteStatement mock.

func (*Client) ExecuteTransaction

func (c *Client) ExecuteTransaction(ctx context.Context, params *dynamodb.ExecuteTransactionInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ExecuteTransactionOutput, error)

ExecuteTransaction mock.

func (*Client) ExportTableToPointInTime

func (c *Client) ExportTableToPointInTime(ctx context.Context, params *dynamodb.ExportTableToPointInTimeInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ExportTableToPointInTimeOutput, error)

ExportTableToPointInTime mock.

func (*Client) GetItem

func (c *Client) GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)

GetItem mock.

func (*Client) ListBackups

func (c *Client) ListBackups(ctx context.Context, params *dynamodb.ListBackupsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListBackupsOutput, error)

ListBackups mock.

func (*Client) ListContributorInsights

func (c *Client) ListContributorInsights(ctx context.Context, params *dynamodb.ListContributorInsightsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListContributorInsightsOutput, error)

ListContributorInsights mock.

func (*Client) ListExports

func (c *Client) ListExports(ctx context.Context, params *dynamodb.ListExportsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListExportsOutput, error)

ListExports mock.

func (*Client) ListGlobalTables

func (c *Client) ListGlobalTables(ctx context.Context, params *dynamodb.ListGlobalTablesInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListGlobalTablesOutput, error)

ListGlobalTables mock.

func (*Client) ListTables

func (c *Client) ListTables(ctx context.Context, params *dynamodb.ListTablesInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListTablesOutput, error)

ListTables mock.

func (*Client) ListTagsOfResource

func (c *Client) ListTagsOfResource(ctx context.Context, params *dynamodb.ListTagsOfResourceInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ListTagsOfResourceOutput, error)

ListTagsOfResource mock.

func (*Client) PutItem

func (c *Client) PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)

PutItem mock.

func (*Client) Query

func (c *Client) Query(ctx context.Context, params *dynamodb.QueryInput, optFns ...func(*dynamodb.Options)) (*dynamodb.QueryOutput, error)

Query mock.

func (*Client) RestoreTableFromBackup

func (c *Client) RestoreTableFromBackup(ctx context.Context, params *dynamodb.RestoreTableFromBackupInput, optFns ...func(*dynamodb.Options)) (*dynamodb.RestoreTableFromBackupOutput, error)

RestoreTableFromBackup mock.

func (*Client) RestoreTableToPointInTime

func (c *Client) RestoreTableToPointInTime(ctx context.Context, params *dynamodb.RestoreTableToPointInTimeInput, optFns ...func(*dynamodb.Options)) (*dynamodb.RestoreTableToPointInTimeOutput, error)

RestoreTableToPointInTime mock.

func (*Client) Scan

func (c *Client) Scan(ctx context.Context, params *dynamodb.ScanInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)

Scan mock.

func (*Client) TagResource

func (c *Client) TagResource(ctx context.Context, params *dynamodb.TagResourceInput, optFns ...func(*dynamodb.Options)) (*dynamodb.TagResourceOutput, error)

TagResource mock.

func (*Client) TransactGetItems

func (c *Client) TransactGetItems(ctx context.Context, params *dynamodb.TransactGetItemsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.TransactGetItemsOutput, error)

TransactGetItems mock.

func (*Client) TransactWriteItems

func (c *Client) TransactWriteItems(ctx context.Context, params *dynamodb.TransactWriteItemsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.TransactWriteItemsOutput, error)

TransactWriteItems mock.

func (*Client) UntagResource

func (c *Client) UntagResource(ctx context.Context, params *dynamodb.UntagResourceInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UntagResourceOutput, error)

UntagResource mock.

func (*Client) UpdateContinuousBackups

func (c *Client) UpdateContinuousBackups(ctx context.Context, params *dynamodb.UpdateContinuousBackupsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateContinuousBackupsOutput, error)

UpdateContinuousBackups mock.

func (*Client) UpdateContributorInsights

func (c *Client) UpdateContributorInsights(ctx context.Context, params *dynamodb.UpdateContributorInsightsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateContributorInsightsOutput, error)

UpdateContributorInsights mock.

func (*Client) UpdateGlobalTable

func (c *Client) UpdateGlobalTable(ctx context.Context, params *dynamodb.UpdateGlobalTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateGlobalTableOutput, error)

UpdateGlobalTable mock.

func (*Client) UpdateGlobalTableSettings

func (c *Client) UpdateGlobalTableSettings(ctx context.Context, params *dynamodb.UpdateGlobalTableSettingsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateGlobalTableSettingsOutput, error)

UpdateGlobalTableSettings mock.

func (*Client) UpdateItem

func (c *Client) UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)

UpdateItem mock.

func (*Client) UpdateTable

func (c *Client) UpdateTable(ctx context.Context, params *dynamodb.UpdateTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateTableOutput, error)

UpdateTable mock.

func (*Client) UpdateTableReplicaAutoScaling

func (c *Client) UpdateTableReplicaAutoScaling(ctx context.Context, params *dynamodb.UpdateTableReplicaAutoScalingInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateTableReplicaAutoScalingOutput, error)

UpdateTableReplicaAutoScaling mock.

func (*Client) UpdateTimeToLive

func (c *Client) UpdateTimeToLive(ctx context.Context, params *dynamodb.UpdateTimeToLiveInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateTimeToLiveOutput, error)

UpdateTimeToLive mock.