dynamo

Documentation

Index

• func MarshalJSONGZ(v any) ([]byte, error)
• func UnmarshalJSONGZ(d []byte, v any) error
• type Marshaler
• type Service
  • func NewService(accessKey, secretKey, region, endpoint, tablePrefix string) (*Service, error)
  • func (s *Service) GetItem(ctx context.Context, table string, key map[string]types.AttributeValue, ...) error
  • func (s *Service) PutItem(ctx context.Context, table string, v any) error
  • func (s *Service) TableName(base string) string
  • func (s *Service) Test(ctx context.Context) error
• type Unmarshaler

Functions

func MarshalJSONGZ

func MarshalJSONGZ(v any) ([]byte, error)

func UnmarshalJSONGZ

func UnmarshalJSONGZ(d []byte, v any) error

Types

type Marshaler

type Marshaler interface {
	MarshalDynamo() (map[string]types.AttributeValue, error)
}

type Service

type Service struct {
	Client *dynamodb.Client
	// contains filtered or unexported fields
}

Service is simple abstraction layer to work with a DynamoDB-compatible database

func NewService

func NewService(accessKey, secretKey, region, endpoint, tablePrefix string) (*Service, error)

NewService creates a new dynamodb service with the given credentials and configuration

func (*Service) GetItem

func (s *Service) GetItem(ctx context.Context, table string, key map[string]types.AttributeValue, dst any) error

GetItem retrieves an item from the given table

func (*Service) PutItem

func (s *Service) PutItem(ctx context.Context, table string, v any) error

PutItem puts an item into the given table

func (*Service) TableName

func (s *Service) TableName(base string) string

TableName returns the full table name with the prefix

func (*Service) Test

func (s *Service) Test(ctx context.Context) error

Test checks if the service is working by trying to list tables

type Unmarshaler

type Unmarshaler interface {
	UnmarshalDynamo(map[string]types.AttributeValue) error
}