dynamodbutils

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

Variables

var RETRY_ATTEMPT int64 = 1

Functions

func CreateTable

func CreateTable(definition *dynamodb.CreateTableInput) error

func DeleteAllItems

func DeleteAllItems(tableName, projectExpression string) (*string, error)

func DeleteItems

func DeleteItems(tableName string, datas <-chan []map[string]types.AttributeValue, bar *progressbar.ProgressBar, done chan bool)

func DeleteTable

func DeleteTable(tableName string) error

func GetDocument

func GetDocument(tableName string, documentQuery map[string]types.AttributeValue, res interface{}) (*dynamodb.GetItemOutput, error)

func ScanAsync

func ScanAsync(tableName, projectExpression string, ch chan<- []map[string]types.AttributeValue, bar *progressbar.ProgressBar)

func WriteBatchItem

func WriteBatchItem(tableName string, items []interface{}) error

func WriteItem

func WriteItem(tableName string, item interface{}) error

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