adapter

Documentation

Index

• func CreateProductDeleteRepository(dependencies map[string]interface{}) (domain.ProductDeleteRepository, error)
• func CreateProductFindAllRepository(dependencies map[string]interface{}) (domain.ProductFindAllRepository, error)
• func CreateProductFindRepository(dependencies map[string]interface{}) (domain.ProductFindRepository, error)
• func CreateProductSaveRepository(dependencies map[string]interface{}) (domain.ProductSaveRepository, error)
• func NewDynamoDbProductDeleteRepository(db DynamoDBAPI, tableName string) domain.ProductDeleteRepository
• func NewDynamoDbProductFindAllRepository(db DynamoDBAPI, tableName string) domain.ProductFindAllRepository
• func NewDynamoDbProductFindRepository(db DynamoDBAPI, tableName string) domain.ProductFindRepository
• func NewDynamoDbProductSaveRepository(db DynamoDBAPI, tableName string) domain.ProductSaveRepository
• type DynamoDBAPI
• type DynamoDbProductEntity
  • func NewProductEntityFromDomain(product *domain.Product) (*DynamoDbProductEntity, error)
  • func (pe *DynamoDbProductEntity) ToDomain() (*domain.Product, error)

Functions

func CreateProductDeleteRepository

func CreateProductDeleteRepository(dependencies map[string]interface{}) (domain.ProductDeleteRepository, error)

func CreateProductFindAllRepository

func CreateProductFindAllRepository(dependencies map[string]interface{}) (domain.ProductFindAllRepository, error)

func CreateProductFindRepository

func CreateProductFindRepository(dependencies map[string]interface{}) (domain.ProductFindRepository, error)

func CreateProductSaveRepository

func CreateProductSaveRepository(dependencies map[string]interface{}) (domain.ProductSaveRepository, error)

func NewDynamoDbProductDeleteRepository

func NewDynamoDbProductDeleteRepository(db DynamoDBAPI, tableName string) domain.ProductDeleteRepository

func NewDynamoDbProductFindAllRepository

func NewDynamoDbProductFindAllRepository(db DynamoDBAPI, tableName string) domain.ProductFindAllRepository

func NewDynamoDbProductFindRepository

func NewDynamoDbProductFindRepository(db DynamoDBAPI, tableName string) domain.ProductFindRepository

func NewDynamoDbProductSaveRepository

func NewDynamoDbProductSaveRepository(db DynamoDBAPI, tableName string) domain.ProductSaveRepository

Types

type DynamoDBAPI

type DynamoDBAPI interface {
	PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
	GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)
	Scan(ctx context.Context, params *dynamodb.ScanInput, optFns ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)
	DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)
}

type DynamoDbProductEntity

type DynamoDbProductEntity struct {
	ID          string    `json:"id" dynamodbav:"id"`
	Name        string    `json:"name" dynamodbav:"name"`
	Description string    `json:"description" dynamodbav:"description"`
	Price       float64   `json:"price" dynamodbav:"price"`
	CreatedAt   time.Time `json:"created_at" dynamodbav:"created_at"`
	UpdatedAt   time.Time `json:"updated_at" dynamodbav:"updated_at"`
}

func NewProductEntityFromDomain

func NewProductEntityFromDomain(product *domain.Product) (*DynamoDbProductEntity, error)

func (*DynamoDbProductEntity) ToDomain

func (pe *DynamoDbProductEntity) ToDomain() (*domain.Product, error)