dyno

package module

Go to main page

Versions in this module

v1

v1.2.4

Jul 31, 2021

v1.2.3

Jul 29, 2021

v1.2.2

Jul 29, 2021

v1.2.1

Jul 28, 2021

v1.2.0

Jul 21, 2021

Changes in this version

type Session

+ func (s *Session) WithContext(ctx context.Context) *Session

v1.1.12

Apr 23, 2021

retracted

v1.1.1

Jul 13, 2021

retracted

v1.1.0

Jul 13, 2021

retracted

Changes in this version

type GSI

+ IndexName string

+ PartitionKey *ddb.AttributeDefinition

+ Projection []string

+ ProvisionedThroughput *ddb.ProvisionedThroughput

+ SortKey *ddb.AttributeDefinition

+ func (g *GSI) GetDynamoGlobalSecondaryIndex() ddb.GlobalSecondaryIndex

+ func (g *GSI) GetDynamoKeySchema() []ddb.KeySchemaElement

+ func (g *GSI) GetDynamoProjection() *ddb.Projection

+ func (g *GSI) SetName(name string) *GSI

+ func (g *GSI) SetPartitionKeyAttributeDefinition(def *ddb.AttributeDefinition) *GSI

+ func (g *GSI) SetSortKeyAttributeDefinition(def *ddb.AttributeDefinition) *GSI

type LSI

+ IndexName string

+ PartitionKey *ddb.AttributeDefinition

+ Projection []string

+ SortKey *ddb.AttributeDefinition

+ func (l *LSI) GetDynamoKeySchema() []ddb.KeySchemaElement

+ func (l *LSI) GetDynamoLocalSecondaryIndex() ddb.LocalSecondaryIndex

+ func (l *LSI) GetDynamoProjection() *ddb.Projection

+ func (l *LSI) SetName(name string) *LSI

+ func (l *LSI) SetPartitionKeyAttributeDefinition(def *ddb.AttributeDefinition) *LSI

+ func (l *LSI) SetSortKeyAttributeDefinition(def *ddb.AttributeDefinition) *LSI

type Table

+ func (t *Table) SetPartitionKeyAttributeDefinition(def *ddbTypes.AttributeDefinition) *Table

+ func (t *Table) SetSortKeyAttributeDefinition(def *ddbTypes.AttributeDefinition) *Table

v1.0.1

Jul 12, 2021

v1.0.0

Jul 12, 2021

v0

v0.2.11

Jul 8, 2021

Changes in this version

+ const ErrAlreadyDone

+ func CopyItemCollectionMetrics(input ddbTypes.ItemCollectionMetrics) ddbTypes.ItemCollectionMetrics

+ func CopyListBackupsInput(input *ddb.ListBackupsInput) *ddb.ListBackupsInput

+ func CopyListGlobalTablesInput(input *ddb.ListGlobalTablesInput) *ddb.ListGlobalTablesInput

+ func CopyListTablesInput(input *ddb.ListTablesInput) *ddb.ListTablesInput

+ func CopyListTagsOfResourceInput(input *ddb.ListTagsOfResourceInput) *ddb.ListTagsOfResourceInput

+ func NewExportTableToPointInTimeInput(bucket, tableArn string) *ddb.ExportTableToPointInTimeInput

+ type BaseOperation struct

+ func NewOperation() *BaseOperation

+ func (p *BaseOperation) Await() (interface{}, error)

+ func (p *BaseOperation) Done() <-chan struct{}

+ func (p *BaseOperation) Duration() time.Duration

+ func (p *BaseOperation) GetResponse() (interface{}, error)

+ func (p *BaseOperation) GetState() OperationState

+ func (p *BaseOperation) ID() string

+ func (p *BaseOperation) SetResponse(val interface{}, err error)

+ func (p *BaseOperation) SetRunning()

+ func (p *BaseOperation) SetState(state OperationState)

type BatchExecuteStatement

+ Handler BatchExecuteStatementHandler

+ func (op *BatchExecuteStatement) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type BatchGetItem

+ Handler BatchGetItemHandler

+ func (op *BatchGetItem) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type BatchGetItemAllFinalHandler

+ func (h *BatchGetItemAllFinalHandler) HandleBatchGetItem(ctx *BatchGetItemContext, output *BatchGetItemOutput)

type BatchWriteItem

+ Handler BatchWriteItemHandler

+ func (op *BatchWriteItem) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type BatchWriteItemAllFinalHandler

+ func (h *BatchWriteItemAllFinalHandler) HandleBatchWriteItem(ctx *BatchWriteItemContext, output *BatchWriteItemOutput)

type CreateBackup

+ func (op *CreateBackup) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type CreateGlobalTable

+ func (op *CreateGlobalTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type CreateTable

+ func (op *CreateTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DeleteBackup

+ func (op *DeleteBackup) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DeleteItem

+ func (op *DeleteItem) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DeleteTable

+ func (op *DeleteTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeBackup

+ func (op *DescribeBackup) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeContinuousBackups

+ func (op *DescribeContinuousBackups) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeContributorInsights

+ func (op *DescribeContributorInsights) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeEndpoints

+ func (op *DescribeEndpoints) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeExport

+ func (op *DescribeExport) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeGlobalTable

+ func (op *DescribeGlobalTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeGlobalTableSettings

+ func (op *DescribeGlobalTableSettings) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeKinesisStreamingDestination

+ func (op *DescribeKinesisStreamingDestination) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeLimits

+ func (op *DescribeLimits) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeTable

+ func (op *DescribeTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeTableReplicaAutoScaling

+ func (op *DescribeTableReplicaAutoScaling) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DescribeTimeToLive

+ func (op *DescribeTimeToLive) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type DisableKinesisStreamingDestination

+ func (op *DisableKinesisStreamingDestination) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type EnableKinesisStreamingDestination

+ func (op *EnableKinesisStreamingDestination) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ExecuteStatement

+ func (op *ExecuteStatement) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ExecuteTransaction

+ func (op *ExecuteTransaction) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ExportTableToPointInTime

+ func (op *ExportTableToPointInTime) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type GetItem

+ func (op *GetItem) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

+ type ListAllBackupsFinalHandler struct

+ func (h *ListAllBackupsFinalHandler) HandleListBackups(ctx *ListBackupsContext, output *ListBackupsOutput)

+ type ListAllGlobalTablesFinalHandler struct

+ func (h *ListAllGlobalTablesFinalHandler) HandleListGlobalTables(ctx *ListGlobalTablesContext, output *ListGlobalTablesOutput)

+ type ListAllTablesFinalHandler struct

+ func (h *ListAllTablesFinalHandler) HandleListTables(ctx *ListTablesContext, output *ListTablesOutput)

+ type ListAllTagsOfResourceFinalHandler struct

+ func (h *ListAllTagsOfResourceFinalHandler) HandleListTagsOfResource(ctx *ListTagsOfResourceContext, output *ListTagsOfResourceOutput)

type ListBackups

+ func NewListAllBackups(input *ddb.ListBackupsInput, mws ...ListBackupsMiddleWare) *ListBackups

+ func (op *ListBackups) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ListContributorInsights

+ func (op *ListContributorInsights) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ListExports

+ func (op *ListExports) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ListGlobalTables

+ Handler ListGlobalTablesHandler

+ func NewListAllGlobalTables(input *ddb.ListGlobalTablesInput, mws ...ListGlobalTablesMiddleWare) *ListGlobalTables

+ func (op *ListGlobalTables) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ListTables

+ Handler ListTablesHandler

+ func NewListAllTables(input *ddb.ListTablesInput, mws ...ListTablesMiddleWare) *ListTables

+ func (op *ListTables) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ListTagsOfResource

+ Handler ListTagsOfResourceHandler

+ func NewListAllTagsOfResource(input *ddb.ListTagsOfResourceInput, mws ...ListTagsOfResourceMiddleWare) *ListTagsOfResource

+ func (op *ListTagsOfResource) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type Operation

+ InvokeDynoOperation func(ctx context.Context, client *ddb.Client)

+ SetResponse func(output interface{}, err error)

+ SetRunning func()

+ type OperationError string

+ func (e OperationError) Error() string

type OperationF

+ func (op OperationF) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

+ func (op OperationF) SetResponse(interface{}, error)

+ func (op OperationF) SetRunning()

+ type OperationState uint32

+ const OperationDone

+ const OperationPending

+ const OperationRunning

+ func (p OperationState) String() string

type Pool

+ func (p *Pool) ListAllBackups(input *ddb.ListBackupsInput, mw ...ListBackupsMiddleWare) *ListBackups

+ func (p *Pool) ListAllGlobalTables(input *ddb.ListGlobalTablesInput, mw ...ListGlobalTablesMiddleWare) *ListGlobalTables

+ func (p *Pool) ListAllTables(input *ddb.ListTablesInput, mw ...ListTablesMiddleWare) *ListTables

+ func (p *Pool) ListAllTagsOfResource(input *ddb.ListTagsOfResourceInput, mw ...ListTagsOfResourceMiddleWare) *ListTagsOfResource

type PutItem

+ func (op *PutItem) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type Query

+ Handler QueryHandler

+ func (op *Query) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type QueryAllFinalHandler

+ func (h *QueryAllFinalHandler) HandleQuery(ctx *QueryContext, output *QueryOutput)

type RestoreTableFromBackup

+ func (op *RestoreTableFromBackup) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type RestoreTableToPointInTime

+ func (op *RestoreTableToPointInTime) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type Scan

+ Handler ScanHandler

+ func (op *Scan) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type ScanAllFinalHandler

+ func (h *ScanAllFinalHandler) HandleScan(ctx *ScanContext, output *ScanOutput)

type Session

+ func NewSession(ctx context.Context, client *ddb.Client) *Session

+ func NewSessionWithConfig(ctx context.Context, config aws.Config, optFns ...func(*ddb.Options)) *Session

+ func (s *Session) BatchExecuteStatement(input *ddb.BatchExecuteStatementInput, mw ...BatchExecuteStatementMiddleWare) *BatchExecuteStatement

+ func (s *Session) BatchGetItem(ctx context.Context, input *ddb.BatchGetItemInput, ...) *BatchGetItem

+ func (s *Session) BatchGetItemAll(ctx context.Context, input *ddb.BatchGetItemInput, ...) *BatchGetItem

+ func (s *Session) BatchWriteItem(input *ddb.BatchWriteItemInput, mw ...BatchWriteItemMiddleWare) *BatchWriteItem

+ func (s *Session) BatchWriteItemAll(input *ddb.BatchWriteItemInput, mw ...BatchWriteItemMiddleWare) *BatchWriteItem

+ func (s *Session) CreateBackup(input *ddb.CreateBackupInput, mw ...CreateBackupMiddleWare) *CreateBackup

+ func (s *Session) CreateGlobalTable(input *ddb.CreateGlobalTableInput, mw ...CreateGlobalTableMiddleWare) *CreateGlobalTable

+ func (s *Session) CreateTable(input *ddb.CreateTableInput, mw ...CreateTableMiddleWare) *CreateTable

+ func (s *Session) DeleteBackup(input *ddb.DeleteBackupInput, mw ...DeleteBackupMiddleWare) *DeleteBackup

+ func (s *Session) DeleteItem(input *ddb.DeleteItemInput, mw ...DeleteItemMiddleWare) *DeleteItem

+ func (s *Session) DeleteTable(input *ddb.DeleteTableInput, mw ...DeleteTableMiddleWare) *DeleteTable

+ func (s *Session) DescribeBackup(input *ddb.DescribeBackupInput, mw ...DescribeBackupMiddleWare) *DescribeBackup

+ func (s *Session) DescribeContinuousBackups(input *ddb.DescribeContinuousBackupsInput, ...) *DescribeContinuousBackups

+ func (s *Session) DescribeContributorInsights(input *ddb.DescribeContributorInsightsInput, ...) *DescribeContributorInsights

+ func (s *Session) DescribeEndpoints(input *ddb.DescribeEndpointsInput, mw ...DescribeEndpointsMiddleWare) *DescribeEndpoints

+ func (s *Session) DescribeExport(input *ddb.DescribeExportInput, mw ...DescribeExportMiddleWare) *DescribeExport

+ func (s *Session) DescribeGlobalTable(input *ddb.DescribeGlobalTableInput, mw ...DescribeGlobalTableMiddleWare) *DescribeGlobalTable

+ func (s *Session) DescribeGlobalTableSettings(input *ddb.DescribeGlobalTableSettingsInput, ...) *DescribeGlobalTableSettings

+ func (s *Session) DescribeKinesisStreamingDestination(input *ddb.DescribeKinesisStreamingDestinationInput, ...) *DescribeKinesisStreamingDestination

+ func (s *Session) DescribeLimits(input *ddb.DescribeLimitsInput, mw ...DescribeLimitsMiddleWare) *DescribeLimits

+ func (s *Session) DescribeTable(input *ddb.DescribeTableInput, mw ...DescribeTableMiddleWare) *DescribeTable

+ func (s *Session) DescribeTableReplicaAutoScaling(input *ddb.DescribeTableReplicaAutoScalingInput, ...) *DescribeTableReplicaAutoScaling

+ func (s *Session) DescribeTimeToLive(input *ddb.DescribeTimeToLiveInput, mw ...DescribeTimeToLiveMiddleWare) *DescribeTimeToLive

+ func (s *Session) DisableKinesisStreamingDestination(input *ddb.DisableKinesisStreamingDestinationInput, ...) *DisableKinesisStreamingDestination

+ func (s *Session) Do(op Operation)

+ func (s *Session) DynamoDB() *ddb.Client

+ func (s *Session) EnableKinesisStreamingDestination(input *ddb.EnableKinesisStreamingDestinationInput, ...) *EnableKinesisStreamingDestination

+ func (s *Session) ExecuteStatement(input *ddb.ExecuteStatementInput, mw ...ExecuteStatementMiddleWare) *ExecuteStatement

+ func (s *Session) ExecuteTransaction(input *ddb.ExecuteTransactionInput, mw ...ExecuteTransactionMiddleWare) *ExecuteTransaction

+ func (s *Session) ExportTableToPointInTime(input *ddb.ExportTableToPointInTimeInput, ...) *ExportTableToPointInTime

+ func (s *Session) GetItem(input *ddb.GetItemInput, mw ...GetItemMiddleWare) *GetItem

+ func (s *Session) ListAllBackups(input *ddb.ListBackupsInput, mw ...ListBackupsMiddleWare) *ListBackups

+ func (s *Session) ListAllGlobalTables(input *ddb.ListGlobalTablesInput, mw ...ListGlobalTablesMiddleWare) *ListGlobalTables

+ func (s *Session) ListAllTables(input *ddb.ListTablesInput, mw ...ListTablesMiddleWare) *ListTables

+ func (s *Session) ListAllTagsOfResource(input *ddb.ListTagsOfResourceInput, mw ...ListTagsOfResourceMiddleWare) *ListTagsOfResource

+ func (s *Session) ListBackups(input *ddb.ListBackupsInput, mw ...ListBackupsMiddleWare) *ListBackups

+ func (s *Session) ListContributorInsights(input *ddb.ListContributorInsightsInput, ...) *ListContributorInsights

+ func (s *Session) ListExports(input *ddb.ListExportsInput, mw ...ListExportsMiddleWare) *ListExports

+ func (s *Session) ListGlobalTables(input *ddb.ListGlobalTablesInput, mw ...ListGlobalTablesMiddleWare) *ListGlobalTables

+ func (s *Session) ListTables(input *ddb.ListTablesInput, mw ...ListTablesMiddleWare) *ListTables

+ func (s *Session) ListTagsOfResource(input *ddb.ListTagsOfResourceInput, mw ...ListTagsOfResourceMiddleWare) *ListTagsOfResource

+ func (s *Session) PutItem(input *ddb.PutItemInput, mw ...PutItemMiddleWare) *PutItem

+ func (s *Session) Query(ctx context.Context, input *ddb.QueryInput, mw ...QueryMiddleWare) *Query

+ func (s *Session) QueryAll(ctx context.Context, input *ddb.QueryInput, mw ...QueryMiddleWare) *Query

+ func (s *Session) RestoreTableFromBackup(input *ddb.RestoreTableFromBackupInput, mw ...RestoreTableFromBackupMiddleWare) *RestoreTableFromBackup

+ func (s *Session) RestoreTableToPointInTime(input *ddb.RestoreTableToPointInTimeInput, ...) *RestoreTableToPointInTime

+ func (s *Session) Scan(ctx context.Context, input *ddb.ScanInput, mw ...ScanMiddleWare) *Scan

+ func (s *Session) ScanAll(input *ddb.ScanInput, mw ...ScanMiddleWare) *Scan

+ func (s *Session) TableExistsWaiter(input *ddb.DescribeTableInput, mw ...DescribeTableMiddleWare) *TableExistsWaiter

+ func (s *Session) TableNotExistsWaiter(input *ddb.DescribeTableInput, mw ...DescribeTableMiddleWare) *TableNotExistsWaiter

+ func (s *Session) TagResource(input *ddb.TagResourceInput, mw ...TagResourceMiddleWare) *TagResource

+ func (s *Session) TransactGetItems(input *ddb.TransactGetItemsInput, mw ...TransactGetItemsMiddleWare) *TransactGetItems

+ func (s *Session) TransactWriteItems(input *ddb.TransactWriteItemsInput, mw ...TransactWriteItemsMiddleWare) *TransactWriteItems

+ func (s *Session) UntagResource(input *ddb.UntagResourceInput, mw ...UntagResourceMiddleWare) *UntagResource

+ func (s *Session) UpdateContinuousBackups(input *ddb.UpdateContinuousBackupsInput, ...) *UpdateContinuousBackups

+ func (s *Session) UpdateContributorInsights(input *ddb.UpdateContributorInsightsInput, ...) *UpdateContributorInsights

+ func (s *Session) UpdateGlobalTable(input *ddb.UpdateGlobalTableInput, mw ...UpdateGlobalTableMiddleWare) *UpdateGlobalTable

+ func (s *Session) UpdateGlobalTableSettings(input *ddb.UpdateGlobalTableSettingsInput, ...) *UpdateGlobalTableSettings

+ func (s *Session) UpdateItem(input *ddb.UpdateItemInput, mw ...UpdateItemMiddleWare) *UpdateItem

+ func (s *Session) UpdateTable(input *ddb.UpdateTableInput, mw ...UpdateTableMiddleWare) *UpdateTable

+ func (s *Session) UpdateTableReplicaAutoScaling(input *ddb.UpdateTableReplicaAutoScalingInput, ...) *UpdateTableReplicaAutoScaling

+ func (s *Session) UpdateTimeToLive(input *ddb.UpdateTimeToLiveInput, mw ...UpdateTimeToLiveMiddleWare) *UpdateTimeToLive

type Table

+ func (t *Table) NewBatchGetBuilder(items []map[string]ddbTypes.AttributeValue, mws ...BatchGetItemMiddleWare) *BatchGetItemBuilder

+ func (t *Table) NewBatchWriteBuilder(puts []map[string]ddbTypes.AttributeValue, ...) *BatchWriteItemBuilder

type TableExistsWaiter

+ func (op *TableExistsWaiter) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type TableNotExistsWaiter

+ func (op *TableNotExistsWaiter) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type TagResource

+ func (op *TagResource) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type TransactGetItems

+ func (op *TransactGetItems) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type TransactWriteItems

+ func (op *TransactWriteItems) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UnmarshalMiddleWare

+ func (mw *UnmarshalMiddleWare) BatchGetItemMiddleWare(next BatchGetItemHandler) BatchGetItemHandler

type UntagResource

+ func (op *UntagResource) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateContinuousBackups

+ func (op *UpdateContinuousBackups) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateContributorInsights

+ func (op *UpdateContributorInsights) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateGlobalTable

+ func (op *UpdateGlobalTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateGlobalTableSettings

+ func (op *UpdateGlobalTableSettings) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateItem

+ func (op *UpdateItem) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateTable

+ func (op *UpdateTable) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateTableReplicaAutoScaling

+ func (op *UpdateTableReplicaAutoScaling) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

type UpdateTimeToLive

+ func (op *UpdateTimeToLive) InvokeDynoOperation(ctx context.Context, client *ddb.Client)

v0.2.10

Jul 8, 2021

Changes in this version

+ const ErrAlreadyWaiting

+ const ErrCannotAwait

+ const ErrResultAlreadySet

type Promise

+ func (p *Promise) GetState() PromiseState

+ func (p *Promise) SetState(state PromiseState)

+ func (p *Promise) SetWaiting()

+ type PromiseState uint32

+ const PromisePending

+ const PromiseReady

+ const PromiseWaiting

+ func (p PromiseState) String() string

type ScanAll

+ func (op *ScanAll) Await() ([]*ddb.ScanOutput, error)

v0.2.9

Jul 7, 2021

Changes in this version

type GetItemBuilder

+ func (bld *GetItemBuilder) AddProjection(names interface{}) *GetItemBuilder

type QueryBuilder

+ func (bld *QueryBuilder) AddProjection(names interface{}) *QueryBuilder

v0.2.8

Jul 7, 2021

v0.2.7

Jul 7, 2021

v0.2.6

Jul 7, 2021

Changes in this version

type UnmarshalMiddleWare

+ func (mw *UnmarshalMiddleWare) BatchGetItemAllMiddleWare(next BatchGetItemAllHandler) BatchGetItemAllHandler

+ func (mw *UnmarshalMiddleWare) GetItemMiddleWare(next GetItemHandler) GetItemHandler

+ func (mw *UnmarshalMiddleWare) QueryAllMiddleWare(next QueryAllHandler) QueryAllHandler

+ func (mw *UnmarshalMiddleWare) QueryMiddleWare(next QueryHandler) QueryHandler

+ func (mw *UnmarshalMiddleWare) ScanAllMiddleWare(next ScanAllHandler) ScanAllHandler

+ func (mw *UnmarshalMiddleWare) ScanMiddleWare(next ScanHandler) ScanHandler

v0.2.5

Jul 7, 2021

Changes in this version

+ type UnmarshalMiddleWare struct

+ Unmarshal func(m map[string]types.AttributeValue) error

+ UnmarshalSlice func(ms []map[string]types.AttributeValue) error

type Unmarshaler

+ func (mw *Unmarshaler) Unmarshal(av map[string]types.AttributeValue) error

+ func (mw *Unmarshaler) UnmarshalSlice(avs []map[string]types.AttributeValue) error

v0.2.4

Jul 2, 2021

v0.2.3

Jul 2, 2021

v0.2.2

Jul 2, 2021

Changes in this version

type BatchExecuteStatementContext

+ Client *ddb.Client

+ Input *ddb.BatchExecuteStatementInput

type BatchGetItemAllContext

+ Client *ddb.Client

+ Input *ddb.BatchGetItemInput

type BatchGetItemContext

+ Client *ddb.Client

+ Input *ddb.BatchGetItemInput

type BatchWriteItemAllContext

+ Client *ddb.Client

+ Input *ddb.BatchWriteItemInput

type BatchWriteItemContext

+ Client *ddb.Client

+ Input *ddb.BatchWriteItemInput

type CreateBackupContext

+ Client *ddb.Client

+ Input *ddb.CreateBackupInput

type CreateGlobalTableContext

+ Client *ddb.Client

+ Input *ddb.CreateGlobalTableInput

type CreateTableContext

+ Client *ddb.Client

+ Input *ddb.CreateTableInput

type DeleteBackupContext

+ Client *ddb.Client

+ Input *ddb.DeleteBackupInput

type DeleteItemContext

+ Client *ddb.Client

+ Input *ddb.DeleteItemInput

type DeleteTableContext

+ Client *ddb.Client

+ Input *ddb.DeleteTableInput

type DescribeBackupContext

+ Client *ddb.Client

+ Input *ddb.DescribeBackupInput

type DescribeContinuousBackupsContext

+ Client *ddb.Client

+ Input *ddb.DescribeContinuousBackupsInput

type DescribeContributorInsightsContext

+ Client *ddb.Client

+ Input *ddb.DescribeContributorInsightsInput

type DescribeEndpointsContext

+ Client *ddb.Client

+ Input *ddb.DescribeEndpointsInput

type DescribeExportContext

+ Client *ddb.Client

+ Input *ddb.DescribeExportInput

type DescribeGlobalTableContext

+ Client *ddb.Client

+ Input *ddb.DescribeGlobalTableInput

type DescribeGlobalTableSettingsContext

+ Client *ddb.Client

+ Input *ddb.DescribeGlobalTableSettingsInput

type DescribeKinesisStreamingDestinationContext

+ Client *ddb.Client

+ Input *ddb.DescribeKinesisStreamingDestinationInput

type DescribeLimitsContext

+ Client *ddb.Client

+ Input *ddb.DescribeLimitsInput

type DescribeTableContext

+ Client *ddb.Client

+ Input *ddb.DescribeTableInput

type DescribeTableReplicaAutoScalingContext

+ Client *ddb.Client

+ Input *ddb.DescribeTableReplicaAutoScalingInput

type DescribeTimeToLiveContext

+ Client *ddb.Client

+ Input *ddb.DescribeTimeToLiveInput

type DisableKinesisStreamingDestinationContext

+ Client *ddb.Client

+ Input *ddb.DisableKinesisStreamingDestinationInput

type EnableKinesisStreamingDestinationContext

+ Client *ddb.Client

+ Input *ddb.EnableKinesisStreamingDestinationInput

type ExecuteStatementContext

+ Client *ddb.Client

+ Input *ddb.ExecuteStatementInput

type ExecuteTransactionContext

+ Client *ddb.Client

+ Input *ddb.ExecuteTransactionInput

type ExportTableToPointInTimeContext

+ Client *ddb.Client

+ Input *ddb.ExportTableToPointInTimeInput

type GetItemContext

+ Client *ddb.Client

+ Input *ddb.GetItemInput

type ListBackupsContext

+ Client *ddb.Client

+ Input *ddb.ListBackupsInput

type ListContributorInsightsContext

+ Client *ddb.Client

+ Input *ddb.ListContributorInsightsInput

type ListExportsContext

+ Client *ddb.Client

+ Input *ddb.ListExportsInput

type ListGlobalTablesContext

+ Client *ddb.Client

+ Input *ddb.ListGlobalTablesInput

type ListTablesContext

+ Client *ddb.Client

+ Input *ddb.ListTablesInput

type ListTagsOfResourceContext

+ Client *ddb.Client

+ Input *ddb.ListTagsOfResourceInput

type PutItemContext

+ Client *ddb.Client

+ Input *ddb.PutItemInput

type QueryAllContext

+ Client *ddb.Client

+ Input *ddb.QueryInput

type QueryContext

+ Client *ddb.Client

+ Input *ddb.QueryInput

type RestoreTableFromBackupContext

+ Client *ddb.Client

+ Input *ddb.RestoreTableFromBackupInput

type RestoreTableToPointInTimeContext

+ Client *ddb.Client

+ Input *ddb.RestoreTableToPointInTimeInput

type ScanAllContext

+ Client *ddb.Client

+ Input *ddb.ScanInput

type ScanContext

+ Client *ddb.Client

+ Input *ddb.ScanInput

type TagResourceContext

+ Client *ddb.Client

+ Input *ddb.TagResourceInput

type TransactGetItemsContext

+ Client *ddb.Client

+ Input *ddb.TransactGetItemsInput

type TransactWriteItemsContext

+ Client *ddb.Client

+ Input *ddb.TransactWriteItemsInput

type UntagResourceContext

+ Client *ddb.Client

+ Input *ddb.UntagResourceInput

type UpdateContinuousBackupsContext

+ Client *ddb.Client

+ Input *ddb.UpdateContinuousBackupsInput

type UpdateContributorInsightsContext

+ Client *ddb.Client

+ Input *ddb.UpdateContributorInsightsInput

type UpdateGlobalTableContext

+ Client *ddb.Client

+ Input *ddb.UpdateGlobalTableInput

type UpdateGlobalTableSettingsContext

+ Client *ddb.Client

+ Input *ddb.UpdateGlobalTableSettingsInput

type UpdateItemContext

+ Client *ddb.Client

+ Input *ddb.UpdateItemInput

type UpdateTableContext

+ Client *ddb.Client

+ Input *ddb.UpdateTableInput

type UpdateTableReplicaAutoScalingContext

+ Client *ddb.Client

+ Input *ddb.UpdateTableReplicaAutoScalingInput

type UpdateTimeToLiveContext

+ Client *ddb.Client

+ Input *ddb.UpdateTimeToLiveInput

v0.2.1

Jun 29, 2021

v0.2.0

Jun 29, 2021

retracted

Changes in this version

+ const ErrResultNotSet

+ func ChunkBatchGetItemInputs(input *ddb.BatchGetItemInput, chunkSize int) (out []*ddb.BatchGetItemInput)

+ func CopyAttributeValue(av types.AttributeValue) types.AttributeValue

+ func CopyAttributeValueMap(input map[string]types.AttributeValue) map[string]types.AttributeValue

+ func CopyBatchGetItem(input *ddb.BatchGetItemInput) *ddb.BatchGetItemInput

+ func CopyBatchWriteItemInput(input *ddb.BatchWriteItemInput) *ddb.BatchWriteItemInput

+ func CopyCondition(cnd types.Condition) types.Condition

+ func CopyDeleteRequest(input *ddbTypes.DeleteRequest) *ddbTypes.DeleteRequest

+ func CopyKeysAndAttributes(input types.KeysAndAttributes) types.KeysAndAttributes

+ func CopyKeysAndAttributesMap(input map[string]types.KeysAndAttributes) map[string]types.KeysAndAttributes

+ func CopyPutRequest(input *ddbTypes.PutRequest) *ddbTypes.PutRequest

+ func CopyQuery(input *ddb.QueryInput) *ddb.QueryInput

+ func CopyScan(input *ddb.ScanInput) *ddb.ScanInput

+ func CopyWriteRequest(input ddbTypes.WriteRequest) ddbTypes.WriteRequest

+ func MustYamlString(in interface{}) string

+ func NewBatchGetItemInput() *ddb.BatchGetItemInput

+ func NewBatchWriteItemInput() *ddb.BatchWriteItemInput

+ func NewCreateBackupInput(tableName *string, backupArn *string) *ddb.CreateBackupInput

+ func NewDeleteBackupInput(backupArn *string) *ddb.DeleteBackupInput

+ func NewDeleteItemInput(tableName *string, key map[string]ddbTypes.AttributeValue) *ddb.DeleteItemInput

+ func NewDeleteTableInput(tableName *string) *ddb.DeleteTableInput

+ func NewDescribeBackupInput(backupArn *string) *ddb.DescribeBackupInput

+ func NewDescribeContinuousBackupsInput(tableName *string) *ddb.DescribeContinuousBackupsInput

+ func NewDescribeContributorInsightsInput(tableName *string, indexName *string) *ddb.DescribeContributorInsightsInput

+ func NewDescribeEndpointsInput() *ddb.DescribeEndpointsInput

+ func NewDescribeExportInput(exportArn *string) *ddb.DescribeExportInput

+ func NewDescribeGlobalTableInput(tableName *string) *ddb.DescribeGlobalTableInput

+ func NewDescribeGlobalTableSettingsInput(tableName *string) *ddb.DescribeGlobalTableSettingsInput

+ func NewDescribeKinesisStreamingDestinationInput(tableName *string) *ddb.DescribeKinesisStreamingDestinationInput

+ func NewDescribeLimitsInput() *ddb.DescribeLimitsInput

+ func NewDescribeTableInput(tableName *string) *ddb.DescribeTableInput

+ func NewDescribeTableReplicaAutoScalingInput(tableName *string) *ddb.DescribeTableReplicaAutoScalingInput

+ func NewDescribeTimeToLiveInput(tableName *string) *ddb.DescribeTimeToLiveInput

+ func NewDisableKinesisStreamingDestinationInput(tableName, streamArn *string) *ddb.DisableKinesisStreamingDestinationInput

+ func NewEnableKinesisStreamingDestinationInput(tableName, streamArn *string) *ddb.EnableKinesisStreamingDestinationInput

+ func NewGetItemInput(tableName *string, key map[string]ddbTypes.AttributeValue) *ddb.GetItemInput

+ func NewListBackupsInput() *ddb.ListBackupsInput

+ func NewListContributorInsightsInput() *ddb.ListContributorInsightsInput

+ func NewListExportsInput() *ddb.ListExportsInput

+ func NewListGlobalTablesInput() *ddb.ListGlobalTablesInput

+ func NewListTablesInput() *ddb.ListTablesInput

+ func NewListTagsOfResourceInput(resourceArn *string) *ddb.ListTagsOfResourceInput

+ func NewPutItemInput(tableName *string, item map[string]ddbTypes.AttributeValue) *ddb.PutItemInput

+ func NewQueryInput(tableName *string) *ddb.QueryInput

+ func NewRestoreTableFromBackupInput(tableName *string, backupArn *string) *ddb.RestoreTableFromBackupInput

+ func NewRestoreTableToPointInTimeInput(tableName *string) *ddb.RestoreTableToPointInTimeInput

+ func NewScanInput(tableName *string) *ddb.ScanInput

+ func NewTagResourceInput(resourceArn *string, tags []ddbTypes.Tag) *ddb.TagResourceInput

+ func NewTransactGetItemsInput() *ddb.TransactGetItemsInput

+ func NewTransactWriteItemsInput() *ddb.TransactWriteItemsInput

+ func NewUntagResourceInput(resourceArn *string, tagKeys []string) *ddb.UntagResourceInput

+ func NewUpdateContinuousBackupsInput(tableName *string, recoveryEnabled bool) *ddb.UpdateContinuousBackupsInput

+ func NewUpdateContributorInsightsInput(tableName, indexName *string, action ddbTypes.ContributorInsightsAction) *ddb.UpdateContributorInsightsInput

+ func NewUpdateGlobalTableInput(tableName *string) *ddb.UpdateGlobalTableInput

+ func NewUpdateGlobalTableSettingsInput(tableName *string) *ddb.UpdateGlobalTableSettingsInput

+ func NewUpdateItemInput(tableName *string) *ddb.UpdateItemInput

+ func NewUpdateTableInput(tableName *string) *ddb.UpdateTableInput

+ func NewUpdateTableReplicaAutoScalingInput(tableName *string) *ddb.UpdateTableReplicaAutoScalingInput

+ func NewUpdateTimeToLiveInput(tableName *string, specification *types.TimeToLiveSpecification) *ddb.UpdateTimeToLiveInput

+ func RandomString(length int) string

+ func SplitScanIntoSegments(input *ddb.ScanInput, segments int32) (inputs []*ddb.ScanInput)

+ func TestTableName() string

+ type BatchExecuteStatement struct

+ func NewBatchExecuteStatement(input *ddb.BatchExecuteStatementInput, mws ...BatchExecuteStatementMiddleWare) *BatchExecuteStatement

+ func (op *BatchExecuteStatement) Await() (*ddb.BatchExecuteStatementOutput, error)

+ func (op *BatchExecuteStatement) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *BatchExecuteStatement) Invoke(ctx context.Context, client *ddb.Client) *BatchExecuteStatement

+ type BatchExecuteStatementContext struct

+ type BatchExecuteStatementFinalHandler struct

+ func (h *BatchExecuteStatementFinalHandler) HandleBatchExecuteStatement(ctx *BatchExecuteStatementContext, output *BatchExecuteStatementOutput)

+ type BatchExecuteStatementHandler interface

+ HandleBatchExecuteStatement func(ctx *BatchExecuteStatementContext, output *BatchExecuteStatementOutput)

+ type BatchExecuteStatementHandlerFunc func(ctx *BatchExecuteStatementContext, output *BatchExecuteStatementOutput)

+ func (h BatchExecuteStatementHandlerFunc) HandleBatchExecuteStatement(ctx *BatchExecuteStatementContext, output *BatchExecuteStatementOutput)

+ type BatchExecuteStatementMiddleWare interface

+ BatchExecuteStatementMiddleWare func(next BatchExecuteStatementHandler) BatchExecuteStatementHandler

+ type BatchExecuteStatementMiddleWareFunc func(next BatchExecuteStatementHandler) BatchExecuteStatementHandler

+ func (mw BatchExecuteStatementMiddleWareFunc) BatchExecuteStatementMiddleWare(next BatchExecuteStatementHandler) BatchExecuteStatementHandler

+ type BatchExecuteStatementOutput struct

+ func (o *BatchExecuteStatementOutput) Get() (out *ddb.BatchExecuteStatementOutput, err error)

+ func (o *BatchExecuteStatementOutput) Set(out *ddb.BatchExecuteStatementOutput, err error)

+ type BatchGetItem struct

+ func NewBatchGetItem(input *ddb.BatchGetItemInput, mws ...BatchGetItemMiddleWare) *BatchGetItem

+ func (op *BatchGetItem) Await() (*ddb.BatchGetItemOutput, error)

+ func (op *BatchGetItem) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *BatchGetItem) Invoke(ctx context.Context, client *ddb.Client) *BatchGetItem

+ type BatchGetItemAll struct

+ func NewBatchGetItemAll(input *ddb.BatchGetItemInput, mws ...BatchGetItemAllMiddleWare) *BatchGetItemAll

+ func (op *BatchGetItemAll) Await() ([]*ddb.BatchGetItemOutput, error)

+ func (op *BatchGetItemAll) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *BatchGetItemAll) Invoke(ctx context.Context, client *ddb.Client) *BatchGetItemAll

+ type BatchGetItemAllContext struct

+ type BatchGetItemAllFinalHandler struct

+ func (b *BatchGetItemAllFinalHandler) HandleBatchGetItemAll(ctx *BatchGetItemAllContext, output *BatchGetItemAllOutput)

+ type BatchGetItemAllHandler interface

+ HandleBatchGetItemAll func(ctx *BatchGetItemAllContext, output *BatchGetItemAllOutput)

+ type BatchGetItemAllHandlerFunc func(ctx *BatchGetItemAllContext, output *BatchGetItemAllOutput)

+ func (h BatchGetItemAllHandlerFunc) HandleBatchGetItemAll(ctx *BatchGetItemAllContext, output *BatchGetItemAllOutput)

+ type BatchGetItemAllMiddleWare interface

+ BatchGetItemAllMiddleWare func(next BatchGetItemAllHandler) BatchGetItemAllHandler

+ type BatchGetItemAllMiddleWareFunc func(handler BatchGetItemAllHandler) BatchGetItemAllHandler

+ func (mw BatchGetItemAllMiddleWareFunc) BatchGetItemAllMiddleWare(h BatchGetItemAllHandler) BatchGetItemAllHandler

+ type BatchGetItemAllOutput struct

+ func (o *BatchGetItemAllOutput) Get() (out []*ddb.BatchGetItemOutput, err error)

+ func (o *BatchGetItemAllOutput) Set(out []*ddb.BatchGetItemOutput, err error)

+ type BatchGetItemBuilder struct

+ func NewBatchGetBuilder(input *ddb.BatchGetItemInput) *BatchGetItemBuilder

+ func (bld *BatchGetItemBuilder) AddKey(tableName string, keys ...map[string]ddbTypes.AttributeValue) *BatchGetItemBuilder

+ func (bld *BatchGetItemBuilder) AddProjection(projection interface{}) *BatchGetItemBuilder

+ func (bld *BatchGetItemBuilder) AddProjectionNames(names ...string) *BatchGetItemBuilder

+ func (bld *BatchGetItemBuilder) Build() (*ddb.BatchGetItemInput, error)

+ func (bld *BatchGetItemBuilder) SetInput(input *ddb.BatchGetItemInput)

+ func (bld *BatchGetItemBuilder) SetKeysAndAttributes(tableName string, keysAndAttributes ddbTypes.KeysAndAttributes) *BatchGetItemBuilder

+ func (bld *BatchGetItemBuilder) SetRequestItems(v map[string]ddbTypes.KeysAndAttributes) *BatchGetItemBuilder

+ func (bld *BatchGetItemBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *BatchGetItemBuilder

+ type BatchGetItemContext struct

+ type BatchGetItemFinalHandler struct

+ func (b *BatchGetItemFinalHandler) HandleBatchGetItem(ctx *BatchGetItemContext, output *BatchGetItemOutput)

+ type BatchGetItemHandler interface

+ HandleBatchGetItem func(ctx *BatchGetItemContext, output *BatchGetItemOutput)

+ type BatchGetItemHandlerFunc func(ctx *BatchGetItemContext, output *BatchGetItemOutput)

+ func (h BatchGetItemHandlerFunc) HandleBatchGetItem(ctx *BatchGetItemContext, output *BatchGetItemOutput)

+ type BatchGetItemMiddleWare interface

+ BatchGetItemMiddleWare func(h BatchGetItemHandler) BatchGetItemHandler

+ type BatchGetItemMiddleWareFunc func(handler BatchGetItemHandler) BatchGetItemHandler

+ func (mw BatchGetItemMiddleWareFunc) BatchGetItemMiddleWare(h BatchGetItemHandler) BatchGetItemHandler

+ type BatchGetItemOutput struct

+ func (o *BatchGetItemOutput) Get() (out *ddb.BatchGetItemOutput, err error)

+ func (o *BatchGetItemOutput) Set(out *ddb.BatchGetItemOutput, err error)

+ type BatchWriteItem struct

+ func NewBatchWriteItem(input *ddb.BatchWriteItemInput, mws ...BatchWriteItemMiddleWare) *BatchWriteItem

+ func (op *BatchWriteItem) Await() (*ddb.BatchWriteItemOutput, error)

+ func (op *BatchWriteItem) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *BatchWriteItem) Invoke(ctx context.Context, client *ddb.Client) *BatchWriteItem

+ type BatchWriteItemAll struct

+ func NewBatchWriteItemAll(input *ddb.BatchWriteItemInput, mws ...BatchWriteItemAllMiddleWare) *BatchWriteItemAll

+ func (op *BatchWriteItemAll) Await() ([]*ddb.BatchWriteItemOutput, error)

+ func (op *BatchWriteItemAll) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *BatchWriteItemAll) Invoke(ctx context.Context, client *ddb.Client) *BatchWriteItemAll

+ type BatchWriteItemAllContext struct

+ type BatchWriteItemAllFinalHandler struct

+ func (b *BatchWriteItemAllFinalHandler) HandleBatchWriteItemAll(ctx *BatchWriteItemAllContext, output *BatchWriteItemAllOutput)

+ type BatchWriteItemAllHandler interface

+ HandleBatchWriteItemAll func(ctx *BatchWriteItemAllContext, output *BatchWriteItemAllOutput)

+ type BatchWriteItemAllHandlerFunc func(ctx *BatchWriteItemAllContext, output *BatchWriteItemAllOutput)

+ func (h BatchWriteItemAllHandlerFunc) HandleBatchWriteItemAll(ctx *BatchWriteItemAllContext, output *BatchWriteItemAllOutput)

+ type BatchWriteItemAllMiddleWare interface

+ BatchWriteItemAllMiddleWare func(next BatchWriteItemAllHandler) BatchWriteItemAllHandler

+ type BatchWriteItemAllMiddleWareFunc func(next BatchWriteItemAllHandler) BatchWriteItemAllHandler

+ func (mw BatchWriteItemAllMiddleWareFunc) BatchWriteItemAllMiddleWare(next BatchWriteItemAllHandler) BatchWriteItemAllHandler

+ type BatchWriteItemAllOutput struct

+ func (o *BatchWriteItemAllOutput) Get() (out []*ddb.BatchWriteItemOutput, err error)

+ func (o *BatchWriteItemAllOutput) Set(out []*ddb.BatchWriteItemOutput, err error)

+ type BatchWriteItemAllPromise struct

+ func (p *BatchWriteItemAllPromise) GetResponse() ([]*ddb.BatchWriteItemOutput, error)

+ type BatchWriteItemBuilder struct

+ func NewBatchWriteItemBuilder(input *ddb.BatchWriteItemInput) *BatchWriteItemBuilder

+ func (bld *BatchWriteItemBuilder) AddDeletes(table string, itemKeys ...map[string]ddbTypes.AttributeValue) *BatchWriteItemBuilder

+ func (bld *BatchWriteItemBuilder) AddPuts(tableName string, items ...map[string]ddbTypes.AttributeValue) *BatchWriteItemBuilder

+ func (bld *BatchWriteItemBuilder) AddWriteRequests(tableName string, requests ...ddbTypes.WriteRequest) *BatchWriteItemBuilder

+ func (bld *BatchWriteItemBuilder) Build() *ddb.BatchWriteItemInput

+ func (bld *BatchWriteItemBuilder) SetRequestItems(v map[string][]ddbTypes.WriteRequest) *BatchWriteItemBuilder

+ func (bld *BatchWriteItemBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *BatchWriteItemBuilder

+ func (bld *BatchWriteItemBuilder) SetReturnItemCollectionMetrics(v ddbTypes.ReturnItemCollectionMetrics) *BatchWriteItemBuilder

+ type BatchWriteItemContext struct

+ type BatchWriteItemFinalHandler struct

+ func (b *BatchWriteItemFinalHandler) HandleBatchWriteItem(ctx *BatchWriteItemContext, output *BatchWriteItemOutput)

+ type BatchWriteItemHandler interface

+ HandleBatchWriteItem func(ctx *BatchWriteItemContext, output *BatchWriteItemOutput)

+ type BatchWriteItemHandlerFunc func(ctx *BatchWriteItemContext, output *BatchWriteItemOutput)

+ func (h BatchWriteItemHandlerFunc) HandleBatchWriteItem(ctx *BatchWriteItemContext, output *BatchWriteItemOutput)

+ type BatchWriteItemMiddleWare interface

+ BatchWriteItemMiddleWare func(next BatchWriteItemHandler) BatchWriteItemHandler

+ type BatchWriteItemMiddleWareFunc func(next BatchWriteItemHandler) BatchWriteItemHandler

+ func (mw BatchWriteItemMiddleWareFunc) BatchWriteItemMiddleWare(next BatchWriteItemHandler) BatchWriteItemHandler

+ type BatchWriteItemOutput struct

+ func (o *BatchWriteItemOutput) Get() (out *ddb.BatchWriteItemOutput, err error)

+ func (o *BatchWriteItemOutput) Set(out *ddb.BatchWriteItemOutput, err error)

+ type Client struct

+ func CreateTestClient() *Client

+ func NewClient(client *ddb.Client) *Client

+ func NewClientFromConfig(config aws.Config, optFns ...func(*ddb.Options)) *Client

+ func (c *Client) BatchExecuteStatement(ctx context.Context, input *ddb.BatchExecuteStatementInput, ...) *BatchExecuteStatement

+ func (c *Client) BatchGetItem(ctx context.Context, input *ddb.BatchGetItemInput, ...) *BatchGetItem

+ func (c *Client) BatchGetItemAll(ctx context.Context, input *ddb.BatchGetItemInput, ...) *BatchGetItemAll

+ func (c *Client) BatchWriteItem(ctx context.Context, input *ddb.BatchWriteItemInput, ...) *BatchWriteItem

+ func (c *Client) BatchWriteItemAll(ctx context.Context, input *ddb.BatchWriteItemInput, ...) *BatchWriteItemAll

+ func (c *Client) CreateBackup(ctx context.Context, input *ddb.CreateBackupInput, ...) *CreateBackup

+ func (c *Client) CreateGlobalTable(ctx context.Context, input *ddb.CreateGlobalTableInput, ...) *CreateGlobalTable

+ func (c *Client) CreateTable(ctx context.Context, input *ddb.CreateTableInput, mw ...CreateTableMiddleWare) *CreateTable

+ func (c *Client) DeleteBackup(ctx context.Context, input *ddb.DeleteBackupInput, ...) *DeleteBackup

+ func (c *Client) DeleteItem(ctx context.Context, input *ddb.DeleteItemInput, mw ...DeleteItemMiddleWare) *DeleteItem

+ func (c *Client) DeleteTable(ctx context.Context, input *ddb.DeleteTableInput, mw ...DeleteTableMiddleWare) *DeleteTable

+ func (c *Client) DescribeBackup(ctx context.Context, input *ddb.DescribeBackupInput, ...) *DescribeBackup

+ func (c *Client) DescribeContinuousBackups(ctx context.Context, input *ddb.DescribeContinuousBackupsInput, ...) *DescribeContinuousBackups

+ func (c *Client) DescribeContributorInsights(ctx context.Context, input *ddb.DescribeContributorInsightsInput, ...) *DescribeContributorInsights

+ func (c *Client) DescribeEndpoints(ctx context.Context, input *ddb.DescribeEndpointsInput, ...) *DescribeEndpoints

+ func (c *Client) DescribeExport(ctx context.Context, input *ddb.DescribeExportInput, ...) *DescribeExport

+ func (c *Client) DescribeGlobalTable(ctx context.Context, input *ddb.DescribeGlobalTableInput, ...) *DescribeGlobalTable

+ func (c *Client) DescribeGlobalTableSettings(ctx context.Context, input *ddb.DescribeGlobalTableSettingsInput, ...) *DescribeGlobalTableSettings

+ func (c *Client) DescribeKinesisStreamingDestination(ctx context.Context, input *ddb.DescribeKinesisStreamingDestinationInput, ...) *DescribeKinesisStreamingDestination

+ func (c *Client) DescribeLimits(ctx context.Context, input *ddb.DescribeLimitsInput, ...) *DescribeLimits

+ func (c *Client) DescribeTable(ctx context.Context, input *ddb.DescribeTableInput, ...) *DescribeTable

+ func (c *Client) DescribeTableReplicaAutoScaling(ctx context.Context, input *ddb.DescribeTableReplicaAutoScalingInput, ...) *DescribeTableReplicaAutoScaling

+ func (c *Client) DescribeTimeToLive(ctx context.Context, input *ddb.DescribeTimeToLiveInput, ...) *DescribeTimeToLive

+ func (c *Client) DisableKinesisStreamingDestination(ctx context.Context, input *ddb.DisableKinesisStreamingDestinationInput, ...) *DisableKinesisStreamingDestination

+ func (c *Client) DynamoDB() *ddb.Client

+ func (c *Client) EnableKinesisStreamingDestination(ctx context.Context, input *ddb.EnableKinesisStreamingDestinationInput, ...) *EnableKinesisStreamingDestination

+ func (c *Client) ExecuteStatement(ctx context.Context, input *ddb.ExecuteStatementInput, ...) *ExecuteStatement

+ func (c *Client) ExecuteTransaction(ctx context.Context, input *ddb.ExecuteTransactionInput, ...) *ExecuteTransaction

+ func (c *Client) ExportTableToPointInTime(ctx context.Context, input *ddb.ExportTableToPointInTimeInput, ...) *ExportTableToPointInTime

+ func (c *Client) GetItem(ctx context.Context, input *ddb.GetItemInput, mw ...GetItemMiddleWare) *GetItem

+ func (c *Client) ListBackups(ctx context.Context, input *ddb.ListBackupsInput, mw ...ListBackupsMiddleWare) *ListBackups

+ func (c *Client) ListContributorInsights(ctx context.Context, input *ddb.ListContributorInsightsInput, ...) *ListContributorInsights

+ func (c *Client) ListExports(ctx context.Context, input *ddb.ListExportsInput, mw ...ListExportsMiddleWare) *ListExports

+ func (c *Client) ListGlobalTables(ctx context.Context, input *ddb.ListGlobalTablesInput, ...) *ListGlobalTables

+ func (c *Client) ListTables(ctx context.Context, input *ddb.ListTablesInput, mw ...ListTablesMiddleWare) *ListTables

+ func (c *Client) ListTagsOfResource(ctx context.Context, input *ddb.ListTagsOfResourceInput, ...) *ListTagsOfResource

+ func (c *Client) PutItem(ctx context.Context, input *ddb.PutItemInput, mw ...PutItemMiddleWare) *PutItem

+ func (c *Client) Query(ctx context.Context, input *ddb.QueryInput, mw ...QueryMiddleWare) *Query

+ func (c *Client) QueryAll(ctx context.Context, input *ddb.QueryInput, mw ...QueryAllMiddleWare) *QueryAll

+ func (c *Client) RestoreTableFromBackup(ctx context.Context, input *ddb.RestoreTableFromBackupInput, ...) *RestoreTableFromBackup

+ func (c *Client) RestoreTableToPointInTime(ctx context.Context, input *ddb.RestoreTableToPointInTimeInput, ...) *RestoreTableToPointInTime

+ func (c *Client) Scan(ctx context.Context, input *ddb.ScanInput, mw ...ScanMiddleWare) *Scan

+ func (c *Client) ScanAll(ctx context.Context, input *ddb.ScanInput, mw ...ScanAllMiddleWare) *ScanAllPromise

+ func (c *Client) TableExistsWaiter(ctx context.Context, input *ddb.DescribeTableInput, ...) *TableExistsWaiter

+ func (c *Client) TableNotExistsWaiter(ctx context.Context, input *ddb.DescribeTableInput, ...) *TableNotExistsWaiter

+ func (c *Client) TagResource(ctx context.Context, input *ddb.TagResourceInput, mw ...TagResourceMiddleWare) *TagResource

+ func (c *Client) TransactGetItems(ctx context.Context, input *ddb.TransactGetItemsInput, ...) *TransactGetItems

+ func (c *Client) TransactWriteItems(ctx context.Context, input *ddb.TransactWriteItemsInput, ...) *TransactWriteItems

+ func (c *Client) UntagResource(ctx context.Context, input *ddb.UntagResourceInput, ...) *UntagResource

+ func (c *Client) UpdateContinuousBackups(ctx context.Context, input *ddb.UpdateContinuousBackupsInput, ...) *UpdateContinuousBackups

+ func (c *Client) UpdateContributorInsights(ctx context.Context, input *ddb.UpdateContributorInsightsInput, ...) *UpdateContributorInsights

+ func (c *Client) UpdateGlobalTable(ctx context.Context, input *ddb.UpdateGlobalTableInput, ...) *UpdateGlobalTable

+ func (c *Client) UpdateGlobalTableSettings(ctx context.Context, input *ddb.UpdateGlobalTableSettingsInput, ...) *UpdateGlobalTableSettings

+ func (c *Client) UpdateItem(ctx context.Context, input *ddb.UpdateItemInput, mw ...UpdateItemMiddleWare) *UpdateItem

+ func (c *Client) UpdateTable(ctx context.Context, input *ddb.UpdateTableInput, mw ...UpdateTableMiddleWare) *UpdateTable

+ func (c *Client) UpdateTableReplicaAutoScaling(ctx context.Context, input *ddb.UpdateTableReplicaAutoScalingInput, ...) *UpdateTableReplicaAutoScaling

+ func (c *Client) UpdateTimeToLive(ctx context.Context, input *ddb.UpdateTimeToLiveInput, ...) *UpdateTimeToLive

+ type CreateBackup struct

+ func NewCreateBackup(input *ddb.CreateBackupInput, mws ...CreateBackupMiddleWare) *CreateBackup

+ func (op *CreateBackup) Await() (*ddb.CreateBackupOutput, error)

+ func (op *CreateBackup) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *CreateBackup) Invoke(ctx context.Context, client *ddb.Client) *CreateBackup

+ type CreateBackupContext struct

+ type CreateBackupFinalHandler struct

+ func (h *CreateBackupFinalHandler) HandleCreateBackup(ctx *CreateBackupContext, output *CreateBackupOutput)

+ type CreateBackupHandler interface

+ HandleCreateBackup func(ctx *CreateBackupContext, output *CreateBackupOutput)

+ type CreateBackupHandlerFunc func(ctx *CreateBackupContext, output *CreateBackupOutput)

+ func (h CreateBackupHandlerFunc) HandleCreateBackup(ctx *CreateBackupContext, output *CreateBackupOutput)

+ type CreateBackupMiddleWare interface

+ CreateBackupMiddleWare func(next CreateBackupHandler) CreateBackupHandler

+ type CreateBackupMiddleWareFunc func(next CreateBackupHandler) CreateBackupHandler

+ func (mw CreateBackupMiddleWareFunc) CreateBackupMiddleWare(next CreateBackupHandler) CreateBackupHandler

+ type CreateBackupOutput struct

+ func (o *CreateBackupOutput) Get() (out *ddb.CreateBackupOutput, err error)

+ func (o *CreateBackupOutput) Set(out *ddb.CreateBackupOutput, err error)

+ type CreateGlobalTable struct

+ func NewCreateGlobalTable(input *ddb.CreateGlobalTableInput, mws ...CreateGlobalTableMiddleWare) *CreateGlobalTable

+ func (op *CreateGlobalTable) Await() (*ddb.CreateGlobalTableOutput, error)

+ func (op *CreateGlobalTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *CreateGlobalTable) Invoke(ctx context.Context, client *ddb.Client) *CreateGlobalTable

+ type CreateGlobalTableBuilder struct

+ func (bld *CreateGlobalTableBuilder) AddReplicaInRegion(region string) *CreateGlobalTableBuilder

+ func (bld *CreateGlobalTableBuilder) AddReplication(r types.Replica) *CreateGlobalTableBuilder

+ func (bld *CreateGlobalTableBuilder) Build() *ddb.CreateGlobalTableInput

+ type CreateGlobalTableContext struct

+ type CreateGlobalTableFinalHandler struct

+ func (h *CreateGlobalTableFinalHandler) HandleCreateGlobalTable(ctx *CreateGlobalTableContext, output *CreateGlobalTableOutput)

+ type CreateGlobalTableHandler interface

+ HandleCreateGlobalTable func(ctx *CreateGlobalTableContext, output *CreateGlobalTableOutput)

+ type CreateGlobalTableHandlerFunc func(ctx *CreateGlobalTableContext, output *CreateGlobalTableOutput)

+ func (h CreateGlobalTableHandlerFunc) HandleCreateGlobalTable(ctx *CreateGlobalTableContext, output *CreateGlobalTableOutput)

+ type CreateGlobalTableMiddleWare interface

+ CreateGlobalTableMiddleWare func(next CreateGlobalTableHandler) CreateGlobalTableHandler

+ type CreateGlobalTableMiddleWareFunc func(next CreateGlobalTableHandler) CreateGlobalTableHandler

+ func (mw CreateGlobalTableMiddleWareFunc) CreateGlobalTableMiddleWare(h CreateGlobalTableHandler) CreateGlobalTableHandler

+ type CreateGlobalTableOutput struct

+ func (o *CreateGlobalTableOutput) Get() (out *ddb.CreateGlobalTableOutput, err error)

+ func (o *CreateGlobalTableOutput) Set(out *ddb.CreateGlobalTableOutput, err error)

+ type CreateTable struct

+ func NewCreateTable(input *ddb.CreateTableInput, mws ...CreateTableMiddleWare) *CreateTable

+ func (op *CreateTable) Await() (*ddb.CreateTableOutput, error)

+ func (op *CreateTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *CreateTable) Invoke(ctx context.Context, client *ddb.Client) *CreateTable

+ type CreateTableBuilder struct

+ func NewCreateTableBuilder() *CreateTableBuilder

+ func (bld *CreateTableBuilder) AddAttributeDefinition(attribute ddbTypes.AttributeDefinition) *CreateTableBuilder

+ func (bld *CreateTableBuilder) AddGlobalIndex(gsi ...ddbTypes.GlobalSecondaryIndex) *CreateTableBuilder

+ func (bld *CreateTableBuilder) AddLocalIndex(lsi ...ddbTypes.LocalSecondaryIndex) *CreateTableBuilder

+ func (bld *CreateTableBuilder) AddTag(key, value string) *CreateTableBuilder

+ func (bld *CreateTableBuilder) AddTags(tags ...ddbTypes.Tag) *CreateTableBuilder

+ func (bld *CreateTableBuilder) AddTagsFromMap(tags map[string]string) *CreateTableBuilder

+ func (bld *CreateTableBuilder) Build() (*ddb.CreateTableInput, error)

+ func (bld *CreateTableBuilder) SetAttributeDefinitions(v []ddbTypes.AttributeDefinition) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetBillingMode(v ddbTypes.BillingMode) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetGlobalSecondaryIndexes(v []ddbTypes.GlobalSecondaryIndex) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetKeySchema(v []ddbTypes.KeySchemaElement) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetLocalSecondaryIndexes(v []ddbTypes.LocalSecondaryIndex) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetProvisionedThroughput(v *ddbTypes.ProvisionedThroughput) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetProvisionedThroughputCapacityUnits(rcu, wcu int64) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetSSESpecification(v *ddbTypes.SSESpecification) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetStreamSpecification(v *ddbTypes.StreamSpecification) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetTableName(v string) *CreateTableBuilder

+ func (bld *CreateTableBuilder) SetTags(v []ddbTypes.Tag) *CreateTableBuilder

+ type CreateTableContext struct

+ type CreateTableFinalHandler struct

+ func (h *CreateTableFinalHandler) HandleCreateTable(ctx *CreateTableContext, output *CreateTableOutput)

+ type CreateTableHandler interface

+ HandleCreateTable func(ctx *CreateTableContext, output *CreateTableOutput)

+ type CreateTableHandlerFunc func(ctx *CreateTableContext, output *CreateTableOutput)

+ func (h CreateTableHandlerFunc) HandleCreateTable(ctx *CreateTableContext, output *CreateTableOutput)

+ type CreateTableMiddleWare interface

+ CreateTableMiddleWare func(next CreateTableHandler) CreateTableHandler

+ type CreateTableMiddleWareFunc func(next CreateTableHandler) CreateTableHandler

+ func (mw CreateTableMiddleWareFunc) CreateTableMiddleWare(h CreateTableHandler) CreateTableHandler

+ type CreateTableOutput struct

+ func (o *CreateTableOutput) Get() (out *ddb.CreateTableOutput, err error)

+ func (o *CreateTableOutput) Set(out *ddb.CreateTableOutput, err error)

+ type DeleteBackup struct

+ func NewDeleteBackup(input *ddb.DeleteBackupInput, mws ...DeleteBackupMiddleWare) *DeleteBackup

+ func (op *DeleteBackup) Await() (*ddb.DeleteBackupOutput, error)

+ func (op *DeleteBackup) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DeleteBackup) Invoke(ctx context.Context, client *ddb.Client) *DeleteBackup

+ type DeleteBackupContext struct

+ type DeleteBackupFinalHandler struct

+ func (h *DeleteBackupFinalHandler) HandleDeleteBackup(ctx *DeleteBackupContext, output *DeleteBackupOutput)

+ type DeleteBackupHandler interface

+ HandleDeleteBackup func(ctx *DeleteBackupContext, output *DeleteBackupOutput)

+ type DeleteBackupHandlerFunc func(ctx *DeleteBackupContext, output *DeleteBackupOutput)

+ func (h DeleteBackupHandlerFunc) HandleDeleteBackup(ctx *DeleteBackupContext, output *DeleteBackupOutput)

+ type DeleteBackupMiddleWare interface

+ DeleteBackupMiddleWare func(next DeleteBackupHandler) DeleteBackupHandler

+ type DeleteBackupMiddleWareFunc func(next DeleteBackupHandler) DeleteBackupHandler

+ func (mw DeleteBackupMiddleWareFunc) DeleteBackupMiddleWare(next DeleteBackupHandler) DeleteBackupHandler

+ type DeleteBackupOutput struct

+ func (o *DeleteBackupOutput) Get() (out *ddb.DeleteBackupOutput, err error)

+ func (o *DeleteBackupOutput) Set(out *ddb.DeleteBackupOutput, err error)

+ type DeleteBackupPromise struct

+ func (p *DeleteBackupPromise) Await() (*ddb.DeleteBackupOutput, error)

+ type DeleteItem struct

+ func NewDeleteItem(input *ddb.DeleteItemInput, mws ...DeleteItemMiddleWare) *DeleteItem

+ func (op *DeleteItem) Await() (*ddb.DeleteItemOutput, error)

+ func (op *DeleteItem) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DeleteItem) Invoke(ctx context.Context, client *ddb.Client) *DeleteItem

+ type DeleteItemBuilder struct

+ func NewDeleteItemBuilder(input *ddb.DeleteItemInput) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) AddCondition(cnd expression.ConditionBuilder) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) Build() (*ddb.DeleteItemInput, error)

+ func (bld *DeleteItemBuilder) SetConditionExpression(v string) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetExpressionAttributeNames(v map[string]string) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetExpressionAttributeValues(v map[string]ddbTypes.AttributeValue) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetKey(key map[string]ddbTypes.AttributeValue) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetReturnItemCollectionMetrics(v ddbTypes.ReturnItemCollectionMetrics) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetReturnValues(v ddbTypes.ReturnValue) *DeleteItemBuilder

+ func (bld *DeleteItemBuilder) SetTableName(v string) *DeleteItemBuilder

+ type DeleteItemContext struct

+ type DeleteItemFinalHandler struct

+ func (h *DeleteItemFinalHandler) HandleDeleteItem(ctx *DeleteItemContext, output *DeleteItemOutput)

+ type DeleteItemHandler interface

+ HandleDeleteItem func(ctx *DeleteItemContext, output *DeleteItemOutput)

+ type DeleteItemHandlerFunc func(ctx *DeleteItemContext, output *DeleteItemOutput)

+ func (h DeleteItemHandlerFunc) HandleDeleteItem(ctx *DeleteItemContext, output *DeleteItemOutput)

+ type DeleteItemMiddleWare interface

+ DeleteItemMiddleWare func(next DeleteItemHandler) DeleteItemHandler

+ type DeleteItemMiddleWareFunc func(handler DeleteItemHandler) DeleteItemHandler

+ func (mw DeleteItemMiddleWareFunc) DeleteItemMiddleWare(h DeleteItemHandler) DeleteItemHandler

+ type DeleteItemOutput struct

+ func (o *DeleteItemOutput) Get() (out *ddb.DeleteItemOutput, err error)

+ func (o *DeleteItemOutput) Set(out *ddb.DeleteItemOutput, err error)

+ type DeleteTable struct

+ func NewDeleteTable(input *ddb.DeleteTableInput, mws ...DeleteTableMiddleWare) *DeleteTable

+ func (op *DeleteTable) Await() (*ddb.DeleteTableOutput, error)

+ func (op *DeleteTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DeleteTable) Invoke(ctx context.Context, client *ddb.Client) *DeleteTable

+ type DeleteTableContext struct

+ type DeleteTableFinalHandler struct

+ func (h *DeleteTableFinalHandler) HandleDeleteTable(ctx *DeleteTableContext, output *DeleteTableOutput)

+ type DeleteTableHandler interface

+ HandleDeleteTable func(ctx *DeleteTableContext, output *DeleteTableOutput)

+ type DeleteTableHandlerFunc func(ctx *DeleteTableContext, output *DeleteTableOutput)

+ func (h DeleteTableHandlerFunc) HandleDeleteTable(ctx *DeleteTableContext, output *DeleteTableOutput)

+ type DeleteTableMiddleWare interface

+ DeleteTableMiddleWare func(next DeleteTableHandler) DeleteTableHandler

+ type DeleteTableMiddleWareFunc func(next DeleteTableHandler) DeleteTableHandler

+ func (mw DeleteTableMiddleWareFunc) DeleteTableMiddleWare(next DeleteTableHandler) DeleteTableHandler

+ type DeleteTableOutput struct

+ func (o *DeleteTableOutput) Get() (out *ddb.DeleteTableOutput, err error)

+ func (o *DeleteTableOutput) Set(out *ddb.DeleteTableOutput, err error)

+ type DescribeBackup struct

+ func NewDescribeBackup(input *ddb.DescribeBackupInput, mws ...DescribeBackupMiddleWare) *DescribeBackup

+ func (op *DescribeBackup) Await() (*ddb.DescribeBackupOutput, error)

+ func (op *DescribeBackup) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeBackup) Invoke(ctx context.Context, client *ddb.Client) *DescribeBackup

+ type DescribeBackupContext struct

+ type DescribeBackupFinalHandler struct

+ func (h *DescribeBackupFinalHandler) HandleDescribeBackup(ctx *DescribeBackupContext, output *DescribeBackupOutput)

+ type DescribeBackupHandler interface

+ HandleDescribeBackup func(ctx *DescribeBackupContext, output *DescribeBackupOutput)

+ type DescribeBackupHandlerFunc func(ctx *DescribeBackupContext, output *DescribeBackupOutput)

+ func (h DescribeBackupHandlerFunc) HandleDescribeBackup(ctx *DescribeBackupContext, output *DescribeBackupOutput)

+ type DescribeBackupMiddleWare interface

+ DescribeBackupMiddleWare func(next DescribeBackupHandler) DescribeBackupHandler

+ type DescribeBackupMiddleWareFunc func(next DescribeBackupHandler) DescribeBackupHandler

+ func (mw DescribeBackupMiddleWareFunc) DescribeBackupMiddleWare(next DescribeBackupHandler) DescribeBackupHandler

+ type DescribeBackupOutput struct

+ func (o *DescribeBackupOutput) Get() (out *ddb.DescribeBackupOutput, err error)

+ func (o *DescribeBackupOutput) Set(out *ddb.DescribeBackupOutput, err error)

+ type DescribeContinuousBackups struct

+ func NewDescribeContinuousBackups(input *ddb.DescribeContinuousBackupsInput, ...) *DescribeContinuousBackups

+ func (op *DescribeContinuousBackups) Await() (*ddb.DescribeContinuousBackupsOutput, error)

+ func (op *DescribeContinuousBackups) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeContinuousBackups) Invoke(ctx context.Context, client *ddb.Client) *DescribeContinuousBackups

+ type DescribeContinuousBackupsContext struct

+ type DescribeContinuousBackupsFinalHandler struct

+ func (h *DescribeContinuousBackupsFinalHandler) HandleDescribeContinuousBackups(ctx *DescribeContinuousBackupsContext, output *DescribeContinuousBackupsOutput)

+ type DescribeContinuousBackupsHandler interface

+ HandleDescribeContinuousBackups func(ctx *DescribeContinuousBackupsContext, output *DescribeContinuousBackupsOutput)

+ type DescribeContinuousBackupsHandlerFunc func(ctx *DescribeContinuousBackupsContext, output *DescribeContinuousBackupsOutput)

+ func (h DescribeContinuousBackupsHandlerFunc) HandleDescribeContinuousBackups(ctx *DescribeContinuousBackupsContext, output *DescribeContinuousBackupsOutput)

+ type DescribeContinuousBackupsMiddleWare interface

+ DescribeContinuousBackupsMiddleWare func(next DescribeContinuousBackupsHandler) DescribeContinuousBackupsHandler

+ type DescribeContinuousBackupsMiddleWareFunc func(next DescribeContinuousBackupsHandler) DescribeContinuousBackupsHandler

+ func (mw DescribeContinuousBackupsMiddleWareFunc) DescribeContinuousBackupsMiddleWare(next DescribeContinuousBackupsHandler) DescribeContinuousBackupsHandler

+ type DescribeContinuousBackupsOutput struct

+ func (o *DescribeContinuousBackupsOutput) Get() (out *ddb.DescribeContinuousBackupsOutput, err error)

+ func (o *DescribeContinuousBackupsOutput) Set(out *ddb.DescribeContinuousBackupsOutput, err error)

+ type DescribeContributorInsights struct

+ func NewDescribeContributorInsights(input *ddb.DescribeContributorInsightsInput, ...) *DescribeContributorInsights

+ func (op *DescribeContributorInsights) Await() (*ddb.DescribeContributorInsightsOutput, error)

+ func (op *DescribeContributorInsights) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeContributorInsights) Invoke(ctx context.Context, client *ddb.Client) *DescribeContributorInsights

+ type DescribeContributorInsightsContext struct

+ type DescribeContributorInsightsFinalHandler struct

+ func (h *DescribeContributorInsightsFinalHandler) HandleDescribeContributorInsights(ctx *DescribeContributorInsightsContext, ...)

+ type DescribeContributorInsightsHandler interface

+ HandleDescribeContributorInsights func(ctx *DescribeContributorInsightsContext, ...)

+ type DescribeContributorInsightsHandlerFunc func(ctx *DescribeContributorInsightsContext, ...)

+ func (h DescribeContributorInsightsHandlerFunc) HandleDescribeContributorInsights(ctx *DescribeContributorInsightsContext, ...)

+ type DescribeContributorInsightsMiddleWare interface

+ DescribeContributorInsightsMiddleWare func(next DescribeContributorInsightsHandler) DescribeContributorInsightsHandler

+ type DescribeContributorInsightsMiddleWareFunc func(next DescribeContributorInsightsHandler) DescribeContributorInsightsHandler

+ func (mw DescribeContributorInsightsMiddleWareFunc) DescribeContributorInsightsMiddleWare(next DescribeContributorInsightsHandler) DescribeContributorInsightsHandler

+ type DescribeContributorInsightsOutput struct

+ func (o *DescribeContributorInsightsOutput) Get() (out *ddb.DescribeContributorInsightsOutput, err error)

+ func (o *DescribeContributorInsightsOutput) Set(out *ddb.DescribeContributorInsightsOutput, err error)

+ type DescribeEndpoints struct

+ func NewDescribeEndpoints(input *ddb.DescribeEndpointsInput, mws ...DescribeEndpointsMiddleWare) *DescribeEndpoints

+ func (op *DescribeEndpoints) Await() (*ddb.DescribeEndpointsOutput, error)

+ func (op *DescribeEndpoints) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeEndpoints) Invoke(ctx context.Context, client *ddb.Client) *DescribeEndpoints

+ type DescribeEndpointsContext struct

+ type DescribeEndpointsFinalHandler struct

+ func (h *DescribeEndpointsFinalHandler) HandleDescribeEndpoints(ctx *DescribeEndpointsContext, output *DescribeEndpointsOutput)

+ type DescribeEndpointsHandler interface

+ HandleDescribeEndpoints func(ctx *DescribeEndpointsContext, output *DescribeEndpointsOutput)

+ type DescribeEndpointsHandlerFunc func(ctx *DescribeEndpointsContext, output *DescribeEndpointsOutput)

+ func (h DescribeEndpointsHandlerFunc) HandleDescribeEndpoints(ctx *DescribeEndpointsContext, output *DescribeEndpointsOutput)

+ type DescribeEndpointsMiddleWare interface

+ DescribeEndpointsMiddleWare func(next DescribeEndpointsHandler) DescribeEndpointsHandler

+ type DescribeEndpointsMiddleWareFunc func(next DescribeEndpointsHandler) DescribeEndpointsHandler

+ func (mw DescribeEndpointsMiddleWareFunc) DescribeEndpointsMiddleWare(next DescribeEndpointsHandler) DescribeEndpointsHandler

+ type DescribeEndpointsOutput struct

+ func (o *DescribeEndpointsOutput) Get() (out *ddb.DescribeEndpointsOutput, err error)

+ func (o *DescribeEndpointsOutput) Set(out *ddb.DescribeEndpointsOutput, err error)

+ type DescribeExport struct

+ func NewDescribeExport(input *ddb.DescribeExportInput, mws ...DescribeExportMiddleWare) *DescribeExport

+ func (op *DescribeExport) Await() (*ddb.DescribeExportOutput, error)

+ func (op *DescribeExport) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeExport) Invoke(ctx context.Context, client *ddb.Client) *DescribeExport

+ type DescribeExportContext struct

+ type DescribeExportFinalHandler struct

+ func (h *DescribeExportFinalHandler) HandleDescribeExport(ctx *DescribeExportContext, output *DescribeExportOutput)

+ type DescribeExportHandler interface

+ HandleDescribeExport func(ctx *DescribeExportContext, output *DescribeExportOutput)

+ type DescribeExportHandlerFunc func(ctx *DescribeExportContext, output *DescribeExportOutput)

+ func (h DescribeExportHandlerFunc) HandleDescribeExport(ctx *DescribeExportContext, output *DescribeExportOutput)

+ type DescribeExportMiddleWare interface

+ DescribeExportMiddleWare func(next DescribeExportHandler) DescribeExportHandler

+ type DescribeExportMiddleWareFunc func(next DescribeExportHandler) DescribeExportHandler

+ func (mw DescribeExportMiddleWareFunc) DescribeExportMiddleWare(next DescribeExportHandler) DescribeExportHandler

+ type DescribeExportOutput struct

+ func (o *DescribeExportOutput) Get() (out *ddb.DescribeExportOutput, err error)

+ func (o *DescribeExportOutput) Set(out *ddb.DescribeExportOutput, err error)

+ type DescribeGlobalTable struct

+ func NewDescribeGlobalTable(input *ddb.DescribeGlobalTableInput, mws ...DescribeGlobalTableMiddleWare) *DescribeGlobalTable

+ func (op *DescribeGlobalTable) Await() (*ddb.DescribeGlobalTableOutput, error)

+ func (op *DescribeGlobalTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeGlobalTable) Invoke(ctx context.Context, client *ddb.Client) *DescribeGlobalTable

+ type DescribeGlobalTableContext struct

+ type DescribeGlobalTableFinalHandler struct

+ func (h *DescribeGlobalTableFinalHandler) HandleDescribeGlobalTable(ctx *DescribeGlobalTableContext, output *DescribeGlobalTableOutput)

+ type DescribeGlobalTableHandler interface

+ HandleDescribeGlobalTable func(ctx *DescribeGlobalTableContext, output *DescribeGlobalTableOutput)

+ type DescribeGlobalTableHandlerFunc func(ctx *DescribeGlobalTableContext, output *DescribeGlobalTableOutput)

+ func (h DescribeGlobalTableHandlerFunc) HandleDescribeGlobalTable(ctx *DescribeGlobalTableContext, output *DescribeGlobalTableOutput)

+ type DescribeGlobalTableMiddleWare interface

+ DescribeGlobalTableMiddleWare func(next DescribeGlobalTableHandler) DescribeGlobalTableHandler

+ type DescribeGlobalTableMiddleWareFunc func(next DescribeGlobalTableHandler) DescribeGlobalTableHandler

+ func (mw DescribeGlobalTableMiddleWareFunc) DescribeGlobalTableMiddleWare(next DescribeGlobalTableHandler) DescribeGlobalTableHandler

+ type DescribeGlobalTableOutput struct

+ func (o *DescribeGlobalTableOutput) Get() (out *ddb.DescribeGlobalTableOutput, err error)

+ func (o *DescribeGlobalTableOutput) Set(out *ddb.DescribeGlobalTableOutput, err error)

+ type DescribeGlobalTableSettings struct

+ func NewDescribeGlobalTableSettings(input *ddb.DescribeGlobalTableSettingsInput, ...) *DescribeGlobalTableSettings

+ func (op *DescribeGlobalTableSettings) Await() (*ddb.DescribeGlobalTableSettingsOutput, error)

+ func (op *DescribeGlobalTableSettings) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeGlobalTableSettings) Invoke(ctx context.Context, client *ddb.Client) *DescribeGlobalTableSettings

+ type DescribeGlobalTableSettingsContext struct

+ type DescribeGlobalTableSettingsFinalHandler struct

+ func (h *DescribeGlobalTableSettingsFinalHandler) HandleDescribeGlobalTableSettings(ctx *DescribeGlobalTableSettingsContext, ...)

+ type DescribeGlobalTableSettingsHandler interface

+ HandleDescribeGlobalTableSettings func(ctx *DescribeGlobalTableSettingsContext, ...)

+ type DescribeGlobalTableSettingsHandlerFunc func(ctx *DescribeGlobalTableSettingsContext, ...)

+ func (h DescribeGlobalTableSettingsHandlerFunc) HandleDescribeGlobalTableSettings(ctx *DescribeGlobalTableSettingsContext, ...)

+ type DescribeGlobalTableSettingsMiddleWare interface

+ DescribeGlobalTableSettingsMiddleWare func(next DescribeGlobalTableSettingsHandler) DescribeGlobalTableSettingsHandler

+ type DescribeGlobalTableSettingsMiddleWareFunc func(next DescribeGlobalTableSettingsHandler) DescribeGlobalTableSettingsHandler

+ func (mw DescribeGlobalTableSettingsMiddleWareFunc) DescribeGlobalTableSettingsMiddleWare(next DescribeGlobalTableSettingsHandler) DescribeGlobalTableSettingsHandler

+ type DescribeGlobalTableSettingsOutput struct

+ func (o *DescribeGlobalTableSettingsOutput) Get() (out *ddb.DescribeGlobalTableSettingsOutput, err error)

+ func (o *DescribeGlobalTableSettingsOutput) Set(out *ddb.DescribeGlobalTableSettingsOutput, err error)

+ type DescribeKinesisStreamingDestination struct

+ func NewDescribeKinesisStreamingDestination(input *ddb.DescribeKinesisStreamingDestinationInput, ...) *DescribeKinesisStreamingDestination

+ func (op *DescribeKinesisStreamingDestination) Await() (*ddb.DescribeKinesisStreamingDestinationOutput, error)

+ func (op *DescribeKinesisStreamingDestination) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeKinesisStreamingDestination) Invoke(ctx context.Context, client *ddb.Client) *DescribeKinesisStreamingDestination

+ type DescribeKinesisStreamingDestinationContext struct

+ type DescribeKinesisStreamingDestinationFinalHandler struct

+ func (h *DescribeKinesisStreamingDestinationFinalHandler) HandleDescribeKinesisStreamingDestination(ctx *DescribeKinesisStreamingDestinationContext, ...)

+ type DescribeKinesisStreamingDestinationHandler interface

+ HandleDescribeKinesisStreamingDestination func(ctx *DescribeKinesisStreamingDestinationContext, ...)

+ type DescribeKinesisStreamingDestinationHandlerFunc func(ctx *DescribeKinesisStreamingDestinationContext, ...)

+ func (h DescribeKinesisStreamingDestinationHandlerFunc) HandleDescribeKinesisStreamingDestination(ctx *DescribeKinesisStreamingDestinationContext, ...)

+ type DescribeKinesisStreamingDestinationMiddleWare interface

+ DescribeKinesisStreamingDestinationMiddleWare func(next DescribeKinesisStreamingDestinationHandler) DescribeKinesisStreamingDestinationHandler

+ type DescribeKinesisStreamingDestinationMiddleWareFunc func(next DescribeKinesisStreamingDestinationHandler) DescribeKinesisStreamingDestinationHandler

+ func (mw DescribeKinesisStreamingDestinationMiddleWareFunc) DescribeKinesisStreamingDestinationMiddleWare(next DescribeKinesisStreamingDestinationHandler) DescribeKinesisStreamingDestinationHandler

+ type DescribeKinesisStreamingDestinationOutput struct

+ func (o *DescribeKinesisStreamingDestinationOutput) Get() (out *ddb.DescribeKinesisStreamingDestinationOutput, err error)

+ func (o *DescribeKinesisStreamingDestinationOutput) Set(out *ddb.DescribeKinesisStreamingDestinationOutput, err error)

+ type DescribeLimits struct

+ func NewDescribeLimits(input *ddb.DescribeLimitsInput, mws ...DescribeLimitsMiddleWare) *DescribeLimits

+ func (op *DescribeLimits) Await() (*ddb.DescribeLimitsOutput, error)

+ func (op *DescribeLimits) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeLimits) Invoke(ctx context.Context, client *ddb.Client) *DescribeLimits

+ type DescribeLimitsContext struct

+ type DescribeLimitsFinalHandler struct

+ func (h *DescribeLimitsFinalHandler) HandleDescribeLimits(ctx *DescribeLimitsContext, output *DescribeLimitsOutput)

+ type DescribeLimitsHandler interface

+ HandleDescribeLimits func(ctx *DescribeLimitsContext, output *DescribeLimitsOutput)

+ type DescribeLimitsHandlerFunc func(ctx *DescribeLimitsContext, output *DescribeLimitsOutput)

+ func (h DescribeLimitsHandlerFunc) HandleDescribeLimits(ctx *DescribeLimitsContext, output *DescribeLimitsOutput)

+ type DescribeLimitsMiddleWare interface

+ DescribeLimitsMiddleWare func(next DescribeLimitsHandler) DescribeLimitsHandler

+ type DescribeLimitsMiddleWareFunc func(next DescribeLimitsHandler) DescribeLimitsHandler

+ func (mw DescribeLimitsMiddleWareFunc) DescribeLimitsMiddleWare(next DescribeLimitsHandler) DescribeLimitsHandler

+ type DescribeLimitsOutput struct

+ func (o *DescribeLimitsOutput) Get() (out *ddb.DescribeLimitsOutput, err error)

+ func (o *DescribeLimitsOutput) Set(out *ddb.DescribeLimitsOutput, err error)

+ type DescribeTable struct

+ func NewDescribeTable(input *ddb.DescribeTableInput, mws ...DescribeTableMiddleWare) *DescribeTable

+ func (op *DescribeTable) Await() (*ddb.DescribeTableOutput, error)

+ func (op *DescribeTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeTable) Invoke(ctx context.Context, client *ddb.Client) *DescribeTable

+ type DescribeTableContext struct

+ type DescribeTableFinalHandler struct

+ func (h *DescribeTableFinalHandler) HandleDescribeTable(ctx *DescribeTableContext, output *DescribeTableOutput)

+ type DescribeTableHandler interface

+ HandleDescribeTable func(ctx *DescribeTableContext, output *DescribeTableOutput)

+ type DescribeTableHandlerFunc func(ctx *DescribeTableContext, output *DescribeTableOutput)

+ func (h DescribeTableHandlerFunc) HandleDescribeTable(ctx *DescribeTableContext, output *DescribeTableOutput)

+ type DescribeTableMiddleWare interface

+ DescribeTableMiddleWare func(next DescribeTableHandler) DescribeTableHandler

+ type DescribeTableMiddleWareFunc func(next DescribeTableHandler) DescribeTableHandler

+ func (mw DescribeTableMiddleWareFunc) DescribeTableMiddleWare(next DescribeTableHandler) DescribeTableHandler

+ type DescribeTableOutput struct

+ func (o *DescribeTableOutput) Get() (out *ddb.DescribeTableOutput, err error)

+ func (o *DescribeTableOutput) Set(out *ddb.DescribeTableOutput, err error)

+ type DescribeTableReplicaAutoScaling struct

+ func NewDescribeTableReplicaAutoScaling(input *ddb.DescribeTableReplicaAutoScalingInput, ...) *DescribeTableReplicaAutoScaling

+ func (op *DescribeTableReplicaAutoScaling) Await() (*ddb.DescribeTableReplicaAutoScalingOutput, error)

+ func (op *DescribeTableReplicaAutoScaling) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeTableReplicaAutoScaling) Invoke(ctx context.Context, client *ddb.Client) *DescribeTableReplicaAutoScaling

+ type DescribeTableReplicaAutoScalingContext struct

+ type DescribeTableReplicaAutoScalingFinalHandler struct

+ func (h *DescribeTableReplicaAutoScalingFinalHandler) HandleDescribeTableReplicaAutoScaling(ctx *DescribeTableReplicaAutoScalingContext, ...)

+ type DescribeTableReplicaAutoScalingHandler interface

+ HandleDescribeTableReplicaAutoScaling func(ctx *DescribeTableReplicaAutoScalingContext, ...)

+ type DescribeTableReplicaAutoScalingHandlerFunc func(ctx *DescribeTableReplicaAutoScalingContext, ...)

+ func (h DescribeTableReplicaAutoScalingHandlerFunc) HandleDescribeTableReplicaAutoScaling(ctx *DescribeTableReplicaAutoScalingContext, ...)

+ type DescribeTableReplicaAutoScalingMiddleWare interface

+ DescribeTableReplicaAutoScalingMiddleWare func(next DescribeTableReplicaAutoScalingHandler) DescribeTableReplicaAutoScalingHandler

+ type DescribeTableReplicaAutoScalingMiddleWareFunc func(next DescribeTableReplicaAutoScalingHandler) DescribeTableReplicaAutoScalingHandler

+ func (mw DescribeTableReplicaAutoScalingMiddleWareFunc) DescribeTableReplicaAutoScalingMiddleWare(next DescribeTableReplicaAutoScalingHandler) DescribeTableReplicaAutoScalingHandler

+ type DescribeTableReplicaAutoScalingOutput struct

+ func (o *DescribeTableReplicaAutoScalingOutput) Get() (out *ddb.DescribeTableReplicaAutoScalingOutput, err error)

+ func (o *DescribeTableReplicaAutoScalingOutput) Set(out *ddb.DescribeTableReplicaAutoScalingOutput, err error)

+ type DescribeTimeToLive struct

+ func NewDescribeTimeToLive(input *ddb.DescribeTimeToLiveInput, mws ...DescribeTimeToLiveMiddleWare) *DescribeTimeToLive

+ func (op *DescribeTimeToLive) Await() (*ddb.DescribeTimeToLiveOutput, error)

+ func (op *DescribeTimeToLive) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DescribeTimeToLive) Invoke(ctx context.Context, client *ddb.Client) *DescribeTimeToLive

+ type DescribeTimeToLiveContext struct

+ type DescribeTimeToLiveFinalHandler struct

+ func (h *DescribeTimeToLiveFinalHandler) HandleDescribeTimeToLive(ctx *DescribeTimeToLiveContext, output *DescribeTimeToLiveOutput)

+ type DescribeTimeToLiveHandler interface

+ HandleDescribeTimeToLive func(ctx *DescribeTimeToLiveContext, output *DescribeTimeToLiveOutput)

+ type DescribeTimeToLiveHandlerFunc func(ctx *DescribeTimeToLiveContext, output *DescribeTimeToLiveOutput)

+ func (h DescribeTimeToLiveHandlerFunc) HandleDescribeTimeToLive(ctx *DescribeTimeToLiveContext, output *DescribeTimeToLiveOutput)

+ type DescribeTimeToLiveMiddleWare interface

+ DescribeTimeToLiveMiddleWare func(next DescribeTimeToLiveHandler) DescribeTimeToLiveHandler

+ type DescribeTimeToLiveMiddleWareFunc func(next DescribeTimeToLiveHandler) DescribeTimeToLiveHandler

+ func (mw DescribeTimeToLiveMiddleWareFunc) DescribeTimeToLiveMiddleWare(next DescribeTimeToLiveHandler) DescribeTimeToLiveHandler

+ type DescribeTimeToLiveOutput struct

+ func (o *DescribeTimeToLiveOutput) Get() (out *ddb.DescribeTimeToLiveOutput, err error)

+ func (o *DescribeTimeToLiveOutput) Set(out *ddb.DescribeTimeToLiveOutput, err error)

+ type DisableKinesisStreamingDestination struct

+ func NewDisableKinesisStreamingDestination(input *ddb.DisableKinesisStreamingDestinationInput, ...) *DisableKinesisStreamingDestination

+ func (op *DisableKinesisStreamingDestination) Await() (*ddb.DisableKinesisStreamingDestinationOutput, error)

+ func (op *DisableKinesisStreamingDestination) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *DisableKinesisStreamingDestination) Invoke(ctx context.Context, client *ddb.Client) *DisableKinesisStreamingDestination

+ type DisableKinesisStreamingDestinationContext struct

+ type DisableKinesisStreamingDestinationFinalHandler struct

+ func (h *DisableKinesisStreamingDestinationFinalHandler) HandleDisableKinesisStreamingDestination(ctx *DisableKinesisStreamingDestinationContext, ...)

+ type DisableKinesisStreamingDestinationHandler interface

+ HandleDisableKinesisStreamingDestination func(ctx *DisableKinesisStreamingDestinationContext, ...)

+ type DisableKinesisStreamingDestinationHandlerFunc func(ctx *DisableKinesisStreamingDestinationContext, ...)

+ func (h DisableKinesisStreamingDestinationHandlerFunc) HandleDisableKinesisStreamingDestination(ctx *DisableKinesisStreamingDestinationContext, ...)

+ type DisableKinesisStreamingDestinationMiddleWare interface

+ DisableKinesisStreamingDestinationMiddleWare func(next DisableKinesisStreamingDestinationHandler) DisableKinesisStreamingDestinationHandler

+ type DisableKinesisStreamingDestinationMiddleWareFunc func(next DisableKinesisStreamingDestinationHandler) DisableKinesisStreamingDestinationHandler

+ func (mw DisableKinesisStreamingDestinationMiddleWareFunc) DisableKinesisStreamingDestinationMiddleWare(next DisableKinesisStreamingDestinationHandler) DisableKinesisStreamingDestinationHandler

+ type DisableKinesisStreamingDestinationOutput struct

+ func (o *DisableKinesisStreamingDestinationOutput) Get() (out *ddb.DisableKinesisStreamingDestinationOutput, err error)

+ func (o *DisableKinesisStreamingDestinationOutput) Set(out *ddb.DisableKinesisStreamingDestinationOutput, err error)

+ type EnableKinesisStreamingDestination struct

+ func NewEnableKinesisStreamingDestination(input *ddb.EnableKinesisStreamingDestinationInput, ...) *EnableKinesisStreamingDestination

+ func (op *EnableKinesisStreamingDestination) Await() (*ddb.EnableKinesisStreamingDestinationOutput, error)

+ func (op *EnableKinesisStreamingDestination) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *EnableKinesisStreamingDestination) Invoke(ctx context.Context, client *ddb.Client) *EnableKinesisStreamingDestination

+ type EnableKinesisStreamingDestinationContext struct

+ type EnableKinesisStreamingDestinationFinalHandler struct

+ func (h *EnableKinesisStreamingDestinationFinalHandler) HandleEnableKinesisStreamingDestination(ctx *EnableKinesisStreamingDestinationContext, ...)

+ type EnableKinesisStreamingDestinationHandler interface

+ HandleEnableKinesisStreamingDestination func(ctx *EnableKinesisStreamingDestinationContext, ...)

+ type EnableKinesisStreamingDestinationHandlerFunc func(ctx *EnableKinesisStreamingDestinationContext, ...)

+ func (h EnableKinesisStreamingDestinationHandlerFunc) HandleEnableKinesisStreamingDestination(ctx *EnableKinesisStreamingDestinationContext, ...)

+ type EnableKinesisStreamingDestinationMiddleWare interface

+ EnableKinesisStreamingDestinationMiddleWare func(next EnableKinesisStreamingDestinationHandler) EnableKinesisStreamingDestinationHandler

+ type EnableKinesisStreamingDestinationMiddleWareFunc func(next EnableKinesisStreamingDestinationHandler) EnableKinesisStreamingDestinationHandler

+ func (mw EnableKinesisStreamingDestinationMiddleWareFunc) EnableKinesisStreamingDestinationMiddleWare(next EnableKinesisStreamingDestinationHandler) EnableKinesisStreamingDestinationHandler

+ type EnableKinesisStreamingDestinationOutput struct

+ func (o *EnableKinesisStreamingDestinationOutput) Get() (out *ddb.EnableKinesisStreamingDestinationOutput, err error)

+ func (o *EnableKinesisStreamingDestinationOutput) Set(out *ddb.EnableKinesisStreamingDestinationOutput, err error)

+ type ErrSet struct

+ Errors []error

+ func NewErrSet(errs []error) *ErrSet

+ func (e *ErrSet) AddErr(errs ...error)

+ func (e *ErrSet) Err() error

+ func (e *ErrSet) Error() string

+ type ExecuteStatement struct

+ func NewExecuteStatement(input *ddb.ExecuteStatementInput, mws ...ExecuteStatementMiddleWare) *ExecuteStatement

+ func (op *ExecuteStatement) Await() (*ddb.ExecuteStatementOutput, error)

+ func (op *ExecuteStatement) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ExecuteStatement) Invoke(ctx context.Context, client *ddb.Client) *ExecuteStatement

+ type ExecuteStatementContext struct

+ type ExecuteStatementFinalHandler struct

+ func (h *ExecuteStatementFinalHandler) HandleExecuteStatement(ctx *ExecuteStatementContext, output *ExecuteStatementOutput)

+ type ExecuteStatementHandler interface

+ HandleExecuteStatement func(ctx *ExecuteStatementContext, output *ExecuteStatementOutput)

+ type ExecuteStatementHandlerFunc func(ctx *ExecuteStatementContext, output *ExecuteStatementOutput)

+ func (h ExecuteStatementHandlerFunc) HandleExecuteStatement(ctx *ExecuteStatementContext, output *ExecuteStatementOutput)

+ type ExecuteStatementMiddleWare interface

+ ExecuteStatementMiddleWare func(next ExecuteStatementHandler) ExecuteStatementHandler

+ type ExecuteStatementMiddleWareFunc func(next ExecuteStatementHandler) ExecuteStatementHandler

+ func (mw ExecuteStatementMiddleWareFunc) ExecuteStatementMiddleWare(next ExecuteStatementHandler) ExecuteStatementHandler

+ type ExecuteStatementOutput struct

+ func (o *ExecuteStatementOutput) Get() (out *ddb.ExecuteStatementOutput, err error)

+ func (o *ExecuteStatementOutput) Set(out *ddb.ExecuteStatementOutput, err error)

+ type ExecuteTransaction struct

+ func NewExecuteTransaction(input *ddb.ExecuteTransactionInput, mws ...ExecuteTransactionMiddleWare) *ExecuteTransaction

+ func (op *ExecuteTransaction) Await() (*ddb.ExecuteTransactionOutput, error)

+ func (op *ExecuteTransaction) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ExecuteTransaction) Invoke(ctx context.Context, client *ddb.Client) *ExecuteTransaction

+ type ExecuteTransactionContext struct

+ type ExecuteTransactionFinalHandler struct

+ func (h *ExecuteTransactionFinalHandler) HandleExecuteTransaction(ctx *ExecuteTransactionContext, output *ExecuteTransactionOutput)

+ type ExecuteTransactionHandler interface

+ HandleExecuteTransaction func(ctx *ExecuteTransactionContext, output *ExecuteTransactionOutput)

+ type ExecuteTransactionHandlerFunc func(ctx *ExecuteTransactionContext, output *ExecuteTransactionOutput)

+ func (h ExecuteTransactionHandlerFunc) HandleExecuteTransaction(ctx *ExecuteTransactionContext, output *ExecuteTransactionOutput)

+ type ExecuteTransactionMiddleWare interface

+ ExecuteTransactionMiddleWare func(next ExecuteTransactionHandler) ExecuteTransactionHandler

+ type ExecuteTransactionMiddleWareFunc func(next ExecuteTransactionHandler) ExecuteTransactionHandler

+ func (mw ExecuteTransactionMiddleWareFunc) ExecuteTransactionMiddleWare(next ExecuteTransactionHandler) ExecuteTransactionHandler

+ type ExecuteTransactionOutput struct

+ func (o *ExecuteTransactionOutput) Get() (out *ddb.ExecuteTransactionOutput, err error)

+ func (o *ExecuteTransactionOutput) Set(out *ddb.ExecuteTransactionOutput, err error)

+ type ExportTableToPointInTime struct

+ func NewExportTableToPointInTime(input *ddb.ExportTableToPointInTimeInput, ...) *ExportTableToPointInTime

+ func (op *ExportTableToPointInTime) Await() (*ddb.ExportTableToPointInTimeOutput, error)

+ func (op *ExportTableToPointInTime) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ExportTableToPointInTime) Invoke(ctx context.Context, client *ddb.Client) *ExportTableToPointInTime

+ type ExportTableToPointInTimeContext struct

+ type ExportTableToPointInTimeFinalHandler struct

+ func (h *ExportTableToPointInTimeFinalHandler) HandleExportTableToPointInTime(ctx *ExportTableToPointInTimeContext, output *ExportTableToPointInTimeOutput)

+ type ExportTableToPointInTimeHandler interface

+ HandleExportTableToPointInTime func(ctx *ExportTableToPointInTimeContext, output *ExportTableToPointInTimeOutput)

+ type ExportTableToPointInTimeHandlerFunc func(ctx *ExportTableToPointInTimeContext, output *ExportTableToPointInTimeOutput)

+ func (h ExportTableToPointInTimeHandlerFunc) HandleExportTableToPointInTime(ctx *ExportTableToPointInTimeContext, output *ExportTableToPointInTimeOutput)

+ type ExportTableToPointInTimeMiddleWare interface

+ ExportTableToPointInTimeMiddleWare func(next ExportTableToPointInTimeHandler) ExportTableToPointInTimeHandler

+ type ExportTableToPointInTimeMiddleWareFunc func(next ExportTableToPointInTimeHandler) ExportTableToPointInTimeHandler

+ func (mw ExportTableToPointInTimeMiddleWareFunc) ExportTableToPointInTimeMiddleWare(next ExportTableToPointInTimeHandler) ExportTableToPointInTimeHandler

+ type ExportTableToPointInTimeOutput struct

+ func (o *ExportTableToPointInTimeOutput) Get() (out *ddb.ExportTableToPointInTimeOutput, err error)

+ func (o *ExportTableToPointInTimeOutput) Set(out *ddb.ExportTableToPointInTimeOutput, err error)

+ type GSI struct

+ PartitionKeyAttributeDefinition *ddb.AttributeDefinition

+ SortKeyAttributeDefinition *ddb.AttributeDefinition

+ func NewGSI(name string) *GSI

+ func (g *GSI) AddProjectionNames(names ...string) *GSI

+ func (g *GSI) DynamoGlobalSecondaryIndex() ddb.GlobalSecondaryIndex

+ func (g *GSI) ExtractAllKeys(avMaps []map[string]ddb.AttributeValue) []map[string]ddb.AttributeValue

+ func (g *GSI) ExtractKeys(avMap map[string]ddb.AttributeValue) map[string]ddb.AttributeValue

+ func (g *GSI) IsOnDemand() bool

+ func (g *GSI) PartitionKeyName() *string

+ func (g *GSI) SetCostUnits(wcus, rcus int64) *GSI

+ func (g *GSI) SetOnDemand() *GSI

+ func (g *GSI) SetPartitionKey(pkName string, attributeType ddb.ScalarAttributeType) *GSI

+ func (g *GSI) SetProjectionTypeKeysOnly(skName string) *GSI

+ func (g *GSI) SetSortKey(skName string, attributeType ddb.ScalarAttributeType) *GSI

+ func (g *GSI) SortKeyName() *string

+ type GetItem struct

+ func NewGetItem(input *ddb.GetItemInput, mws ...GetItemMiddleWare) *GetItem

+ func (op *GetItem) Await() (*ddb.GetItemOutput, error)

+ func (op *GetItem) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *GetItem) Invoke(ctx context.Context, client *ddb.Client) *GetItem

+ type GetItemBuilder struct

+ func NewGetItemBuilder(input *ddb.GetItemInput) *GetItemBuilder

+ func (bld *GetItemBuilder) AddProjectionNames(names ...string) *GetItemBuilder

+ func (bld *GetItemBuilder) Build() (*ddb.GetItemInput, error)

+ func (bld *GetItemBuilder) SetConsistentRead(v bool) *GetItemBuilder

+ func (bld *GetItemBuilder) SetExpressionAttributeNames(v map[string]string) *GetItemBuilder

+ func (bld *GetItemBuilder) SetInput(input *ddb.GetItemInput) *GetItemBuilder

+ func (bld *GetItemBuilder) SetKey(v map[string]ddbTypes.AttributeValue) *GetItemBuilder

+ func (bld *GetItemBuilder) SetProjectionExpression(v string) *GetItemBuilder

+ func (bld *GetItemBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *GetItemBuilder

+ func (bld *GetItemBuilder) SetTableName(v string) *GetItemBuilder

+ type GetItemContext struct

+ type GetItemFinalHandler struct

+ func (h *GetItemFinalHandler) HandleGetItem(ctx *GetItemContext, output *GetItemOutput)

+ type GetItemHandler interface

+ HandleGetItem func(ctx *GetItemContext, output *GetItemOutput)

+ type GetItemHandlerFunc func(ctx *GetItemContext, output *GetItemOutput)

+ func (h GetItemHandlerFunc) HandleGetItem(ctx *GetItemContext, output *GetItemOutput)

+ type GetItemMiddleWare interface

+ GetItemMiddleWare func(next GetItemHandler) GetItemHandler

+ type GetItemMiddleWareFunc func(next GetItemHandler) GetItemHandler

+ func (mw GetItemMiddleWareFunc) GetItemMiddleWare(next GetItemHandler) GetItemHandler

+ type GetItemOutput struct

+ func (o *GetItemOutput) Get() (out *ddb.GetItemOutput, err error)

+ func (o *GetItemOutput) Set(out *ddb.GetItemOutput, err error)

+ type LSI struct

+ PartitionKeyAttributeDefinition *ddb.AttributeDefinition

+ SortKeyAttributeDefinition *ddb.AttributeDefinition

+ func NewLSI(name string) *LSI

+ func (l *LSI) AddProjectionNames(names ...string) *LSI

+ func (l *LSI) DynamoLocalSecondaryIndex() ddb.LocalSecondaryIndex

+ func (l *LSI) ExtractAllKeys(avMaps []map[string]ddb.AttributeValue) []map[string]ddb.AttributeValue

+ func (l *LSI) ExtractKeys(avMap map[string]ddb.AttributeValue) map[string]ddb.AttributeValue

+ func (l *LSI) GetIndexName() string

+ func (l *LSI) PartitionKeyName() *string

+ func (l *LSI) SetPartitionKey(pkName string, attributeType ddb.ScalarAttributeType) *LSI

+ func (l *LSI) SetProjectionTypeKeysOnly(skName string) *LSI

+ func (l *LSI) SetSortKey(skName string, attributeType ddb.ScalarAttributeType) *LSI

+ func (l *LSI) SortKeyName() *string

+ type ListBackups struct

+ func NewListBackups(input *ddb.ListBackupsInput, mws ...ListBackupsMiddleWare) *ListBackups

+ func (op *ListBackups) Await() (*ddb.ListBackupsOutput, error)

+ func (op *ListBackups) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ListBackups) Invoke(ctx context.Context, client *ddb.Client) *ListBackups

+ type ListBackupsContext struct

+ type ListBackupsFinalHandler struct

+ func (h *ListBackupsFinalHandler) HandleListBackups(ctx *ListBackupsContext, output *ListBackupsOutput)

+ type ListBackupsHandler interface

+ HandleListBackups func(ctx *ListBackupsContext, output *ListBackupsOutput)

+ type ListBackupsHandlerFunc func(ctx *ListBackupsContext, output *ListBackupsOutput)

+ func (h ListBackupsHandlerFunc) HandleListBackups(ctx *ListBackupsContext, output *ListBackupsOutput)

+ type ListBackupsMiddleWare interface

+ ListBackupsMiddleWare func(next ListBackupsHandler) ListBackupsHandler

+ type ListBackupsMiddleWareFunc func(next ListBackupsHandler) ListBackupsHandler

+ func (mw ListBackupsMiddleWareFunc) ListBackupsMiddleWare(next ListBackupsHandler) ListBackupsHandler

+ type ListBackupsOutput struct

+ func (o *ListBackupsOutput) Get() (out *ddb.ListBackupsOutput, err error)

+ func (o *ListBackupsOutput) Set(out *ddb.ListBackupsOutput, err error)

+ type ListContributorInsights struct

+ func NewListContributorInsights(input *ddb.ListContributorInsightsInput, ...) *ListContributorInsights

+ func (op *ListContributorInsights) Await() (*ddb.ListContributorInsightsOutput, error)

+ func (op *ListContributorInsights) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ListContributorInsights) Invoke(ctx context.Context, client *ddb.Client) *ListContributorInsights

+ type ListContributorInsightsContext struct

+ type ListContributorInsightsFinalHandler struct

+ func (h *ListContributorInsightsFinalHandler) HandleListContributorInsights(ctx *ListContributorInsightsContext, output *ListContributorInsightsOutput)

+ type ListContributorInsightsHandler interface

+ HandleListContributorInsights func(ctx *ListContributorInsightsContext, output *ListContributorInsightsOutput)

+ type ListContributorInsightsHandlerFunc func(ctx *ListContributorInsightsContext, output *ListContributorInsightsOutput)

+ func (h ListContributorInsightsHandlerFunc) HandleListContributorInsights(ctx *ListContributorInsightsContext, output *ListContributorInsightsOutput)

+ type ListContributorInsightsMiddleWare interface

+ ListContributorInsightsMiddleWare func(next ListContributorInsightsHandler) ListContributorInsightsHandler

+ type ListContributorInsightsMiddleWareFunc func(next ListContributorInsightsHandler) ListContributorInsightsHandler

+ func (mw ListContributorInsightsMiddleWareFunc) ListContributorInsightsMiddleWare(next ListContributorInsightsHandler) ListContributorInsightsHandler

+ type ListContributorInsightsOutput struct

+ func (o *ListContributorInsightsOutput) Get() (out *ddb.ListContributorInsightsOutput, err error)

+ func (o *ListContributorInsightsOutput) Set(out *ddb.ListContributorInsightsOutput, err error)

+ type ListExports struct

+ func NewListExports(input *ddb.ListExportsInput, mws ...ListExportsMiddleWare) *ListExports

+ func (op *ListExports) Await() (*ddb.ListExportsOutput, error)

+ func (op *ListExports) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ListExports) Invoke(ctx context.Context, client *ddb.Client) *ListExports

+ type ListExportsContext struct

+ type ListExportsFinalHandler struct

+ func (h *ListExportsFinalHandler) HandleListExports(ctx *ListExportsContext, output *ListExportsOutput)

+ type ListExportsHandler interface

+ HandleListExports func(ctx *ListExportsContext, output *ListExportsOutput)

+ type ListExportsHandlerFunc func(ctx *ListExportsContext, output *ListExportsOutput)

+ func (h ListExportsHandlerFunc) HandleListExports(ctx *ListExportsContext, output *ListExportsOutput)

+ type ListExportsMiddleWare interface

+ ListExportsMiddleWare func(next ListExportsHandler) ListExportsHandler

+ type ListExportsMiddleWareFunc func(next ListExportsHandler) ListExportsHandler

+ func (mw ListExportsMiddleWareFunc) ListExportsMiddleWare(next ListExportsHandler) ListExportsHandler

+ type ListExportsOutput struct

+ func (o *ListExportsOutput) Get() (out *ddb.ListExportsOutput, err error)

+ func (o *ListExportsOutput) Set(out *ddb.ListExportsOutput, err error)

+ type ListGlobalTables struct

+ func NewListGlobalTables(input *ddb.ListGlobalTablesInput, mws ...ListGlobalTablesMiddleWare) *ListGlobalTables

+ func (op *ListGlobalTables) Await() (*ddb.ListGlobalTablesOutput, error)

+ func (op *ListGlobalTables) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ListGlobalTables) Invoke(ctx context.Context, client *ddb.Client) *ListGlobalTables

+ type ListGlobalTablesContext struct

+ type ListGlobalTablesFinalHandler struct

+ func (h *ListGlobalTablesFinalHandler) HandleListGlobalTables(ctx *ListGlobalTablesContext, output *ListGlobalTablesOutput)

+ type ListGlobalTablesHandler interface

+ HandleListGlobalTables func(ctx *ListGlobalTablesContext, output *ListGlobalTablesOutput)

+ type ListGlobalTablesHandlerFunc func(ctx *ListGlobalTablesContext, output *ListGlobalTablesOutput)

+ func (h ListGlobalTablesHandlerFunc) HandleListGlobalTables(ctx *ListGlobalTablesContext, output *ListGlobalTablesOutput)

+ type ListGlobalTablesMiddleWare interface

+ ListGlobalTablesMiddleWare func(next ListGlobalTablesHandler) ListGlobalTablesHandler

+ type ListGlobalTablesMiddleWareFunc func(next ListGlobalTablesHandler) ListGlobalTablesHandler

+ func (mw ListGlobalTablesMiddleWareFunc) ListGlobalTablesMiddleWare(next ListGlobalTablesHandler) ListGlobalTablesHandler

+ type ListGlobalTablesOutput struct

+ func (o *ListGlobalTablesOutput) Get() (out *ddb.ListGlobalTablesOutput, err error)

+ func (o *ListGlobalTablesOutput) Set(out *ddb.ListGlobalTablesOutput, err error)

+ type ListTables struct

+ func NewListTables(input *ddb.ListTablesInput, mws ...ListTablesMiddleWare) *ListTables

+ func (op *ListTables) Await() (*ddb.ListTablesOutput, error)

+ func (op *ListTables) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ListTables) Invoke(ctx context.Context, client *ddb.Client) *ListTables

+ type ListTablesContext struct

+ type ListTablesFinalHandler struct

+ func (h *ListTablesFinalHandler) HandleListTables(ctx *ListTablesContext, output *ListTablesOutput)

+ type ListTablesHandler interface

+ HandleListTables func(ctx *ListTablesContext, output *ListTablesOutput)

+ type ListTablesHandlerFunc func(ctx *ListTablesContext, output *ListTablesOutput)

+ func (h ListTablesHandlerFunc) HandleListTables(ctx *ListTablesContext, output *ListTablesOutput)

+ type ListTablesMiddleWare interface

+ ListTablesMiddleWare func(next ListTablesHandler) ListTablesHandler

+ type ListTablesMiddleWareFunc func(next ListTablesHandler) ListTablesHandler

+ func (mw ListTablesMiddleWareFunc) ListTablesMiddleWare(next ListTablesHandler) ListTablesHandler

+ type ListTablesOutput struct

+ func (o *ListTablesOutput) Get() (out *ddb.ListTablesOutput, err error)

+ func (o *ListTablesOutput) Set(out *ddb.ListTablesOutput, err error)

+ type ListTagsOfResource struct

+ func NewListTagsOfResource(input *ddb.ListTagsOfResourceInput, mws ...ListTagsOfResourceMiddleWare) *ListTagsOfResource

+ func (op *ListTagsOfResource) Await() (*ddb.ListTagsOfResourceOutput, error)

+ func (op *ListTagsOfResource) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ListTagsOfResource) Invoke(ctx context.Context, client *ddb.Client) *ListTagsOfResource

+ type ListTagsOfResourceContext struct

+ type ListTagsOfResourceFinalHandler struct

+ func (h *ListTagsOfResourceFinalHandler) HandleListTagsOfResource(ctx *ListTagsOfResourceContext, output *ListTagsOfResourceOutput)

+ type ListTagsOfResourceHandler interface

+ HandleListTagsOfResource func(ctx *ListTagsOfResourceContext, output *ListTagsOfResourceOutput)

+ type ListTagsOfResourceHandlerFunc func(ctx *ListTagsOfResourceContext, output *ListTagsOfResourceOutput)

+ func (h ListTagsOfResourceHandlerFunc) HandleListTagsOfResource(ctx *ListTagsOfResourceContext, output *ListTagsOfResourceOutput)

+ type ListTagsOfResourceMiddleWare interface

+ ListTagsOfResourceMiddleWare func(next ListTagsOfResourceHandler) ListTagsOfResourceHandler

+ type ListTagsOfResourceMiddleWareFunc func(next ListTagsOfResourceHandler) ListTagsOfResourceHandler

+ func (mw ListTagsOfResourceMiddleWareFunc) ListTagsOfResourceMiddleWare(next ListTagsOfResourceHandler) ListTagsOfResourceHandler

+ type ListTagsOfResourceOutput struct

+ func (o *ListTagsOfResourceOutput) Get() (out *ddb.ListTagsOfResourceOutput, err error)

+ func (o *ListTagsOfResourceOutput) Set(out *ddb.ListTagsOfResourceOutput, err error)

+ type Operation interface

+ DynoInvoke func(context.Context, *ddb.Client)

+ type OperationF func(context.Context, *ddb.Client)

+ func (op OperationF) DynoInvoke(ctx context.Context, client *ddb.Client)

+ type Pool struct

+ func NewPool(ctx context.Context, client *ddb.Client, limit uint64) *Pool

+ func (p *Pool) ActiveCount() uint64

+ func (p *Pool) BatchExecuteStatement(input *ddb.BatchExecuteStatementInput, mw ...BatchExecuteStatementMiddleWare) *BatchExecuteStatement

+ func (p *Pool) BatchGetItem(input *ddb.BatchGetItemInput, mw ...BatchGetItemMiddleWare) *BatchGetItem

+ func (p *Pool) BatchGetItemAll(input *ddb.BatchGetItemInput, mw ...BatchGetItemAllMiddleWare) *BatchGetItemAll

+ func (p *Pool) BatchWriteItem(input *ddb.BatchWriteItemInput, mw ...BatchWriteItemMiddleWare) *BatchWriteItem

+ func (p *Pool) BatchWriteItemAll(input *ddb.BatchWriteItemInput, mw ...BatchWriteItemAllMiddleWare) *BatchWriteItemAll

+ func (p *Pool) CreateBackup(input *ddb.CreateBackupInput, mw ...CreateBackupMiddleWare) *CreateBackup

+ func (p *Pool) CreateGlobalTable(input *ddb.CreateGlobalTableInput, mw ...CreateGlobalTableMiddleWare) *CreateGlobalTable

+ func (p *Pool) CreateTable(input *ddb.CreateTableInput, mw ...CreateTableMiddleWare) *CreateTable

+ func (p *Pool) DeleteBackup(input *ddb.DeleteBackupInput, mw ...DeleteBackupMiddleWare) *DeleteBackup

+ func (p *Pool) DeleteItem(input *ddb.DeleteItemInput, mw ...DeleteItemMiddleWare) *DeleteItem

+ func (p *Pool) DeleteTable(input *ddb.DeleteTableInput, mw ...DeleteTableMiddleWare) *DeleteTable

+ func (p *Pool) DescribeBackup(input *ddb.DescribeBackupInput, mw ...DescribeBackupMiddleWare) *DescribeBackup

+ func (p *Pool) DescribeContinuousBackups(input *ddb.DescribeContinuousBackupsInput, ...) *DescribeContinuousBackups

+ func (p *Pool) DescribeContributorInsights(input *ddb.DescribeContributorInsightsInput, ...) *DescribeContributorInsights

+ func (p *Pool) DescribeEndpoints(input *ddb.DescribeEndpointsInput, mw ...DescribeEndpointsMiddleWare) *DescribeEndpoints

+ func (p *Pool) DescribeExport(input *ddb.DescribeExportInput, mw ...DescribeExportMiddleWare) *DescribeExport

+ func (p *Pool) DescribeGlobalTable(input *ddb.DescribeGlobalTableInput, mw ...DescribeGlobalTableMiddleWare) *DescribeGlobalTable

+ func (p *Pool) DescribeGlobalTableSettings(input *ddb.DescribeGlobalTableSettingsInput, ...) *DescribeGlobalTableSettings

+ func (p *Pool) DescribeKinesisStreamingDestination(input *ddb.DescribeKinesisStreamingDestinationInput, ...) *DescribeKinesisStreamingDestination

+ func (p *Pool) DescribeLimits(input *ddb.DescribeLimitsInput, mw ...DescribeLimitsMiddleWare) *DescribeLimits

+ func (p *Pool) DescribeTable(input *ddb.DescribeTableInput, mw ...DescribeTableMiddleWare) *DescribeTable

+ func (p *Pool) DescribeTableReplicaAutoScaling(input *ddb.DescribeTableReplicaAutoScalingInput, ...) *DescribeTableReplicaAutoScaling

+ func (p *Pool) DescribeTimeToLive(input *ddb.DescribeTimeToLiveInput, mw ...DescribeTimeToLiveMiddleWare) *DescribeTimeToLive

+ func (p *Pool) DisableKinesisStreamingDestination(input *ddb.DisableKinesisStreamingDestinationInput, ...) *DisableKinesisStreamingDestination

+ func (p *Pool) Do(ops ...Operation) (err error)

+ func (p *Pool) EnableKinesisStreamingDestination(input *ddb.EnableKinesisStreamingDestinationInput, ...) *EnableKinesisStreamingDestination

+ func (p *Pool) ExecuteStatement(input *ddb.ExecuteStatementInput, mw ...ExecuteStatementMiddleWare) *ExecuteStatement

+ func (p *Pool) ExecuteTransaction(input *ddb.ExecuteTransactionInput, mw ...ExecuteTransactionMiddleWare) *ExecuteTransaction

+ func (p *Pool) ExportTableToPointInTime(input *ddb.ExportTableToPointInTimeInput, ...) *ExportTableToPointInTime

+ func (p *Pool) GetItem(input *ddb.GetItemInput, mw ...GetItemMiddleWare) *GetItem

+ func (p *Pool) ID() string

+ func (p *Pool) Limit() uint64

+ func (p *Pool) ListBackups(input *ddb.ListBackupsInput, mw ...ListBackupsMiddleWare) *ListBackups

+ func (p *Pool) ListContributorInsights(input *ddb.ListContributorInsightsInput, ...) *ListContributorInsights

+ func (p *Pool) ListExports(input *ddb.ListExportsInput, mw ...ListExportsMiddleWare) *ListExports

+ func (p *Pool) ListGlobalTables(input *ddb.ListGlobalTablesInput, mw ...ListGlobalTablesMiddleWare) *ListGlobalTables

+ func (p *Pool) ListTables(input *ddb.ListTablesInput, mw ...ListTablesMiddleWare) *ListTables

+ func (p *Pool) ListTagsOfResource(input *ddb.ListTagsOfResourceInput, mw ...ListTagsOfResourceMiddleWare) *ListTagsOfResource

+ func (p *Pool) PutItem(input *ddb.PutItemInput, mw ...PutItemMiddleWare) *PutItem

+ func (p *Pool) Query(input *ddb.QueryInput, mw ...QueryMiddleWare) *Query

+ func (p *Pool) QueryAll(input *ddb.QueryInput, mw ...QueryAllMiddleWare) *QueryAll

+ func (p *Pool) RestoreTableFromBackup(input *ddb.RestoreTableFromBackupInput, mw ...RestoreTableFromBackupMiddleWare) *RestoreTableFromBackup

+ func (p *Pool) RestoreTableToPointInTime(input *ddb.RestoreTableToPointInTimeInput, ...) *RestoreTableToPointInTime

+ func (p *Pool) Scan(input *ddb.ScanInput, mw ...ScanMiddleWare) *Scan

+ func (p *Pool) ScanAll(input *ddb.ScanInput, mw ...ScanAllMiddleWare) *ScanAllPromise

+ func (p *Pool) String() string

+ func (p *Pool) TableExistsWaiter(input *ddb.DescribeTableInput, mw ...DescribeTableMiddleWare) *TableExistsWaiter

+ func (p *Pool) TableNotExistsWaiter(input *ddb.DescribeTableInput, mw ...DescribeTableMiddleWare) *TableNotExistsWaiter

+ func (p *Pool) TagResource(input *ddb.TagResourceInput, mw ...TagResourceMiddleWare) *TagResource

+ func (p *Pool) TransactGetItems(input *ddb.TransactGetItemsInput, mw ...TransactGetItemsMiddleWare) *TransactGetItems

+ func (p *Pool) TransactWriteItems(input *ddb.TransactWriteItemsInput, mw ...TransactWriteItemsMiddleWare) *TransactWriteItems

+ func (p *Pool) UntagResource(input *ddb.UntagResourceInput, mw ...UntagResourceMiddleWare) *UntagResource

+ func (p *Pool) UpdateContinuousBackups(input *ddb.UpdateContinuousBackupsInput, ...) *UpdateContinuousBackups

+ func (p *Pool) UpdateContributorInsights(input *ddb.UpdateContributorInsightsInput, ...) *UpdateContributorInsights

+ func (p *Pool) UpdateGlobalTable(input *ddb.UpdateGlobalTableInput, mw ...UpdateGlobalTableMiddleWare) *UpdateGlobalTable

+ func (p *Pool) UpdateGlobalTableSettings(input *ddb.UpdateGlobalTableSettingsInput, ...) *UpdateGlobalTableSettings

+ func (p *Pool) UpdateItem(input *ddb.UpdateItemInput, mw ...UpdateItemMiddleWare) *UpdateItem

+ func (p *Pool) UpdateTable(input *ddb.UpdateTableInput, mw ...UpdateTableMiddleWare) *UpdateTable

+ func (p *Pool) UpdateTableReplicaAutoScaling(input *ddb.UpdateTableReplicaAutoScalingInput, ...) *UpdateTableReplicaAutoScaling

+ func (p *Pool) UpdateTimeToLive(input *ddb.UpdateTimeToLiveInput, mw ...UpdateTimeToLiveMiddleWare) *UpdateTimeToLive

+ func (p *Pool) Wait() <-chan struct{}

+ type Promise struct

+ func NewPromise() *Promise

+ func (p *Promise) Await() (interface{}, error)

+ func (p *Promise) Done() <-chan struct{}

+ func (p *Promise) Duration() time.Duration

+ func (p *Promise) GetResponse() (interface{}, error)

+ func (p *Promise) ID() string

+ func (p *Promise) SetResponse(val interface{}, err error)

+ func (p *Promise) Start()

+ type PromiseError string

+ func (e PromiseError) Error() string

+ type PutItem struct

+ func NewPutItem(input *ddb.PutItemInput, mws ...PutItemMiddleWare) *PutItem

+ func (op *PutItem) Await() (*ddb.PutItemOutput, error)

+ func (op *PutItem) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *PutItem) Invoke(ctx context.Context, client *ddb.Client) *PutItem

+ type PutItemBuilder struct

+ func NewPutItemBuilder(input *ddb.PutItemInput) *PutItemBuilder

+ func (bld *PutItemBuilder) AddCondition(cnd expression.ConditionBuilder) *PutItemBuilder

+ func (bld *PutItemBuilder) Build() (*ddb.PutItemInput, error)

+ func (bld *PutItemBuilder) SetConditionExpression(v string) *PutItemBuilder

+ func (bld *PutItemBuilder) SetConditionalOperator(v ddbTypes.ConditionalOperator) *PutItemBuilder

+ func (bld *PutItemBuilder) SetExpected(v map[string]ddbTypes.ExpectedAttributeValue) *PutItemBuilder

+ func (bld *PutItemBuilder) SetExpressionAttributeNames(v map[string]string) *PutItemBuilder

+ func (bld *PutItemBuilder) SetExpressionAttributeValues(v map[string]ddbTypes.AttributeValue) *PutItemBuilder

+ func (bld *PutItemBuilder) SetItem(item map[string]ddbTypes.AttributeValue) *PutItemBuilder

+ func (bld *PutItemBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *PutItemBuilder

+ func (bld *PutItemBuilder) SetReturnItemCollectionMetrics(v ddbTypes.ReturnItemCollectionMetrics) *PutItemBuilder

+ func (bld *PutItemBuilder) SetReturnValues(v ddbTypes.ReturnValue) *PutItemBuilder

+ func (bld *PutItemBuilder) SetTableName(v string) *PutItemBuilder

+ type PutItemContext struct

+ type PutItemFinalHandler struct

+ func (h *PutItemFinalHandler) HandlePutItem(ctx *PutItemContext, output *PutItemOutput)

+ type PutItemHandler interface

+ HandlePutItem func(ctx *PutItemContext, output *PutItemOutput)

+ type PutItemHandlerFunc func(ctx *PutItemContext, output *PutItemOutput)

+ func (h PutItemHandlerFunc) HandlePutItem(ctx *PutItemContext, output *PutItemOutput)

+ type PutItemMiddleWare interface

+ PutItemMiddleWare func(next PutItemHandler) PutItemHandler

+ type PutItemMiddleWareFunc func(next PutItemHandler) PutItemHandler

+ func (mw PutItemMiddleWareFunc) PutItemMiddleWare(next PutItemHandler) PutItemHandler

+ type PutItemOutput struct

+ func (o *PutItemOutput) Get() (out *ddb.PutItemOutput, err error)

+ func (o *PutItemOutput) Set(out *ddb.PutItemOutput, err error)

+ type Query struct

+ func NewQuery(input *ddb.QueryInput, mws ...QueryMiddleWare) *Query

+ func (op *Query) Await() (*ddb.QueryOutput, error)

+ func (op *Query) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *Query) Invoke(ctx context.Context, client *ddb.Client) *Query

+ type QueryAll struct

+ func NewQueryAll(input *ddb.QueryInput, mws ...QueryAllMiddleWare) *QueryAll

+ func (op *QueryAll) Await() ([]*ddb.QueryOutput, error)

+ func (op *QueryAll) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *QueryAll) Invoke(ctx context.Context, client *ddb.Client) *QueryAll

+ type QueryAllContext struct

+ type QueryAllFinalHandler struct

+ func (h *QueryAllFinalHandler) HandleQueryAll(ctx *QueryAllContext, output *QueryAllOutput)

+ type QueryAllHandler interface

+ HandleQueryAll func(ctx *QueryAllContext, output *QueryAllOutput)

+ type QueryAllHandlerFunc func(ctx *QueryAllContext, output *QueryAllOutput)

+ func (h QueryAllHandlerFunc) HandleQueryAll(ctx *QueryAllContext, output *QueryAllOutput)

+ type QueryAllMiddleWare interface

+ QueryAllMiddleWare func(next QueryAllHandler) QueryAllHandler

+ type QueryAllMiddleWareFunc func(next QueryAllHandler) QueryAllHandler

+ func (mw QueryAllMiddleWareFunc) QueryAllMiddleWare(next QueryAllHandler) QueryAllHandler

+ type QueryAllOutput struct

+ func (o *QueryAllOutput) Get() (out []*ddb.QueryOutput, err error)

+ func (o *QueryAllOutput) Set(out []*ddb.QueryOutput, err error)

+ type QueryBuilder struct

+ func NewQueryBuilder(input *ddb.QueryInput) *QueryBuilder

+ func (bld *QueryBuilder) AddFilter(cnd expression.ConditionBuilder) *QueryBuilder

+ func (bld *QueryBuilder) AddKeyCondition(cnd expression.KeyConditionBuilder) *QueryBuilder

+ func (bld *QueryBuilder) AddKeyEquals(fieldName string, value interface{}) *QueryBuilder

+ func (bld *QueryBuilder) AddProjectionNames(names ...string) *QueryBuilder

+ func (bld *QueryBuilder) Build() (*ddb.QueryInput, error)

+ func (bld *QueryBuilder) SetAscOrder() *QueryBuilder

+ func (bld *QueryBuilder) SetAttributesToGet(v []string) *QueryBuilder

+ func (bld *QueryBuilder) SetConditionalOperator(v ddbTypes.ConditionalOperator) *QueryBuilder

+ func (bld *QueryBuilder) SetConsistentRead(v bool) *QueryBuilder

+ func (bld *QueryBuilder) SetDescOrder() *QueryBuilder

+ func (bld *QueryBuilder) SetExclusiveStartKey(v map[string]ddbTypes.AttributeValue) *QueryBuilder

+ func (bld *QueryBuilder) SetExpressionAttributeNames(v map[string]string) *QueryBuilder

+ func (bld *QueryBuilder) SetExpressionAttributeValues(v map[string]ddbTypes.AttributeValue) *QueryBuilder

+ func (bld *QueryBuilder) SetFilterExpression(v string) *QueryBuilder

+ func (bld *QueryBuilder) SetIndexName(v string) *QueryBuilder

+ func (bld *QueryBuilder) SetKeyConditionExpression(v string) *QueryBuilder

+ func (bld *QueryBuilder) SetKeyConditions(v map[string]ddbTypes.Condition) *QueryBuilder

+ func (bld *QueryBuilder) SetLimit(v int32) *QueryBuilder

+ func (bld *QueryBuilder) SetProjectionExpression(v string) *QueryBuilder

+ func (bld *QueryBuilder) SetQueryFilter(v map[string]ddbTypes.Condition) *QueryBuilder

+ func (bld *QueryBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *QueryBuilder

+ func (bld *QueryBuilder) SetScanIndexForward(v bool) *QueryBuilder

+ func (bld *QueryBuilder) SetSelect(v ddbTypes.Select) *QueryBuilder

+ func (bld *QueryBuilder) SetTableName(v string) *QueryBuilder

+ type QueryContext struct

+ type QueryFinalHandler struct

+ func (h *QueryFinalHandler) HandleQuery(ctx *QueryContext, output *QueryOutput)

+ type QueryHandler interface

+ HandleQuery func(ctx *QueryContext, output *QueryOutput)

+ type QueryHandlerFunc func(ctx *QueryContext, output *QueryOutput)

+ func (h QueryHandlerFunc) HandleQuery(ctx *QueryContext, output *QueryOutput)

+ type QueryMiddleWare interface

+ QueryMiddleWare func(next QueryHandler) QueryHandler

+ type QueryMiddleWareFunc func(next QueryHandler) QueryHandler

+ func (mw QueryMiddleWareFunc) QueryMiddleWare(next QueryHandler) QueryHandler

+ type QueryOutput struct

+ func (o *QueryOutput) Get() (out *ddb.QueryOutput, err error)

+ func (o *QueryOutput) Set(out *ddb.QueryOutput, err error)

+ type RestoreTableFromBackup struct

+ func NewRestoreTableFromBackup(input *ddb.RestoreTableFromBackupInput, ...) *RestoreTableFromBackup

+ func (op *RestoreTableFromBackup) Await() (*ddb.RestoreTableFromBackupOutput, error)

+ func (op *RestoreTableFromBackup) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *RestoreTableFromBackup) Invoke(ctx context.Context, client *ddb.Client) *RestoreTableFromBackup

+ type RestoreTableFromBackupContext struct

+ type RestoreTableFromBackupFinalHandler struct

+ func (h *RestoreTableFromBackupFinalHandler) HandleRestoreTableFromBackup(ctx *RestoreTableFromBackupContext, output *RestoreTableFromBackupOutput)

+ type RestoreTableFromBackupHandler interface

+ HandleRestoreTableFromBackup func(ctx *RestoreTableFromBackupContext, output *RestoreTableFromBackupOutput)

+ type RestoreTableFromBackupHandlerFunc func(ctx *RestoreTableFromBackupContext, output *RestoreTableFromBackupOutput)

+ func (h RestoreTableFromBackupHandlerFunc) HandleRestoreTableFromBackup(ctx *RestoreTableFromBackupContext, output *RestoreTableFromBackupOutput)

+ type RestoreTableFromBackupMiddleWare interface

+ RestoreTableFromBackupMiddleWare func(next RestoreTableFromBackupHandler) RestoreTableFromBackupHandler

+ type RestoreTableFromBackupMiddleWareFunc func(next RestoreTableFromBackupHandler) RestoreTableFromBackupHandler

+ func (mw RestoreTableFromBackupMiddleWareFunc) RestoreTableFromBackupMiddleWare(next RestoreTableFromBackupHandler) RestoreTableFromBackupHandler

+ type RestoreTableFromBackupOutput struct

+ func (o *RestoreTableFromBackupOutput) Get() (out *ddb.RestoreTableFromBackupOutput, err error)

+ func (o *RestoreTableFromBackupOutput) Set(out *ddb.RestoreTableFromBackupOutput, err error)

+ type RestoreTableToPointInTime struct

+ func NewRestoreTableToPointInTime(input *ddb.RestoreTableToPointInTimeInput, ...) *RestoreTableToPointInTime

+ func (op *RestoreTableToPointInTime) Await() (*ddb.RestoreTableToPointInTimeOutput, error)

+ func (op *RestoreTableToPointInTime) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *RestoreTableToPointInTime) Invoke(ctx context.Context, client *ddb.Client) *RestoreTableToPointInTime

+ type RestoreTableToPointInTimeContext struct

+ type RestoreTableToPointInTimeFinalHandler struct

+ func (h *RestoreTableToPointInTimeFinalHandler) HandleRestoreTableToPointInTime(ctx *RestoreTableToPointInTimeContext, output *RestoreTableToPointInTimeOutput)

+ type RestoreTableToPointInTimeHandler interface

+ HandleRestoreTableToPointInTime func(ctx *RestoreTableToPointInTimeContext, output *RestoreTableToPointInTimeOutput)

+ type RestoreTableToPointInTimeHandlerFunc func(ctx *RestoreTableToPointInTimeContext, output *RestoreTableToPointInTimeOutput)

+ func (h RestoreTableToPointInTimeHandlerFunc) HandleRestoreTableToPointInTime(ctx *RestoreTableToPointInTimeContext, output *RestoreTableToPointInTimeOutput)

+ type RestoreTableToPointInTimeMiddleWare interface

+ RestoreTableToPointInTimeMiddleWare func(next RestoreTableToPointInTimeHandler) RestoreTableToPointInTimeHandler

+ type RestoreTableToPointInTimeMiddleWareFunc func(next RestoreTableToPointInTimeHandler) RestoreTableToPointInTimeHandler

+ func (mw RestoreTableToPointInTimeMiddleWareFunc) RestoreTableToPointInTimeMiddleWare(next RestoreTableToPointInTimeHandler) RestoreTableToPointInTimeHandler

+ type RestoreTableToPointInTimeOutput struct

+ func (o *RestoreTableToPointInTimeOutput) Get() (out *ddb.RestoreTableToPointInTimeOutput, err error)

+ func (o *RestoreTableToPointInTimeOutput) Set(out *ddb.RestoreTableToPointInTimeOutput, err error)

+ type Scan struct

+ func NewScan(input *ddb.ScanInput, mws ...ScanMiddleWare) *Scan

+ func (op *Scan) Await() (*ddb.ScanOutput, error)

+ func (op *Scan) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *Scan) Invoke(ctx context.Context, client *ddb.Client) *Scan

+ type ScanAll struct

+ func NewScanAll(input *ddb.ScanInput, mws ...ScanAllMiddleWare) *ScanAll

+ func (op *ScanAll) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *ScanAll) Invoke(ctx context.Context, client *ddb.Client) *ScanAllPromise

+ type ScanAllContext struct

+ type ScanAllFinalHandler struct

+ func (h *ScanAllFinalHandler) HandleScanAll(ctx *ScanAllContext, output *ScanAllOutput)

+ type ScanAllHandler interface

+ HandleScanAll func(ctx *ScanAllContext, output *ScanAllOutput)

+ type ScanAllHandlerFunc func(ctx *ScanAllContext, output *ScanAllOutput)

+ func (h ScanAllHandlerFunc) HandleScanAll(ctx *ScanAllContext, output *ScanAllOutput)

+ type ScanAllMiddleWare interface

+ ScanAllMiddleWare func(next ScanAllHandler) ScanAllHandler

+ type ScanAllMiddleWareFunc func(next ScanAllHandler) ScanAllHandler

+ func (mw ScanAllMiddleWareFunc) ScanAllMiddleWare(next ScanAllHandler) ScanAllHandler

+ type ScanAllOutput struct

+ func (o *ScanAllOutput) Get() (out []*ddb.ScanOutput, err error)

+ func (o *ScanAllOutput) Set(out []*ddb.ScanOutput, err error)

+ type ScanAllPromise struct

+ func (p *ScanAllPromise) Await() ([]*ddb.ScanOutput, error)

+ func (p *ScanAllPromise) GetResponse() ([]*ddb.ScanOutput, error)

+ type ScanBuilder struct

+ func NewScanBuilder(input *ddb.ScanInput) *ScanBuilder

+ func (bld *ScanBuilder) AddFilter(cnd expression.ConditionBuilder) *ScanBuilder

+ func (bld *ScanBuilder) AddProjection(names interface{}) *ScanBuilder

+ func (bld *ScanBuilder) AddProjectionNames(names ...string) *ScanBuilder

+ func (bld *ScanBuilder) Build() (*ddb.ScanInput, error)

+ func (bld *ScanBuilder) BuildSegments(segments int32) ([]*ddb.ScanInput, error)

+ func (bld *ScanBuilder) SetConsistentRead(v bool) *ScanBuilder

+ func (bld *ScanBuilder) SetExclusiveStartKey(v map[string]ddbTypes.AttributeValue) *ScanBuilder

+ func (bld *ScanBuilder) SetExpressionAttributeNames(v map[string]string) *ScanBuilder

+ func (bld *ScanBuilder) SetExpressionAttributeValues(v map[string]ddbTypes.AttributeValue) *ScanBuilder

+ func (bld *ScanBuilder) SetFilterExpression(v string) *ScanBuilder

+ func (bld *ScanBuilder) SetIndexName(v string) *ScanBuilder

+ func (bld *ScanBuilder) SetInput(input *ddb.ScanInput) *ScanBuilder

+ func (bld *ScanBuilder) SetLimit(v int32) *ScanBuilder

+ func (bld *ScanBuilder) SetProjectionExpression(v string) *ScanBuilder

+ func (bld *ScanBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *ScanBuilder

+ func (bld *ScanBuilder) SetScanFilter(v map[string]ddbTypes.Condition) *ScanBuilder

+ func (bld *ScanBuilder) SetSegment(v int32) *ScanBuilder

+ func (bld *ScanBuilder) SetSelect(v ddbTypes.Select) *ScanBuilder

+ func (bld *ScanBuilder) SetTableName(v string) *ScanBuilder

+ func (bld *ScanBuilder) SetTotalSegments(v int32) *ScanBuilder

+ type ScanContext struct

+ type ScanFinalHandler struct

+ func (h *ScanFinalHandler) HandleScan(ctx *ScanContext, output *ScanOutput)

+ type ScanHandler interface

+ HandleScan func(ctx *ScanContext, output *ScanOutput)

+ type ScanHandlerFunc func(ctx *ScanContext, output *ScanOutput)

+ func (h ScanHandlerFunc) HandleScan(ctx *ScanContext, output *ScanOutput)

+ type ScanMiddleWare interface

+ ScanMiddleWare func(next ScanHandler) ScanHandler

+ type ScanMiddleWareFunc func(next ScanHandler) ScanHandler

+ func (mw ScanMiddleWareFunc) ScanMiddleWare(next ScanHandler) ScanHandler

+ type ScanOutput struct

+ func (o *ScanOutput) Get() (out *ddb.ScanOutput, err error)

+ func (o *ScanOutput) Set(out *ddb.ScanOutput, err error)

+ type Table struct

+ GSIs map[string]*GSI

+ LSIs map[string]*LSI

+ LastSync time.Time

+ PartitionKeyAttributeDefinition *ddbTypes.AttributeDefinition

+ SortKeyAttributeDefinition *ddbTypes.AttributeDefinition

+ Tags []ddbTypes.Tag

+ func CreateTestTable(db *Client) *Table

+ func NewTable(name string) *Table

+ func (t *Table) AddGSI(gsi ...*GSI) *Table

+ func (t *Table) AddLSI(lsi ...*LSI)

+ func (t *Table) AddTag(key, value string) *Table

+ func (t *Table) BackupInput(backupName string) *ddb.CreateBackupInput

+ func (t *Table) BatchDelete(items []map[string]ddbTypes.AttributeValue, mws ...BatchWriteItemAllMiddleWare) *BatchWriteItemAll

+ func (t *Table) BatchGet(items []map[string]ddbTypes.AttributeValue, mws ...BatchGetItemAllMiddleWare) *BatchGetItemAll

+ func (t *Table) BatchPut(items []map[string]ddbTypes.AttributeValue, mws ...BatchWriteItemAllMiddleWare) *BatchWriteItemAll

+ func (t *Table) Create() (*CreateTable, error)

+ func (t *Table) CreateTableInput() (*ddb.CreateTableInput, error)

+ func (t *Table) CreateTableMiddleWare(next CreateTableHandler) CreateTableHandler

+ func (t *Table) Delete() *DeleteTable

+ func (t *Table) DeleteInput() *ddb.DeleteTableInput

+ func (t *Table) DescribeTableInput() *ddb.DescribeTableInput

+ func (t *Table) DescribeTableMiddleWare(next DescribeTableHandler) DescribeTableHandler

+ func (t *Table) Description() *ddbTypes.TableDescription

+ func (t *Table) ExtractAllKeys(avMaps []map[string]ddbTypes.AttributeValue) []map[string]ddbTypes.AttributeValue

+ func (t *Table) ExtractKeys(avMap map[string]ddbTypes.AttributeValue) map[string]ddbTypes.AttributeValue

+ func (t *Table) ExtractPartitionKeyValue(avMap map[string]ddbTypes.AttributeValue) ddbTypes.AttributeValue

+ func (t *Table) ExtractSortKeyValue(avMap map[string]ddbTypes.AttributeValue) ddbTypes.AttributeValue

+ func (t *Table) IsOnDemand() bool

+ func (t *Table) Name() string

+ func (t *Table) NewBackup(backupName string) *CreateBackup

+ func (t *Table) NewPutItemBuilder() *PutItemBuilder

+ func (t *Table) PartitionKeyName() string

+ func (t *Table) QueryBuilder() *QueryBuilder

+ func (t *Table) RCUs() int64

+ func (t *Table) ScanBuilder() *ScanBuilder

+ func (t *Table) SetCostUnits(RCUs, WCUs int64) *Table

+ func (t *Table) SetName(name string) *Table

+ func (t *Table) SetOnDemand() *Table

+ func (t *Table) SetPartitionKey(pkName string, attributeType ddbTypes.ScalarAttributeType) *Table

+ func (t *Table) SetReadCostUnits(costUnits int64) *Table

+ func (t *Table) SetSortKey(skName string, attributeType ddbTypes.ScalarAttributeType) *Table

+ func (t *Table) SetWriteCostUnits(costUnits int64) *Table

+ func (t *Table) SortKeyName() string

+ func (t *Table) TableExistsWaiter() *TableExistsWaiter

+ func (t *Table) TableNotExistsWaiter() *TableNotExistsWaiter

+ func (t *Table) UniqueKeyCondition() *expression.ConditionBuilder

+ func (t *Table) UpdateWithRemote() *TableExistsWaiter

+ func (t *Table) UpdateWithTableDescription(input *ddbTypes.TableDescription)

+ func (t *Table) WCUs() int64

+ type TableExistsWaiter struct

+ func NewTableExistsWaiter(input *ddb.DescribeTableInput, mws ...DescribeTableMiddleWare) *TableExistsWaiter

+ func (op *TableExistsWaiter) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *TableExistsWaiter) Invoke(ctx context.Context, client *ddb.Client) *TableExistsWaiter

+ type TableExistsWaiterFinalHandler struct

+ func (h *TableExistsWaiterFinalHandler) HandleDescribeTable(ctx *DescribeTableContext, output *DescribeTableOutput)

+ type TableNotExistsWaiter struct

+ func NewTableNotExistsWaiter(input *ddb.DescribeTableInput, mws ...DescribeTableMiddleWare) *TableNotExistsWaiter

+ func (op *TableNotExistsWaiter) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *TableNotExistsWaiter) Invoke(ctx context.Context, client *ddb.Client) *TableNotExistsWaiter

+ type TableNotExistsWaiterFinalHandler struct

+ func (h *TableNotExistsWaiterFinalHandler) HandleDescribeTable(ctx *DescribeTableContext, output *DescribeTableOutput)

+ type TagResource struct

+ func NewTagResource(input *ddb.TagResourceInput, mws ...TagResourceMiddleWare) *TagResource

+ func (op *TagResource) Await() (*ddb.TagResourceOutput, error)

+ func (op *TagResource) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *TagResource) Invoke(ctx context.Context, client *ddb.Client) *TagResource

+ type TagResourceBuilder struct

+ type TagResourceContext struct

+ type TagResourceFinalHandler struct

+ func (h *TagResourceFinalHandler) HandleTagResource(ctx *TagResourceContext, output *TagResourceOutput)

+ type TagResourceHandler interface

+ HandleTagResource func(ctx *TagResourceContext, output *TagResourceOutput)

+ type TagResourceHandlerFunc func(ctx *TagResourceContext, output *TagResourceOutput)

+ func (h TagResourceHandlerFunc) HandleTagResource(ctx *TagResourceContext, output *TagResourceOutput)

+ type TagResourceMiddleWare interface

+ TagResourceMiddleWare func(next TagResourceHandler) TagResourceHandler

+ type TagResourceMiddleWareFunc func(next TagResourceHandler) TagResourceHandler

+ func (mw TagResourceMiddleWareFunc) TagResourceMiddleWare(next TagResourceHandler) TagResourceHandler

+ type TagResourceOutput struct

+ func (o *TagResourceOutput) Get() (out *ddb.TagResourceOutput, err error)

+ func (o *TagResourceOutput) Set(out *ddb.TagResourceOutput, err error)

+ type TestEmbeddedItem struct

+ Bar int

+ Baz []byte

+ Foo float64

+ type TestItem struct

+ Embedded *TestEmbeddedItem

+ ID string

+ TimeStamp int64

+ func GetTestItems(cnt int) []*TestItem

+ func NewTestItem() *TestItem

+ type TestItemMarshaller struct

+ Embedded *TestEmbeddedItem

+ ID string

+ TimeStamp time.Time

+ func GetMarshalledTestRecords(cnt int) []*TestItemMarshaller

+ func NewMarshalledTestItem() *TestItemMarshaller

+ func (m *TestItemMarshaller) UnmarshalAttributeValueMap(avMap map[string]ddbType.AttributeValue) error

+ func (m TestItemMarshaller) MarshalAttributeValueMap(av map[string]ddbType.AttributeValue) error

+ type TransactGetItems struct

+ func NewTransactGetItems(input *ddb.TransactGetItemsInput, mws ...TransactGetItemsMiddleWare) *TransactGetItems

+ func (op *TransactGetItems) Await() (*ddb.TransactGetItemsOutput, error)

+ func (op *TransactGetItems) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *TransactGetItems) Invoke(ctx context.Context, client *ddb.Client) *TransactGetItems

+ type TransactGetItemsBuilder struct

+ func NewTransactGetItemsBuilder(input *ddb.TransactGetItemsInput) *TransactGetItemsBuilder

+ func (bld *TransactGetItemsBuilder) AddGet(gets ...*ddbTypes.Get) *TransactGetItemsBuilder

+ func (bld *TransactGetItemsBuilder) Build() *ddb.TransactGetItemsInput

+ func (bld *TransactGetItemsBuilder) SetInput(input *ddb.TransactGetItemsInput) *TransactGetItemsBuilder

+ func (bld *TransactGetItemsBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *TransactGetItemsBuilder

+ type TransactGetItemsContext struct

+ type TransactGetItemsFinalHandler struct

+ func (h *TransactGetItemsFinalHandler) HandleTransactGetItems(ctx *TransactGetItemsContext, output *TransactGetItemsOutput)

+ type TransactGetItemsHandler interface

+ HandleTransactGetItems func(ctx *TransactGetItemsContext, output *TransactGetItemsOutput)

+ type TransactGetItemsHandlerFunc func(ctx *TransactGetItemsContext, output *TransactGetItemsOutput)

+ func (h TransactGetItemsHandlerFunc) HandleTransactGetItems(ctx *TransactGetItemsContext, output *TransactGetItemsOutput)

+ type TransactGetItemsMiddleWare interface

+ TransactGetItemsMiddleWare func(next TransactGetItemsHandler) TransactGetItemsHandler

+ type TransactGetItemsMiddleWareFunc func(next TransactGetItemsHandler) TransactGetItemsHandler

+ func (mw TransactGetItemsMiddleWareFunc) TransactGetItemsMiddleWare(next TransactGetItemsHandler) TransactGetItemsHandler

+ type TransactGetItemsOutput struct

+ func (o *TransactGetItemsOutput) Get() (out *ddb.TransactGetItemsOutput, err error)

+ func (o *TransactGetItemsOutput) Set(out *ddb.TransactGetItemsOutput, err error)

+ type TransactWriteItems struct

+ func NewTransactWriteItems(input *ddb.TransactWriteItemsInput, mws ...TransactWriteItemsMiddleWare) *TransactWriteItems

+ func (op *TransactWriteItems) Await() (*ddb.TransactWriteItemsOutput, error)

+ func (op *TransactWriteItems) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *TransactWriteItems) Invoke(ctx context.Context, client *ddb.Client) *TransactWriteItems

+ type TransactWriteItemsBuilder struct

+ func NewTransactWriteItemsBuilder(input *ddb.TransactWriteItemsInput) *TransactWriteItemsBuilder

+ func (bld *TransactWriteItemsBuilder) AddDelete(del *ddbTypes.Delete, cnd *ddbTypes.ConditionCheck) *TransactWriteItemsBuilder

+ func (bld *TransactWriteItemsBuilder) AddPut(put *ddbTypes.Put, cnd *ddbTypes.ConditionCheck) *TransactWriteItemsBuilder

+ func (bld *TransactWriteItemsBuilder) AddTransactWriteItem(write ddbTypes.TransactWriteItem) *TransactWriteItemsBuilder

+ func (bld *TransactWriteItemsBuilder) AddUpdate(update *ddbTypes.Update, cnd *ddbTypes.ConditionCheck) *TransactWriteItemsBuilder

+ func (bld *TransactWriteItemsBuilder) Build() *ddb.TransactWriteItemsInput

+ func (bld *TransactWriteItemsBuilder) SetInput(input *ddb.TransactWriteItemsInput) *TransactWriteItemsBuilder

+ func (bld *TransactWriteItemsBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *TransactWriteItemsBuilder

+ type TransactWriteItemsContext struct

+ type TransactWriteItemsFinalHandler struct

+ func (h *TransactWriteItemsFinalHandler) HandleTransactWriteItems(ctx *TransactWriteItemsContext, output *TransactWriteItemsOutput)

+ type TransactWriteItemsHandler interface

+ HandleTransactWriteItems func(ctx *TransactWriteItemsContext, output *TransactWriteItemsOutput)

+ type TransactWriteItemsHandlerFunc func(ctx *TransactWriteItemsContext, output *TransactWriteItemsOutput)

+ func (h TransactWriteItemsHandlerFunc) HandleTransactWriteItems(ctx *TransactWriteItemsContext, output *TransactWriteItemsOutput)

+ type TransactWriteItemsMiddleWare interface

+ TransactWriteItemsMiddleWare func(next TransactWriteItemsHandler) TransactWriteItemsHandler

+ type TransactWriteItemsMiddleWareFunc func(next TransactWriteItemsHandler) TransactWriteItemsHandler

+ func (mw TransactWriteItemsMiddleWareFunc) TransactWriteItemsMiddleWare(next TransactWriteItemsHandler) TransactWriteItemsHandler

+ type TransactWriteItemsOutput struct

+ func (o *TransactWriteItemsOutput) Get() (out *ddb.TransactWriteItemsOutput, err error)

+ func (o *TransactWriteItemsOutput) Set(out *ddb.TransactWriteItemsOutput, err error)

+ type Unmarshaler struct

+ func NewUnmarshaler(target interface{}) *Unmarshaler

+ func (mw *Unmarshaler) BatchGetItemAllMiddleWare(next BatchGetItemAllHandler) BatchGetItemAllHandler

+ func (mw *Unmarshaler) GetItemMiddleWare(next GetItemHandler) GetItemHandler

+ func (mw *Unmarshaler) QueryAllMiddleWare(next QueryAllHandler) QueryAllHandler

+ func (mw *Unmarshaler) QueryMiddleWare(next QueryHandler) QueryHandler

+ func (mw *Unmarshaler) ScanAllMiddleWare(next ScanAllHandler) ScanAllHandler

+ func (mw *Unmarshaler) ScanMiddleWare(next ScanHandler) ScanHandler

+ type UntagResource struct

+ func NewUntagResource(input *ddb.UntagResourceInput, mws ...UntagResourceMiddleWare) *UntagResource

+ func (op *UntagResource) Await() (*ddb.UntagResourceOutput, error)

+ func (op *UntagResource) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UntagResource) Invoke(ctx context.Context, client *ddb.Client) *UntagResource

+ type UntagResourceBuilder struct

+ type UntagResourceContext struct

+ type UntagResourceFinalHandler struct

+ func (h *UntagResourceFinalHandler) HandleUntagResource(ctx *UntagResourceContext, output *UntagResourceOutput)

+ type UntagResourceHandler interface

+ HandleUntagResource func(ctx *UntagResourceContext, output *UntagResourceOutput)

+ type UntagResourceHandlerFunc func(ctx *UntagResourceContext, output *UntagResourceOutput)

+ func (h UntagResourceHandlerFunc) HandleUntagResource(ctx *UntagResourceContext, output *UntagResourceOutput)

+ type UntagResourceMiddleWare interface

+ UntagResourceMiddleWare func(next UntagResourceHandler) UntagResourceHandler

+ type UntagResourceMiddleWareFunc func(next UntagResourceHandler) UntagResourceHandler

+ func (mw UntagResourceMiddleWareFunc) UntagResourceMiddleWare(next UntagResourceHandler) UntagResourceHandler

+ type UntagResourceOutput struct

+ func (o *UntagResourceOutput) Get() (out *ddb.UntagResourceOutput, err error)

+ func (o *UntagResourceOutput) Set(out *ddb.UntagResourceOutput, err error)

+ type UpdateContinuousBackups struct

+ func NewUpdateContinuousBackups(input *ddb.UpdateContinuousBackupsInput, ...) *UpdateContinuousBackups

+ func (op *UpdateContinuousBackups) Await() (*ddb.UpdateContinuousBackupsOutput, error)

+ func (op *UpdateContinuousBackups) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateContinuousBackups) Invoke(ctx context.Context, client *ddb.Client) *UpdateContinuousBackups

+ type UpdateContinuousBackupsBuilder struct

+ type UpdateContinuousBackupsContext struct

+ type UpdateContinuousBackupsFinalHandler struct

+ func (h *UpdateContinuousBackupsFinalHandler) HandleUpdateContinuousBackups(ctx *UpdateContinuousBackupsContext, output *UpdateContinuousBackupsOutput)

+ type UpdateContinuousBackupsHandler interface

+ HandleUpdateContinuousBackups func(ctx *UpdateContinuousBackupsContext, output *UpdateContinuousBackupsOutput)

+ type UpdateContinuousBackupsHandlerFunc func(ctx *UpdateContinuousBackupsContext, output *UpdateContinuousBackupsOutput)

+ func (h UpdateContinuousBackupsHandlerFunc) HandleUpdateContinuousBackups(ctx *UpdateContinuousBackupsContext, output *UpdateContinuousBackupsOutput)

+ type UpdateContinuousBackupsMiddleWare interface

+ UpdateContinuousBackupsMiddleWare func(next UpdateContinuousBackupsHandler) UpdateContinuousBackupsHandler

+ type UpdateContinuousBackupsMiddleWareFunc func(next UpdateContinuousBackupsHandler) UpdateContinuousBackupsHandler

+ func (mw UpdateContinuousBackupsMiddleWareFunc) UpdateContinuousBackupsMiddleWare(next UpdateContinuousBackupsHandler) UpdateContinuousBackupsHandler

+ type UpdateContinuousBackupsOutput struct

+ func (o *UpdateContinuousBackupsOutput) Get() (out *ddb.UpdateContinuousBackupsOutput, err error)

+ func (o *UpdateContinuousBackupsOutput) Set(out *ddb.UpdateContinuousBackupsOutput, err error)

+ type UpdateContributorInsights struct

+ func NewUpdateContributorInsights(input *ddb.UpdateContributorInsightsInput, ...) *UpdateContributorInsights

+ func (op *UpdateContributorInsights) Await() (*ddb.UpdateContributorInsightsOutput, error)

+ func (op *UpdateContributorInsights) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateContributorInsights) Invoke(ctx context.Context, client *ddb.Client) *UpdateContributorInsights

+ type UpdateContributorInsightsBuilder struct

+ type UpdateContributorInsightsContext struct

+ type UpdateContributorInsightsFinalHandler struct

+ func (h *UpdateContributorInsightsFinalHandler) HandleUpdateContributorInsights(ctx *UpdateContributorInsightsContext, output *UpdateContributorInsightsOutput)

+ type UpdateContributorInsightsHandler interface

+ HandleUpdateContributorInsights func(ctx *UpdateContributorInsightsContext, output *UpdateContributorInsightsOutput)

+ type UpdateContributorInsightsHandlerFunc func(ctx *UpdateContributorInsightsContext, output *UpdateContributorInsightsOutput)

+ func (h UpdateContributorInsightsHandlerFunc) HandleUpdateContributorInsights(ctx *UpdateContributorInsightsContext, output *UpdateContributorInsightsOutput)

+ type UpdateContributorInsightsMiddleWare interface

+ UpdateContributorInsightsMiddleWare func(next UpdateContributorInsightsHandler) UpdateContributorInsightsHandler

+ type UpdateContributorInsightsMiddleWareFunc func(next UpdateContributorInsightsHandler) UpdateContributorInsightsHandler

+ func (mw UpdateContributorInsightsMiddleWareFunc) UpdateContributorInsightsMiddleWare(next UpdateContributorInsightsHandler) UpdateContributorInsightsHandler

+ type UpdateContributorInsightsOutput struct

+ func (o *UpdateContributorInsightsOutput) Get() (out *ddb.UpdateContributorInsightsOutput, err error)

+ func (o *UpdateContributorInsightsOutput) Set(out *ddb.UpdateContributorInsightsOutput, err error)

+ type UpdateGlobalTable struct

+ func NewUpdateGlobalTable(input *ddb.UpdateGlobalTableInput, mws ...UpdateGlobalTableMiddleWare) *UpdateGlobalTable

+ func (op *UpdateGlobalTable) Await() (*ddb.UpdateGlobalTableOutput, error)

+ func (op *UpdateGlobalTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateGlobalTable) Invoke(ctx context.Context, client *ddb.Client) *UpdateGlobalTable

+ type UpdateGlobalTableContext struct

+ type UpdateGlobalTableFinalHandler struct

+ func (h *UpdateGlobalTableFinalHandler) HandleUpdateGlobalTable(ctx *UpdateGlobalTableContext, output *UpdateGlobalTableOutput)

+ type UpdateGlobalTableHandler interface

+ HandleUpdateGlobalTable func(ctx *UpdateGlobalTableContext, output *UpdateGlobalTableOutput)

+ type UpdateGlobalTableHandlerFunc func(ctx *UpdateGlobalTableContext, output *UpdateGlobalTableOutput)

+ func (h UpdateGlobalTableHandlerFunc) HandleUpdateGlobalTable(ctx *UpdateGlobalTableContext, output *UpdateGlobalTableOutput)

+ type UpdateGlobalTableMiddleWare interface

+ UpdateGlobalTableMiddleWare func(next UpdateGlobalTableHandler) UpdateGlobalTableHandler

+ type UpdateGlobalTableMiddleWareFunc func(next UpdateGlobalTableHandler) UpdateGlobalTableHandler

+ func (mw UpdateGlobalTableMiddleWareFunc) UpdateGlobalTableMiddleWare(next UpdateGlobalTableHandler) UpdateGlobalTableHandler

+ type UpdateGlobalTableOutput struct

+ func (o *UpdateGlobalTableOutput) Get() (out *ddb.UpdateGlobalTableOutput, err error)

+ func (o *UpdateGlobalTableOutput) Set(out *ddb.UpdateGlobalTableOutput, err error)

+ type UpdateGlobalTableSettings struct

+ func NewUpdateGlobalTableSettings(input *ddb.UpdateGlobalTableSettingsInput, ...) *UpdateGlobalTableSettings

+ func (op *UpdateGlobalTableSettings) Await() (*ddb.UpdateGlobalTableSettingsOutput, error)

+ func (op *UpdateGlobalTableSettings) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateGlobalTableSettings) Invoke(ctx context.Context, client *ddb.Client) *UpdateGlobalTableSettings

+ type UpdateGlobalTableSettingsContext struct

+ type UpdateGlobalTableSettingsFinalHandler struct

+ func (h *UpdateGlobalTableSettingsFinalHandler) HandleUpdateGlobalTableSettings(ctx *UpdateGlobalTableSettingsContext, output *UpdateGlobalTableSettingsOutput)

+ type UpdateGlobalTableSettingsHandler interface

+ HandleUpdateGlobalTableSettings func(ctx *UpdateGlobalTableSettingsContext, output *UpdateGlobalTableSettingsOutput)

+ type UpdateGlobalTableSettingsHandlerFunc func(ctx *UpdateGlobalTableSettingsContext, output *UpdateGlobalTableSettingsOutput)

+ func (h UpdateGlobalTableSettingsHandlerFunc) HandleUpdateGlobalTableSettings(ctx *UpdateGlobalTableSettingsContext, output *UpdateGlobalTableSettingsOutput)

+ type UpdateGlobalTableSettingsMiddleWare interface

+ UpdateGlobalTableSettingsMiddleWare func(next UpdateGlobalTableSettingsHandler) UpdateGlobalTableSettingsHandler

+ type UpdateGlobalTableSettingsMiddleWareFunc func(next UpdateGlobalTableSettingsHandler) UpdateGlobalTableSettingsHandler

+ func (mw UpdateGlobalTableSettingsMiddleWareFunc) UpdateGlobalTableSettingsMiddleWare(next UpdateGlobalTableSettingsHandler) UpdateGlobalTableSettingsHandler

+ type UpdateGlobalTableSettingsOutput struct

+ func (o *UpdateGlobalTableSettingsOutput) Get() (out *ddb.UpdateGlobalTableSettingsOutput, err error)

+ func (o *UpdateGlobalTableSettingsOutput) Set(out *ddb.UpdateGlobalTableSettingsOutput, err error)

+ type UpdateItem struct

+ func NewUpdateItem(input *ddb.UpdateItemInput, mws ...UpdateItemMiddleWare) *UpdateItem

+ func (op *UpdateItem) Await() (*ddb.UpdateItemOutput, error)

+ func (op *UpdateItem) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateItem) Invoke(ctx context.Context, client *ddb.Client) *UpdateItem

+ type UpdateItemBuilder struct

+ func NewUpdateItemBuilder(input *ddb.UpdateItemInput) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) Add(field string, value interface{}) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) AddCondition(cnd expression.ConditionBuilder) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) AddItem(item map[string]ddbTypes.AttributeValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) Build() (*ddb.UpdateItemInput, error)

+ func (bld *UpdateItemBuilder) Delete(field string, value interface{}) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) DeleteItem(item map[string]ddbTypes.AttributeValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) Remove(fields ...string) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) Set(field string, value interface{}) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetAttributeUpdates(v map[string]ddbTypes.AttributeValueUpdate) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetConditionExpression(v string) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetConditionalOperator(v ddbTypes.ConditionalOperator) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetExpected(v map[string]ddbTypes.ExpectedAttributeValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetExpressionAttributeNames(v map[string]string) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetExpressionAttributeValues(v map[string]ddbTypes.AttributeValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetItem(item map[string]dynamodb.AttributeValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetKey(v map[string]ddbTypes.AttributeValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetReturnConsumedCapacity(v ddbTypes.ReturnConsumedCapacity) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetReturnItemCollectionMetrics(v ddbTypes.ReturnItemCollectionMetrics) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetReturnValues(v ddbTypes.ReturnValue) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetTableName(v string) *UpdateItemBuilder

+ func (bld *UpdateItemBuilder) SetUpdateExpression(v string) *UpdateItemBuilder

+ type UpdateItemContext struct

+ type UpdateItemFinalHandler struct

+ func (h *UpdateItemFinalHandler) HandleUpdateItem(ctx *UpdateItemContext, output *UpdateItemOutput)

+ type UpdateItemHandler interface

+ HandleUpdateItem func(ctx *UpdateItemContext, output *UpdateItemOutput)

+ type UpdateItemHandlerFunc func(ctx *UpdateItemContext, output *UpdateItemOutput)

+ func (h UpdateItemHandlerFunc) HandleUpdateItem(ctx *UpdateItemContext, output *UpdateItemOutput)

+ type UpdateItemMiddleWare interface

+ UpdateItemMiddleWare func(next UpdateItemHandler) UpdateItemHandler

+ type UpdateItemMiddleWareFunc func(next UpdateItemHandler) UpdateItemHandler

+ func (mw UpdateItemMiddleWareFunc) UpdateItemMiddleWare(next UpdateItemHandler) UpdateItemHandler

+ type UpdateItemOutput struct

+ func (o *UpdateItemOutput) Get() (out *ddb.UpdateItemOutput, err error)

+ func (o *UpdateItemOutput) Set(out *ddb.UpdateItemOutput, err error)

+ type UpdateTable struct

+ func NewUpdateTable(input *ddb.UpdateTableInput, mws ...UpdateTableMiddleWare) *UpdateTable

+ func (op *UpdateTable) Await() (*ddb.UpdateTableOutput, error)

+ func (op *UpdateTable) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateTable) Invoke(ctx context.Context, client *ddb.Client) *UpdateTable

+ type UpdateTableContext struct

+ type UpdateTableFinalHandler struct

+ func (h *UpdateTableFinalHandler) HandleUpdateTable(ctx *UpdateTableContext, output *UpdateTableOutput)

+ type UpdateTableHandler interface

+ HandleUpdateTable func(ctx *UpdateTableContext, output *UpdateTableOutput)

+ type UpdateTableHandlerFunc func(ctx *UpdateTableContext, output *UpdateTableOutput)

+ func (h UpdateTableHandlerFunc) HandleUpdateTable(ctx *UpdateTableContext, output *UpdateTableOutput)

+ type UpdateTableMiddleWare interface

+ UpdateTableMiddleWare func(next UpdateTableHandler) UpdateTableHandler

+ type UpdateTableMiddleWareFunc func(next UpdateTableHandler) UpdateTableHandler

+ func (mw UpdateTableMiddleWareFunc) UpdateTableMiddleWare(next UpdateTableHandler) UpdateTableHandler

+ type UpdateTableOutput struct

+ func (o *UpdateTableOutput) Get() (out *ddb.UpdateTableOutput, err error)

+ func (o *UpdateTableOutput) Set(out *ddb.UpdateTableOutput, err error)

+ type UpdateTableReplicaAutoScaling struct

+ func NewUpdateTableReplicaAutoScaling(input *ddb.UpdateTableReplicaAutoScalingInput, ...) *UpdateTableReplicaAutoScaling

+ func (op *UpdateTableReplicaAutoScaling) Await() (*ddb.UpdateTableReplicaAutoScalingOutput, error)

+ func (op *UpdateTableReplicaAutoScaling) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateTableReplicaAutoScaling) Invoke(ctx context.Context, client *ddb.Client) *UpdateTableReplicaAutoScaling

+ type UpdateTableReplicaAutoScalingContext struct

+ type UpdateTableReplicaAutoScalingFinalHandler struct

+ func (h *UpdateTableReplicaAutoScalingFinalHandler) HandleUpdateTableReplicaAutoScaling(ctx *UpdateTableReplicaAutoScalingContext, ...)

+ type UpdateTableReplicaAutoScalingHandler interface

+ HandleUpdateTableReplicaAutoScaling func(ctx *UpdateTableReplicaAutoScalingContext, ...)

+ type UpdateTableReplicaAutoScalingHandlerFunc func(ctx *UpdateTableReplicaAutoScalingContext, ...)

+ func (h UpdateTableReplicaAutoScalingHandlerFunc) HandleUpdateTableReplicaAutoScaling(ctx *UpdateTableReplicaAutoScalingContext, ...)

+ type UpdateTableReplicaAutoScalingMiddleWare interface

+ UpdateTableReplicaAutoScalingMiddleWare func(next UpdateTableReplicaAutoScalingHandler) UpdateTableReplicaAutoScalingHandler

+ type UpdateTableReplicaAutoScalingMiddleWareFunc func(next UpdateTableReplicaAutoScalingHandler) UpdateTableReplicaAutoScalingHandler

+ func (mw UpdateTableReplicaAutoScalingMiddleWareFunc) UpdateTableReplicaAutoScalingMiddleWare(next UpdateTableReplicaAutoScalingHandler) UpdateTableReplicaAutoScalingHandler

+ type UpdateTableReplicaAutoScalingOutput struct

+ func (o *UpdateTableReplicaAutoScalingOutput) Get() (out *ddb.UpdateTableReplicaAutoScalingOutput, err error)

+ func (o *UpdateTableReplicaAutoScalingOutput) Set(out *ddb.UpdateTableReplicaAutoScalingOutput, err error)

+ type UpdateTimeToLive struct

+ func NewUpdateTimeToLive(input *ddb.UpdateTimeToLiveInput, mws ...UpdateTimeToLiveMiddleWare) *UpdateTimeToLive

+ func (op *UpdateTimeToLive) Await() (*ddb.UpdateTimeToLiveOutput, error)

+ func (op *UpdateTimeToLive) DynoInvoke(ctx context.Context, client *ddb.Client)

+ func (op *UpdateTimeToLive) Invoke(ctx context.Context, client *ddb.Client) *UpdateTimeToLive

+ type UpdateTimeToLiveContext struct

+ type UpdateTimeToLiveFinalHandler struct

+ func (h *UpdateTimeToLiveFinalHandler) HandleUpdateTimeToLive(ctx *UpdateTimeToLiveContext, output *UpdateTimeToLiveOutput)

+ type UpdateTimeToLiveHandler interface

+ HandleUpdateTimeToLive func(ctx *UpdateTimeToLiveContext, output *UpdateTimeToLiveOutput)

+ type UpdateTimeToLiveHandlerFunc func(ctx *UpdateTimeToLiveContext, output *UpdateTimeToLiveOutput)

+ func (h UpdateTimeToLiveHandlerFunc) HandleUpdateTimeToLive(ctx *UpdateTimeToLiveContext, output *UpdateTimeToLiveOutput)

+ type UpdateTimeToLiveMiddleWare interface

+ UpdateTimeToLiveMiddleWare func(next UpdateTimeToLiveHandler) UpdateTimeToLiveHandler

+ type UpdateTimeToLiveMiddleWareFunc func(next UpdateTimeToLiveHandler) UpdateTimeToLiveHandler

+ func (mw UpdateTimeToLiveMiddleWareFunc) UpdateTimeToLiveMiddleWare(next UpdateTimeToLiveHandler) UpdateTimeToLiveHandler

+ type UpdateTimeToLiveOutput struct

+ func (o *UpdateTimeToLiveOutput) Get() (out *ddb.UpdateTimeToLiveOutput, err error)

+ func (o *UpdateTimeToLiveOutput) Set(out *ddb.UpdateTimeToLiveOutput, err error)

v0.1.15

May 25, 2021

v0.1.14

May 24, 2021

v0.1.13

May 4, 2021

v0.1.12

Apr 23, 2021

v0.1.11

Mar 30, 2021

v0.1.10

Mar 5, 2021

v0.1.9

Feb 24, 2021

v0.1.8

Feb 15, 2021

v0.1.7

Jan 21, 2021

v0.1.6

Jan 20, 2021

v0.1.5

Jan 20, 2021

v0.1.4

Jan 20, 2021

v0.1.3

Jan 20, 2021

v0.1.2

Jan 19, 2021

v0.1.1

Dec 1, 2020

Changes in this version

+ const ErrBackupInInvalidState

+ const ErrBatchOperationTimedOut

+ const ErrBatchOutputContextCancelled

+ const ErrEncodingBadKind

+ const ErrEncodingBadValue

+ const ErrEncodingEmbeddedBadKind

+ const ErrEncodingEmbeddedMapMarshalFailed

+ const ErrEncodingEmbeddedMapUnmarshalFailed

+ const ErrEncodingEmbeddedStructMarshalFailed

+ const ErrEncodingEmbeddedStructUnmarshalFailed

+ const ErrGsiNameAlreadyExists

+ const ErrLockFailedLeaseRenewal

+ const ErrLockFailedToAcquire

+ const ErrLockTimeout

+ const ErrLsiNameAlreadyExists

+ const ErrOperationNeverFinished

+ const ErrOperationNeverStarted

+ const ErrOperatorNotFound

+ const ErrPartitionKeyTableIndexMismatch

+ const ErrRequestExecutionContextCancelled

+ const ErrTableIsInInvalidState

+ const ErrTableMissingIndex

+ const ErrTableNotLoaded

+ func BoolPtr(b bool) *bool

+ func DurationPtr(dur time.Duration) *time.Duration

+ func FilterName(input string) string

+ func GetStringFromInterface(in interface{}) (string, error)

+ func Int64Ptr(i int64) *int64

+ func IntPtr(i int) *int

+ func InterfaceValue(v interface{}) interface

+ func IsAwsErrorCode(err error, codes ...string) bool

+ func IsEmptyInterface(x interface{}) bool

+ func StringPtr(s string) *string

+ func TimePtr(t time.Time) *time.Time

+ func Validator() *validator.Validate

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type ExecutionFunction func(ctx context.Context) error

+ type Request struct

+ func (r *Request) BatchGetItem(in *dynamodb.BatchGetItemInput) (out *dynamodb.BatchGetItemOutput, err error)

+ func (r *Request) BatchWriteItem(in *dynamodb.BatchWriteItemInput) (out *dynamodb.BatchWriteItemOutput, err error)

+ func (r *Request) Cancel()

+ func (r *Request) Context() context.Context

+ func (r *Request) CreateBackup(in *dynamodb.CreateBackupInput) (out *dynamodb.CreateBackupOutput, err error)

+ func (r *Request) CreateGlobalTable(in *dynamodb.CreateGlobalTableInput) (out *dynamodb.CreateGlobalTableOutput, err error)

+ func (r *Request) CreateTable(in *dynamodb.CreateTableInput) (out *dynamodb.CreateTableOutput, err error)

+ func (r *Request) DeleteBackup(in *dynamodb.DeleteBackupInput) (out *dynamodb.DeleteBackupOutput, err error)

+ func (r *Request) DeleteItem(in *dynamodb.DeleteItemInput) (out *dynamodb.DeleteItemOutput, err error)

+ func (r *Request) DeleteTable(in *dynamodb.DeleteTableInput) (out *dynamodb.DeleteTableOutput, err error)

+ func (r *Request) DescribeBackup(in *dynamodb.DescribeBackupInput) (out *dynamodb.DescribeBackupOutput, err error)

+ func (r *Request) DescribeTable(in *dynamodb.DescribeTableInput) (out *dynamodb.DescribeTableOutput, err error)

+ func (r *Request) Execute(execFunc ExecutionFunction) error

+ func (r *Request) GetItem(in *dynamodb.GetItemInput) (out *dynamodb.GetItemOutput, err error)

+ func (r *Request) ListBackups(in *dynamodb.ListBackupsInput) (out *dynamodb.ListBackupsOutput, err error)

+ func (r *Request) ListTables(in *dynamodb.ListTablesInput) (out *dynamodb.ListTablesOutput, err error)

+ func (r *Request) PutItem(in *dynamodb.PutItemInput) (out *dynamodb.PutItemOutput, err error)

+ func (r *Request) Query(in *dynamodb.QueryInput) (out *dynamodb.QueryOutput, err error)

+ func (r *Request) RestoreTableFromBackup(in *dynamodb.RestoreTableFromBackupInput) (out *dynamodb.RestoreTableFromBackupOutput, err error)

+ func (r *Request) Scan(in *dynamodb.ScanInput) (out *dynamodb.ScanOutput, err error)

+ func (r *Request) SetContext(ctx context.Context) *Request

+ func (r *Request) SetTimeout(timeout time.Duration) *Request

+ func (r *Request) UpdateItem(in *dynamodb.UpdateItemInput) (out *dynamodb.UpdateItemOutput, err error)

+ func (r *Request) UpdateTable(in *dynamodb.UpdateTableInput) (out *dynamodb.UpdateTableOutput, err error)

+ type Session struct

+ func New(awsSession *session.Session) *Session

+ func NewWithContext(ctx context.Context, awsSession *session.Session) *Session

+ func (s *Session) AWSSession() *session.Session

+ func (s *Session) Ctx() context.Context

+ func (s *Session) DynamoClient() *dynamodb.DynamoDB

+ func (s *Session) Log() *logrus.Entry

+ func (s *Session) MaxTimeout() time.Duration

+ func (s *Session) Request() *Request

+ func (s *Session) RequestWithContext(ctx context.Context) *Request

+ func (s *Session) RequestWithTimeout(timeout time.Duration) *Request

+ func (s *Session) SetContext(ctx context.Context) *Session

+ func (s *Session) SetLogger(logger *logrus.Logger) *Session

+ func (s *Session) SetMaxTimeout(timeout time.Duration) *Session

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL