migrator

Documentation

Index

• func Migrate(tableName string, arn string, repopulateCache bool, scripts []interface{}) (int, error)
• type Counter
  • func (c Counter) Inc(key string, delta int)
• type PreScanTransformation
• type ScanTransformation
• type TransformationAlbumOwner
  • func (t *TransformationAlbumOwner) GeneratePatches(run *TransformationRun, item map[string]*dynamodb.AttributeValue) ([]*dynamodb.WriteRequest, error)
• type TransformationRun
• type TransformationUpDateIndex
  • func (i TransformationUpDateIndex) PreScan(run *TransformationRun) error

Functions

func Migrate

func Migrate(tableName string, arn string, repopulateCache bool, scripts []interface{}) (int, error)

Types

type Counter

type Counter map[string]int

func (Counter) Inc

func (c Counter) Inc(key string, delta int)

type PreScanTransformation

type PreScanTransformation interface {
	PreScan(run *TransformationRun) error
}

type ScanTransformation

type ScanTransformation interface {
	GeneratePatches(run *TransformationRun, item map[string]*dynamodb.AttributeValue) ([]*dynamodb.WriteRequest, error)
}

type TransformationAlbumOwner

type TransformationAlbumOwner struct{}

func (*TransformationAlbumOwner) GeneratePatches

func (t *TransformationAlbumOwner) GeneratePatches(run *TransformationRun, item map[string]*dynamodb.AttributeValue) ([]*dynamodb.WriteRequest, error)

type TransformationRun

type TransformationRun struct {
	Session           *session.Session
	DynamoDBClient    *dynamodb.DynamoDB
	DynamoDBTableName string
	TopicARN          string
	Counter           Counter
}

type TransformationUpDateIndex

type TransformationUpDateIndex struct{}

func (TransformationUpDateIndex) PreScan

func (i TransformationUpDateIndex) PreScan(run *TransformationRun) error