Documentation
¶
Index ¶
- Variables
- func CreateTable(definition *dynamodb.CreateTableInput) error
- func DeleteAllItems(tableName, projectExpression string) (*string, error)
- func DeleteItems(tableName string, datas <-chan []map[string]types.AttributeValue, ...)
- func DeleteTable(tableName string) error
- func GetDocument(tableName string, documentQuery map[string]types.AttributeValue, ...) (*dynamodb.GetItemOutput, error)
- func ScanAsync(tableName, projectExpression string, ...)
- func WriteBatchItem(tableName string, items []interface{}) error
- func WriteItem(tableName string, item interface{}) error
- type Update
- type UpdateType
Constants ¶
This section is empty.
Variables ¶
View Source
var RETRY_ATTEMPT int64 = 1
Functions ¶
func CreateTable ¶
func CreateTable(definition *dynamodb.CreateTableInput) error
func DeleteAllItems ¶ added in v0.0.97
func DeleteItems ¶ added in v0.0.98
func DeleteItems(tableName string, datas <-chan []map[string]types.AttributeValue, bar *progressbar.ProgressBar, done chan bool)
func DeleteTable ¶
func GetDocument ¶ added in v0.0.99
func GetDocument(tableName string, documentQuery map[string]types.AttributeValue, res interface{}) (*dynamodb.GetItemOutput, error)
func ScanAsync ¶ added in v0.0.98
func ScanAsync(tableName, projectExpression string, ch chan<- []map[string]types.AttributeValue, bar *progressbar.ProgressBar)
func WriteBatchItem ¶ added in v0.0.92
Types ¶
type Update ¶
type Update struct {
Type UpdateType `json:"type,omitempty"`
Key string `json:"key,omitempty"`
Value string `json:"value,omitempty"`
}
type UpdateType ¶
type UpdateType string
Source Files
Click to show internal directories.
Click to hide internal directories.