throttle

Feb 15, 2017

Changes in this version

+ const DeleteCapacityRate

+ const DeleteTickerPeriod

+ const GlobalSecondaryIndex

+ var ErrDuplicatedMessage = errors.New("duplicated message id")

+ func DeleteTicker(ctx context.Context, dt *DynamodbThrottle)

+ type DefaultThrottler struct

+ func (dl DefaultThrottler) Set(k string) error

+ func (dl DefaultThrottler) Unset(k string) error

+ type DynamodbThrottle struct

+ Dynamodb *dynamodb.DynamoDB

+ RetentionPeriod time.Duration

+ TableName string

+ func (dt *DynamodbThrottle) GetWriteCapacity() (int64, error)

+ func (dt DynamodbThrottle) GetExpiredItems() (*dynamodb.QueryOutput, error)

+ func (dt DynamodbThrottle) Set(jobid string) error

+ func (dt DynamodbThrottle) Unset(jobid string) error

+ type Throttler interface

+ Set func(id string) error

+ Unset func(id string) error

+ func NewDynamodbThrottle(ctx context.Context, profile, region, table string, retention time.Duration) Throttler