Documentation
¶
Index ¶
- func BatchPutItems(client *awsdynamodb.Client, tableName string, opt ...BatchWriteOption) rivo.Pipeline[types.PutRequest, *awsdynamodb.BatchWriteItemOutput]
- func BatchWrite(client *awsdynamodb.Client, opt ...BatchWriteOption) ...
- func Scan(client *dynamodb.Client, input *dynamodb.ScanInput, opt ...ScanOption) rivo.Pipeline[rivo.None, *dynamodb.ScanOutput]
- func ScanItems(client *dynamodb.Client, input *dynamodb.ScanInput, opt ...ScanOption) rivo.Pipeline[rivo.None, map[string]types.AttributeValue]
- type BatchWriteOption
- type ScanOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchPutItems ¶
func BatchPutItems(client *awsdynamodb.Client, tableName string, opt ...BatchWriteOption) rivo.Pipeline[types.PutRequest, *awsdynamodb.BatchWriteItemOutput]
BatchPutItems returns a pipeline which writes the input stream to the provided DynamoDB using the BatchWriteItem API, but only for PutItem operations;
func BatchWrite ¶
func BatchWrite(client *awsdynamodb.Client, opt ...BatchWriteOption) rivo.Pipeline[*awsdynamodb.BatchWriteItemInput, *awsdynamodb.BatchWriteItemOutput]
BatchWrite returns a pipeline which writes the input stream to the provided DynamoDB using the BatchWriteItem API.
Types ¶
type BatchWriteOption ¶
type BatchWriteOption func(*batchWriteOptions) error
func BatchWriteChanSize ¶
func BatchWriteChanSize(chanSize int) BatchWriteOption
func BatchWritePoolSize ¶
func BatchWritePoolSize(poolSize int) BatchWriteOption
type ScanOption ¶
type ScanOption func(*scanOptions) error
func ScanPoolSize ¶
func ScanPoolSize(poolSize int) ScanOption
Source Files
Click to show internal directories.
Click to hide internal directories.