dynamodb

Documentation

Index

• Constants
• func ProvideDynamodDB(unmarshaller config.Unmarshaller, measures metric.Measures, logger log.Logger) (store.S, error)
• type Config
• type DynamoClient
  • func (s *DynamoClient) Delete(key model.Key) (store.OwnableItem, error)
  • func (s *DynamoClient) Get(key model.Key) (store.OwnableItem, error)
  • func (s *DynamoClient) GetAll(bucket string) (map[string]store.OwnableItem, error)
  • func (s *DynamoClient) Push(key model.Key, item store.OwnableItem) error
• type MockDB
  • func (s *MockDB) Delete(key model.Key) (store.OwnableItem, *dynamodb.ConsumedCapacity, error)
  • func (s *MockDB) Get(key model.Key) (store.OwnableItem, *dynamodb.ConsumedCapacity, error)
  • func (s *MockDB) GetAll(bucket string) (map[string]store.OwnableItem, *dynamodb.ConsumedCapacity, error)
  • func (s *MockDB) Push(key model.Key, item store.OwnableItem) (*dynamodb.ConsumedCapacity, error)

Constants

const (
	DynamoDB = "dynamo"
)

Functions

func ProvideDynamodDB

func ProvideDynamodDB(unmarshaller config.Unmarshaller, measures metric.Measures, logger log.Logger) (store.S, error)

Types

type Config

type Config struct {
	Table      string
	Endpoint   string
	Region     string
	MaxRetries int
	AccessKey  string
	SecretKey  string
}

type DynamoClient

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

func (*DynamoClient) Delete

func (s *DynamoClient) Delete(key model.Key) (store.OwnableItem, error)

func (*DynamoClient) Get

func (s *DynamoClient) Get(key model.Key) (store.OwnableItem, error)

func (*DynamoClient) GetAll

func (s *DynamoClient) GetAll(bucket string) (map[string]store.OwnableItem, error)

func (*DynamoClient) Push

func (s *DynamoClient) Push(key model.Key, item store.OwnableItem) error

type MockDB

type MockDB struct {
	mock.Mock
}

func (*MockDB) Delete

func (s *MockDB) Delete(key model.Key) (store.OwnableItem, *dynamodb.ConsumedCapacity, error)

func (*MockDB) Get

func (s *MockDB) Get(key model.Key) (store.OwnableItem, *dynamodb.ConsumedCapacity, error)

func (*MockDB) GetAll

func (s *MockDB) GetAll(bucket string) (map[string]store.OwnableItem, *dynamodb.ConsumedCapacity, error)

func (*MockDB) Push

func (s *MockDB) Push(key model.Key, item store.OwnableItem) (*dynamodb.ConsumedCapacity, error)