dynamodb

Documentation

Index

• func Create(dynamodbClient dynamodbiface.DynamoDBAPI, tableName string, ttl time.Duration) wfcache.StorageMaker
• type DynamoDbStorage
  • func (s *DynamoDbStorage) BatchGet(ctx context.Context, keys []string) (results []*wfcache.CacheItem)
  • func (s *DynamoDbStorage) BatchSet(ctx context.Context, pairs map[string][]byte) error
  • func (s *DynamoDbStorage) Del(ctx context.Context, key string) error
  • func (s *DynamoDbStorage) Get(ctx context.Context, key string) *wfcache.CacheItem
  • func (s *DynamoDbStorage) Set(ctx context.Context, key string, data []byte) error
  • func (s *DynamoDbStorage) TimeToLive() time.Duration

Functions

func Create

func Create(dynamodbClient dynamodbiface.DynamoDBAPI, tableName string, ttl time.Duration) wfcache.StorageMaker

Types

type DynamoDbStorage

type DynamoDbStorage struct {
	// contains filtered or unexported fields
}

func (*DynamoDbStorage) BatchGet

func (s *DynamoDbStorage) BatchGet(ctx context.Context, keys []string) (results []*wfcache.CacheItem)

If you request more than 100 items, BatchGetItem returns a ValidationException with the message "Too many items requested for the BatchGetItem call."

func (*DynamoDbStorage) BatchSet

func (s *DynamoDbStorage) BatchSet(ctx context.Context, pairs map[string][]byte) error

func (*DynamoDbStorage) Del

func (s *DynamoDbStorage) Del(ctx context.Context, key string) error

func (*DynamoDbStorage) Get

func (s *DynamoDbStorage) Get(ctx context.Context, key string) *wfcache.CacheItem

func (*DynamoDbStorage) Set

func (s *DynamoDbStorage) Set(ctx context.Context, key string, data []byte) error

func (*DynamoDbStorage) TimeToLive

func (s *DynamoDbStorage) TimeToLive() time.Duration