Versions in this module Expand all Collapse all v0 v0.4.1 Sep 28, 2022 v0.4.0 Sep 25, 2022 Changes in this version + const AwsAttrTypeBinary + const AwsAttrTypeNumber + const AwsAttrTypeString + const AwsDynamodbNoIndex + const AwsKeyTypePartition + const AwsKeyTypeSort + var ErrTimeout = errors.New("timeout while waiting for status") + func AwsDynamodbEqualsBuilder(condition map[string]interface{}) *expression.ConditionBuilder + func AwsDynamodbExistsAllBuilder(attrs []string) *expression.ConditionBuilder + func AwsDynamodbNotExistsAllBuilder(attrs []string) *expression.ConditionBuilder + func AwsDynamodbToAttributeSet(v interface{}) *dynamodb.AttributeValue + func AwsDynamodbToAttributeValue(v interface{}) *dynamodb.AttributeValue + func AwsDynamodbWaitForGsiStatus(adc *AwsDynamodbConnect, tableName, gsiName string, statusList []string, ...) error + func AwsDynamodbWaitForTableStatus(adc *AwsDynamodbConnect, tableName string, statusList []string, ...) error + func AwsIgnoreErrorIfMatched(err error, excludeCodeList ...string) error + func AwsIgnoreTransactErrorIfMatched(err error, excludeCodeList ...string) error + func IsAwsError(err error, awsErrCode string) bool + type AwsDynamodbConnect struct + func NewAwsDynamodbConnect(cfg *aws.Config, sess *session.Session, db *dynamodb.DynamoDB, ...) (*AwsDynamodbConnect, error) + func (adc *AwsDynamodbConnect) AddValuesToAttributes(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) AddValuesToSet(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) BuildCreateGlobalSecondaryIndexAction(indexName, projectionType string, rcu, wcu int64, ...) *dynamodb.CreateGlobalSecondaryIndexAction + func (adc *AwsDynamodbConnect) BuildDeleteItemInput(table string, keyFilter map[string]interface{}, ...) (*dynamodb.DeleteItemInput, error) + func (adc *AwsDynamodbConnect) BuildGetItemInput(table string, keyFilter map[string]interface{}) (*dynamodb.GetItemInput, error) + func (adc *AwsDynamodbConnect) BuildPutItemInput(table string, item map[string]*dynamodb.AttributeValue, ...) (*dynamodb.PutItemInput, error) + func (adc *AwsDynamodbConnect) BuildQueryInput(table string, keyFilter, nonKeyFilter *expression.ConditionBuilder, ...) (*dynamodb.QueryInput, error) + func (adc *AwsDynamodbConnect) BuildScanInput(table string, filter *expression.ConditionBuilder, indexName string, ...) (*dynamodb.ScanInput, error) + func (adc *AwsDynamodbConnect) BuildTxAddValuesToAttributes(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxAddValuesToSet(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxDelete(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxDeleteValuesFromSet(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxGet(table string, keyFilter map[string]interface{}) (*dynamodb.TransactGetItem, error) + func (adc *AwsDynamodbConnect) BuildTxPut(table string, item interface{}, condition *expression.ConditionBuilder) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxPutIfNotExist(table string, item interface{}, pkAttrs []string) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxPutIfNotExistRaw(table string, item map[string]*dynamodb.AttributeValue, pkAttrs []string) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxPutRaw(table string, item map[string]*dynamodb.AttributeValue, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxRemoveAttributes(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxSetAttributes(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxUpdate(table string, keyFilter map[string]interface{}, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildTxUpdateRaw(table string, key map[string]*dynamodb.AttributeValue, ...) (*dynamodb.TransactWriteItem, error) + func (adc *AwsDynamodbConnect) BuildUpdateItemInput(table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemInput, error) + func (adc *AwsDynamodbConnect) Close() error + func (adc *AwsDynamodbConnect) CreateGlobalSecondaryIndex(ctx aws.Context, table, indexName string, rcu, wcu int64, ...) error + func (adc *AwsDynamodbConnect) CreateGlobalSecondaryIndexWithAction(ctx aws.Context, tableName string, attrDefs []AwsDynamodbNameAndType, ...) error + func (adc *AwsDynamodbConnect) CreateTable(ctx aws.Context, table string, rcu, wcu int64, ...) error + func (adc *AwsDynamodbConnect) DeleteGlobalSecondaryIndex(ctx aws.Context, table, indexName string) error + func (adc *AwsDynamodbConnect) DeleteItem(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.DeleteItemOutput, error) + func (adc *AwsDynamodbConnect) DeleteItemWithInput(ctx aws.Context, input *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error) + func (adc *AwsDynamodbConnect) DeleteTable(ctx aws.Context, table string) error + func (adc *AwsDynamodbConnect) DeleteValuesFromSet(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) ExecTxGetItems(ctx aws.Context, input *dynamodb.TransactGetItemsInput) (*dynamodb.TransactGetItemsOutput, error) + func (adc *AwsDynamodbConnect) ExecTxWriteItems(ctx aws.Context, input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, error) + func (adc *AwsDynamodbConnect) GetDb() *dynamodb.DynamoDB + func (adc *AwsDynamodbConnect) GetDbProxy() *DynamoDbProxy + func (adc *AwsDynamodbConnect) GetGlobalSecondaryIndexStatus(ctx aws.Context, table, indexName string) (string, error) + func (adc *AwsDynamodbConnect) GetItem(ctx aws.Context, table string, keyFilter map[string]interface{}) (AwsDynamodbItem, error) + func (adc *AwsDynamodbConnect) GetItemWithInput(ctx aws.Context, input *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error) + func (adc *AwsDynamodbConnect) GetTableStatus(ctx aws.Context, table string) (string, error) + func (adc *AwsDynamodbConnect) HasTable(ctx aws.Context, table string) (bool, error) + func (adc *AwsDynamodbConnect) Init() error + func (adc *AwsDynamodbConnect) ListTables(ctx aws.Context) ([]string, error) + func (adc *AwsDynamodbConnect) LogMetrics(category string, cmd *prom.CmdExecInfo) error + func (adc *AwsDynamodbConnect) Metrics(category string, opts ...prom.MetricsOpts) (*prom.Metrics, error) + func (adc *AwsDynamodbConnect) MetricsLogger() prom.IMetricsLogger + func (adc *AwsDynamodbConnect) NewCmdExecInfo() *prom.CmdExecInfo + func (adc *AwsDynamodbConnect) NewContext(timeoutMs ...int) (aws.Context, context.CancelFunc) + func (adc *AwsDynamodbConnect) PutItem(ctx aws.Context, table string, item interface{}, ...) (*dynamodb.PutItemOutput, error) + func (adc *AwsDynamodbConnect) PutItemIfNotExist(ctx aws.Context, table string, item interface{}, pkAttrs []string) (*dynamodb.PutItemOutput, error) + func (adc *AwsDynamodbConnect) PutItemIfNotExistRaw(ctx aws.Context, table string, item map[string]*dynamodb.AttributeValue, ...) (*dynamodb.PutItemOutput, error) + func (adc *AwsDynamodbConnect) PutItemRaw(ctx aws.Context, table string, item map[string]*dynamodb.AttributeValue, ...) (*dynamodb.PutItemOutput, error) + func (adc *AwsDynamodbConnect) PutItemWithInput(ctx aws.Context, input *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error) + func (adc *AwsDynamodbConnect) QueryItems(ctx aws.Context, table string, ...) ([]AwsDynamodbItem, error) + func (adc *AwsDynamodbConnect) QueryItemsWithCallback(ctx aws.Context, table string, ...) error + func (adc *AwsDynamodbConnect) QueryWithInput(ctx aws.Context, input *dynamodb.QueryInput) ([]AwsDynamodbItem, error) + func (adc *AwsDynamodbConnect) QueryWithInputCallback(ctx aws.Context, input *dynamodb.QueryInput, callback AwsDynamodbItemCallback) error + func (adc *AwsDynamodbConnect) RegisterMetricsLogger(metricsLogger prom.IMetricsLogger) *AwsDynamodbConnect + func (adc *AwsDynamodbConnect) RemoveAttributes(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) ScanItems(ctx aws.Context, table string, filter *expression.ConditionBuilder, ...) ([]AwsDynamodbItem, error) + func (adc *AwsDynamodbConnect) ScanItemsWithCallback(ctx aws.Context, table string, filter *expression.ConditionBuilder, ...) error + func (adc *AwsDynamodbConnect) ScanWithInput(ctx aws.Context, input *dynamodb.ScanInput) ([]AwsDynamodbItem, error) + func (adc *AwsDynamodbConnect) ScanWithInputCallback(ctx aws.Context, input *dynamodb.ScanInput, callback AwsDynamodbItemCallback) error + func (adc *AwsDynamodbConnect) SetAttributes(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) UpdateItem(ctx aws.Context, table string, keyFilter map[string]interface{}, ...) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) UpdateItemWithInput(ctx aws.Context, input *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error) + func (adc *AwsDynamodbConnect) WrapTxGetItems(ctx aws.Context, items ...*dynamodb.TransactGetItem) ([]AwsDynamodbItem, error) + func (adc *AwsDynamodbConnect) WrapTxWriteItems(ctx aws.Context, clientRequestToken string, ...) (*dynamodb.TransactWriteItemsOutput, error) + type AwsDynamodbItem map[string]interface + type AwsDynamodbItemCallback func(item AwsDynamodbItem, lastEvaluatedKey map[string]*dynamodb.AttributeValue) (bool, error) + type AwsDynamodbNameAndType struct + Name string + Type string + type AwsQueryOpt struct + ScanIndexBackward *bool + type DynamoDbProxy struct + func (dp *DynamoDbProxy) BatchExecuteStatement(input *dynamodb.BatchExecuteStatementInput) (*dynamodb.BatchExecuteStatementOutput, error) + func (dp *DynamoDbProxy) BatchExecuteStatementWithContext(ctx aws.Context, input *dynamodb.BatchExecuteStatementInput, ...) (*dynamodb.BatchExecuteStatementOutput, error) + func (dp *DynamoDbProxy) BatchGetItem(input *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error) + func (dp *DynamoDbProxy) BatchGetItemPages(input *dynamodb.BatchGetItemInput, ...) error + func (dp *DynamoDbProxy) BatchGetItemPagesWithContext(ctx aws.Context, input *dynamodb.BatchGetItemInput, ...) error + func (dp *DynamoDbProxy) BatchGetItemWithContext(ctx aws.Context, input *dynamodb.BatchGetItemInput, opts ...request.Option) (*dynamodb.BatchGetItemOutput, error) + func (dp *DynamoDbProxy) BatchWriteItem(input *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error) + func (dp *DynamoDbProxy) BatchWriteItemWithContext(ctx aws.Context, input *dynamodb.BatchWriteItemInput, opts ...request.Option) (*dynamodb.BatchWriteItemOutput, error) + func (dp *DynamoDbProxy) CreateBackup(input *dynamodb.CreateBackupInput) (*dynamodb.CreateBackupOutput, error) + func (dp *DynamoDbProxy) CreateBackupWithContext(ctx aws.Context, input *dynamodb.CreateBackupInput, opts ...request.Option) (*dynamodb.CreateBackupOutput, error) + func (dp *DynamoDbProxy) CreateGlobalTable(input *dynamodb.CreateGlobalTableInput) (*dynamodb.CreateGlobalTableOutput, error) + func (dp *DynamoDbProxy) CreateGlobalTableWithContext(ctx aws.Context, input *dynamodb.CreateGlobalTableInput, ...) (*dynamodb.CreateGlobalTableOutput, error) + func (dp *DynamoDbProxy) CreateTable(input *dynamodb.CreateTableInput) (*dynamodb.CreateTableOutput, error) + func (dp *DynamoDbProxy) CreateTableWithContext(ctx aws.Context, input *dynamodb.CreateTableInput, opts ...request.Option) (*dynamodb.CreateTableOutput, error) + func (dp *DynamoDbProxy) DeleteBackup(input *dynamodb.DeleteBackupInput) (*dynamodb.DeleteBackupOutput, error) + func (dp *DynamoDbProxy) DeleteBackupWithContext(ctx aws.Context, input *dynamodb.DeleteBackupInput, opts ...request.Option) (*dynamodb.DeleteBackupOutput, error) + func (dp *DynamoDbProxy) DeleteItem(input *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error) + func (dp *DynamoDbProxy) DeleteItemWithContext(ctx aws.Context, input *dynamodb.DeleteItemInput, opts ...request.Option) (*dynamodb.DeleteItemOutput, error) + func (dp *DynamoDbProxy) DeleteTable(input *dynamodb.DeleteTableInput) (*dynamodb.DeleteTableOutput, error) + func (dp *DynamoDbProxy) DeleteTableWithContext(ctx aws.Context, input *dynamodb.DeleteTableInput, opts ...request.Option) (*dynamodb.DeleteTableOutput, error) + func (dp *DynamoDbProxy) DescribeBackup(input *dynamodb.DescribeBackupInput) (*dynamodb.DescribeBackupOutput, error) + func (dp *DynamoDbProxy) DescribeBackupWithContext(ctx aws.Context, input *dynamodb.DescribeBackupInput, opts ...request.Option) (*dynamodb.DescribeBackupOutput, error) + func (dp *DynamoDbProxy) DescribeContinuousBackups(input *dynamodb.DescribeContinuousBackupsInput) (*dynamodb.DescribeContinuousBackupsOutput, error) + func (dp *DynamoDbProxy) DescribeContinuousBackupsWithContext(ctx aws.Context, input *dynamodb.DescribeContinuousBackupsInput, ...) (*dynamodb.DescribeContinuousBackupsOutput, error) + func (dp *DynamoDbProxy) DescribeContributorInsights(input *dynamodb.DescribeContributorInsightsInput) (*dynamodb.DescribeContributorInsightsOutput, error) + func (dp *DynamoDbProxy) DescribeContributorInsightsWithContext(ctx aws.Context, input *dynamodb.DescribeContributorInsightsInput, ...) (*dynamodb.DescribeContributorInsightsOutput, error) + func (dp *DynamoDbProxy) DescribeEndpoints(input *dynamodb.DescribeEndpointsInput) (*dynamodb.DescribeEndpointsOutput, error) + func (dp *DynamoDbProxy) DescribeEndpointsWithContext(ctx aws.Context, input *dynamodb.DescribeEndpointsInput, ...) (*dynamodb.DescribeEndpointsOutput, error) + func (dp *DynamoDbProxy) DescribeExport(input *dynamodb.DescribeExportInput) (*dynamodb.DescribeExportOutput, error) + func (dp *DynamoDbProxy) DescribeExportWithContext(ctx aws.Context, input *dynamodb.DescribeExportInput, opts ...request.Option) (*dynamodb.DescribeExportOutput, error) + func (dp *DynamoDbProxy) DescribeGlobalTable(input *dynamodb.DescribeGlobalTableInput) (*dynamodb.DescribeGlobalTableOutput, error) + func (dp *DynamoDbProxy) DescribeGlobalTableSettings(input *dynamodb.DescribeGlobalTableSettingsInput) (*dynamodb.DescribeGlobalTableSettingsOutput, error) + func (dp *DynamoDbProxy) DescribeGlobalTableSettingsWithContext(ctx aws.Context, input *dynamodb.DescribeGlobalTableSettingsInput, ...) (*dynamodb.DescribeGlobalTableSettingsOutput, error) + func (dp *DynamoDbProxy) DescribeGlobalTableWithContext(ctx aws.Context, input *dynamodb.DescribeGlobalTableInput, ...) (*dynamodb.DescribeGlobalTableOutput, error) + func (dp *DynamoDbProxy) DescribeKinesisStreamingDestination(input *dynamodb.DescribeKinesisStreamingDestinationInput) (*dynamodb.DescribeKinesisStreamingDestinationOutput, error) + func (dp *DynamoDbProxy) DescribeKinesisStreamingDestinationWithContext(ctx aws.Context, input *dynamodb.DescribeKinesisStreamingDestinationInput, ...) (*dynamodb.DescribeKinesisStreamingDestinationOutput, error) + func (dp *DynamoDbProxy) DescribeLimits(input *dynamodb.DescribeLimitsInput) (*dynamodb.DescribeLimitsOutput, error) + func (dp *DynamoDbProxy) DescribeLimitsWithContext(ctx aws.Context, input *dynamodb.DescribeLimitsInput, opts ...request.Option) (*dynamodb.DescribeLimitsOutput, error) + func (dp *DynamoDbProxy) DescribeTable(input *dynamodb.DescribeTableInput) (*dynamodb.DescribeTableOutput, error) + func (dp *DynamoDbProxy) DescribeTableReplicaAutoScaling(input *dynamodb.DescribeTableReplicaAutoScalingInput) (*dynamodb.DescribeTableReplicaAutoScalingOutput, error) + func (dp *DynamoDbProxy) DescribeTableReplicaAutoScalingWithContext(ctx aws.Context, input *dynamodb.DescribeTableReplicaAutoScalingInput, ...) (*dynamodb.DescribeTableReplicaAutoScalingOutput, error) + func (dp *DynamoDbProxy) DescribeTableWithContext(ctx aws.Context, input *dynamodb.DescribeTableInput, opts ...request.Option) (*dynamodb.DescribeTableOutput, error) + func (dp *DynamoDbProxy) DescribeTimeToLive(input *dynamodb.DescribeTimeToLiveInput) (*dynamodb.DescribeTimeToLiveOutput, error) + func (dp *DynamoDbProxy) DescribeTimeToLiveWithContext(ctx aws.Context, input *dynamodb.DescribeTimeToLiveInput, ...) (*dynamodb.DescribeTimeToLiveOutput, error) + func (dp *DynamoDbProxy) DisableKinesisStreamingDestination(input *dynamodb.DisableKinesisStreamingDestinationInput) (*dynamodb.DisableKinesisStreamingDestinationOutput, error) + func (dp *DynamoDbProxy) DisableKinesisStreamingDestinationWithContext(ctx aws.Context, input *dynamodb.DisableKinesisStreamingDestinationInput, ...) (*dynamodb.DisableKinesisStreamingDestinationOutput, error) + func (dp *DynamoDbProxy) EnableKinesisStreamingDestination(input *dynamodb.EnableKinesisStreamingDestinationInput) (*dynamodb.EnableKinesisStreamingDestinationOutput, error) + func (dp *DynamoDbProxy) EnableKinesisStreamingDestinationWithContext(ctx aws.Context, input *dynamodb.EnableKinesisStreamingDestinationInput, ...) (*dynamodb.EnableKinesisStreamingDestinationOutput, error) + func (dp *DynamoDbProxy) ExecuteStatement(input *dynamodb.ExecuteStatementInput) (*dynamodb.ExecuteStatementOutput, error) + func (dp *DynamoDbProxy) ExecuteStatementWithContext(ctx aws.Context, input *dynamodb.ExecuteStatementInput, opts ...request.Option) (*dynamodb.ExecuteStatementOutput, error) + func (dp *DynamoDbProxy) ExecuteTransaction(input *dynamodb.ExecuteTransactionInput) (*dynamodb.ExecuteTransactionOutput, error) + func (dp *DynamoDbProxy) ExecuteTransactionWithContext(ctx aws.Context, input *dynamodb.ExecuteTransactionInput, ...) (*dynamodb.ExecuteTransactionOutput, error) + func (dp *DynamoDbProxy) ExportTableToPointInTime(input *dynamodb.ExportTableToPointInTimeInput) (*dynamodb.ExportTableToPointInTimeOutput, error) + func (dp *DynamoDbProxy) ExportTableToPointInTimeWithContext(ctx aws.Context, input *dynamodb.ExportTableToPointInTimeInput, ...) (*dynamodb.ExportTableToPointInTimeOutput, error) + func (dp *DynamoDbProxy) GetItem(input *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error) + func (dp *DynamoDbProxy) GetItemWithContext(ctx aws.Context, input *dynamodb.GetItemInput, opts ...request.Option) (*dynamodb.GetItemOutput, error) + func (dp *DynamoDbProxy) ListBackups(input *dynamodb.ListBackupsInput) (*dynamodb.ListBackupsOutput, error) + func (dp *DynamoDbProxy) ListBackupsWithContext(ctx aws.Context, input *dynamodb.ListBackupsInput, opts ...request.Option) (*dynamodb.ListBackupsOutput, error) + func (dp *DynamoDbProxy) ListContributorInsights(input *dynamodb.ListContributorInsightsInput) (*dynamodb.ListContributorInsightsOutput, error) + func (dp *DynamoDbProxy) ListContributorInsightsPages(input *dynamodb.ListContributorInsightsInput, ...) error + func (dp *DynamoDbProxy) ListContributorInsightsPagesWithContext(ctx aws.Context, input *dynamodb.ListContributorInsightsInput, ...) error + func (dp *DynamoDbProxy) ListContributorInsightsWithContext(ctx aws.Context, input *dynamodb.ListContributorInsightsInput, ...) (*dynamodb.ListContributorInsightsOutput, error) + func (dp *DynamoDbProxy) ListExports(input *dynamodb.ListExportsInput) (*dynamodb.ListExportsOutput, error) + func (dp *DynamoDbProxy) ListExportsPages(input *dynamodb.ListExportsInput, ...) error + func (dp *DynamoDbProxy) ListExportsPagesWithContext(ctx aws.Context, input *dynamodb.ListExportsInput, ...) error + func (dp *DynamoDbProxy) ListExportsWithContext(ctx aws.Context, input *dynamodb.ListExportsInput, opts ...request.Option) (*dynamodb.ListExportsOutput, error) + func (dp *DynamoDbProxy) ListGlobalTables(input *dynamodb.ListGlobalTablesInput) (*dynamodb.ListGlobalTablesOutput, error) + func (dp *DynamoDbProxy) ListGlobalTablesWithContext(ctx aws.Context, input *dynamodb.ListGlobalTablesInput, opts ...request.Option) (*dynamodb.ListGlobalTablesOutput, error) + func (dp *DynamoDbProxy) ListTables(input *dynamodb.ListTablesInput) (*dynamodb.ListTablesOutput, error) + func (dp *DynamoDbProxy) ListTablesPages(input *dynamodb.ListTablesInput, ...) error + func (dp *DynamoDbProxy) ListTablesPagesWithContext(ctx aws.Context, input *dynamodb.ListTablesInput, ...) error + func (dp *DynamoDbProxy) ListTablesWithContext(ctx aws.Context, input *dynamodb.ListTablesInput, opts ...request.Option) (*dynamodb.ListTablesOutput, error) + func (dp *DynamoDbProxy) ListTagsOfResource(input *dynamodb.ListTagsOfResourceInput) (*dynamodb.ListTagsOfResourceOutput, error) + func (dp *DynamoDbProxy) ListTagsOfResourceWithContext(ctx aws.Context, input *dynamodb.ListTagsOfResourceInput, ...) (*dynamodb.ListTagsOfResourceOutput, error) + func (dp *DynamoDbProxy) PutItem(input *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error) + func (dp *DynamoDbProxy) PutItemWithContext(ctx aws.Context, input *dynamodb.PutItemInput, opts ...request.Option) (*dynamodb.PutItemOutput, error) + func (dp *DynamoDbProxy) Query(input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error) + func (dp *DynamoDbProxy) QueryPages(input *dynamodb.QueryInput, fn func(*dynamodb.QueryOutput, bool) bool) error + func (dp *DynamoDbProxy) QueryPagesWithContext(ctx aws.Context, input *dynamodb.QueryInput, ...) error + func (dp *DynamoDbProxy) QueryWithContext(ctx aws.Context, input *dynamodb.QueryInput, opts ...request.Option) (*dynamodb.QueryOutput, error) + func (dp *DynamoDbProxy) RestoreTableFromBackup(input *dynamodb.RestoreTableFromBackupInput) (*dynamodb.RestoreTableFromBackupOutput, error) + func (dp *DynamoDbProxy) RestoreTableFromBackupWithContext(ctx aws.Context, input *dynamodb.RestoreTableFromBackupInput, ...) (*dynamodb.RestoreTableFromBackupOutput, error) + func (dp *DynamoDbProxy) RestoreTableToPointInTime(input *dynamodb.RestoreTableToPointInTimeInput) (*dynamodb.RestoreTableToPointInTimeOutput, error) + func (dp *DynamoDbProxy) RestoreTableToPointInTimeWithContext(ctx aws.Context, input *dynamodb.RestoreTableToPointInTimeInput, ...) (*dynamodb.RestoreTableToPointInTimeOutput, error) + func (dp *DynamoDbProxy) Scan(input *dynamodb.ScanInput) (*dynamodb.ScanOutput, error) + func (dp *DynamoDbProxy) ScanPages(input *dynamodb.ScanInput, fn func(*dynamodb.ScanOutput, bool) bool) error + func (dp *DynamoDbProxy) ScanPagesWithContext(ctx aws.Context, input *dynamodb.ScanInput, ...) error + func (dp *DynamoDbProxy) ScanWithContext(ctx aws.Context, input *dynamodb.ScanInput, opts ...request.Option) (*dynamodb.ScanOutput, error) + func (dp *DynamoDbProxy) TagResource(input *dynamodb.TagResourceInput) (*dynamodb.TagResourceOutput, error) + func (dp *DynamoDbProxy) TagResourceWithContext(ctx aws.Context, input *dynamodb.TagResourceInput, opts ...request.Option) (*dynamodb.TagResourceOutput, error) + func (dp *DynamoDbProxy) TransactGetItems(input *dynamodb.TransactGetItemsInput) (*dynamodb.TransactGetItemsOutput, error) + func (dp *DynamoDbProxy) TransactGetItemsWithContext(ctx aws.Context, input *dynamodb.TransactGetItemsInput, opts ...request.Option) (*dynamodb.TransactGetItemsOutput, error) + func (dp *DynamoDbProxy) TransactWriteItems(input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, error) + func (dp *DynamoDbProxy) TransactWriteItemsWithContext(ctx aws.Context, input *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error) + func (dp *DynamoDbProxy) UntagResource(input *dynamodb.UntagResourceInput) (*dynamodb.UntagResourceOutput, error) + func (dp *DynamoDbProxy) UntagResourceWithContext(ctx aws.Context, input *dynamodb.UntagResourceInput, opts ...request.Option) (*dynamodb.UntagResourceOutput, error) + func (dp *DynamoDbProxy) UpdateContinuousBackups(input *dynamodb.UpdateContinuousBackupsInput) (*dynamodb.UpdateContinuousBackupsOutput, error) + func (dp *DynamoDbProxy) UpdateContinuousBackupsWithContext(ctx aws.Context, input *dynamodb.UpdateContinuousBackupsInput, ...) (*dynamodb.UpdateContinuousBackupsOutput, error) + func (dp *DynamoDbProxy) UpdateContributorInsights(input *dynamodb.UpdateContributorInsightsInput) (*dynamodb.UpdateContributorInsightsOutput, error) + func (dp *DynamoDbProxy) UpdateContributorInsightsWithContext(ctx aws.Context, input *dynamodb.UpdateContributorInsightsInput, ...) (*dynamodb.UpdateContributorInsightsOutput, error) + func (dp *DynamoDbProxy) UpdateGlobalTable(input *dynamodb.UpdateGlobalTableInput) (*dynamodb.UpdateGlobalTableOutput, error) + func (dp *DynamoDbProxy) UpdateGlobalTableSettings(input *dynamodb.UpdateGlobalTableSettingsInput) (*dynamodb.UpdateGlobalTableSettingsOutput, error) + func (dp *DynamoDbProxy) UpdateGlobalTableSettingsWithContext(ctx aws.Context, input *dynamodb.UpdateGlobalTableSettingsInput, ...) (*dynamodb.UpdateGlobalTableSettingsOutput, error) + func (dp *DynamoDbProxy) UpdateGlobalTableWithContext(ctx aws.Context, input *dynamodb.UpdateGlobalTableInput, ...) (*dynamodb.UpdateGlobalTableOutput, error) + func (dp *DynamoDbProxy) UpdateItem(input *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error) + func (dp *DynamoDbProxy) UpdateItemWithContext(ctx aws.Context, input *dynamodb.UpdateItemInput, opts ...request.Option) (*dynamodb.UpdateItemOutput, error) + func (dp *DynamoDbProxy) UpdateTable(input *dynamodb.UpdateTableInput) (*dynamodb.UpdateTableOutput, error) + func (dp *DynamoDbProxy) UpdateTableReplicaAutoScaling(input *dynamodb.UpdateTableReplicaAutoScalingInput) (*dynamodb.UpdateTableReplicaAutoScalingOutput, error) + func (dp *DynamoDbProxy) UpdateTableReplicaAutoScalingWithContext(ctx aws.Context, input *dynamodb.UpdateTableReplicaAutoScalingInput, ...) (*dynamodb.UpdateTableReplicaAutoScalingOutput, error) + func (dp *DynamoDbProxy) UpdateTableWithContext(ctx aws.Context, input *dynamodb.UpdateTableInput, opts ...request.Option) (*dynamodb.UpdateTableOutput, error) + func (dp *DynamoDbProxy) UpdateTimeToLive(input *dynamodb.UpdateTimeToLiveInput) (*dynamodb.UpdateTimeToLiveOutput, error) + func (dp *DynamoDbProxy) UpdateTimeToLiveWithContext(ctx aws.Context, input *dynamodb.UpdateTimeToLiveInput, opts ...request.Option) (*dynamodb.UpdateTimeToLiveOutput, error)
Go to main page