Versions in this module Expand all Collapse all v1 v1.0.0 Feb 1, 2019 Changes in this version + func RandomSleeper(ms int) int + type Capacity struct + Read int64 + Write int64 + type Config struct + func NewConfig(readUnits, writeUnits, readWorkers, writeWorkers int) Config + func (c Config) Provisioning(current Provisioning) Provisioning + func (c Config) Workers() (int, int) + type Copier interface + Copy func(readers, writers int) error + func NewCopier(srcTableService, trgTableService DynamoDBService, copierChan CopierChan, ...) Copier + type CopierChan struct + Errors chan error + Items chan []DynamoDBItem + func NewCopierChan(itemsChanSize int) CopierChan + type DynamoDBClient interface + func NewDynamoClient(roleArn string) DynamoDBClient + type DynamoDBItem map[string]*dynamodb.AttributeValue + type DynamoDBService interface + BatchWrite func(items []DynamoDBItem) error + DescribeTable func() (*dynamodb.TableDescription, error) + Scan func(totalSegments, segment int, itemsChan chan<- []DynamoDBItem) error + UpdateCapacity func(capacity Capacity) error + WaitForReadyTable func() error + func NewDynamoDBService(tableName string, client DynamoDBClient, sleepFn Sleeper, logger Logger) DynamoDBService + type Logger interface + Printf func(format string, msg ...interface{}) + func NewDebugLogger(logger Logger, debug bool) Logger + type Provisioner interface + Fetch func() (Provisioning, error) + Update func(provisioning Provisioning) (Provisioning, error) + func NewProvisioner(srcTableService, trgTableService DynamoDBService, logger Logger) Provisioner + type Provisioning struct + Source *Capacity + Target *Capacity + func NewProvisioning(srcDescription, trgDescription *dynamodb.TableDescription) Provisioning + type Sleeper func(ms int) int
Go to main page