dynamo

Documentation

Index

• type Provider
  • func NewProvider(client *dynamodb.Client) *Provider
  • func (p *Provider) DeleteItem(ctx context.Context, tableName string, key map[string]types.AttributeValue) error
  • func (p *Provider) DescribeTable(ctx context.Context, tableName string) (*models.TableInfo, error)
  • func (p *Provider) ListTables(ctx context.Context) ([]string, error)
  • func (p *Provider) PutItem(ctx context.Context, name string, item models.Item) error
  • func (p *Provider) PutItems(ctx context.Context, name string, items []models.Item) error
  • func (p *Provider) QueryItems(ctx context.Context, tableName string, indexName string, ...) ([]models.Item, map[string]types.AttributeValue, error)
  • func (p *Provider) ScanItems(ctx context.Context, tableName string, filterExpr *expression.Expression, ...) ([]models.Item, map[string]types.AttributeValue, error)

Types

type Provider

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

func NewProvider

func NewProvider(client *dynamodb.Client) *Provider

func (*Provider) DeleteItem

func (p *Provider) DeleteItem(ctx context.Context, tableName string, key map[string]types.AttributeValue) error

func (*Provider) DescribeTable

func (p *Provider) DescribeTable(ctx context.Context, tableName string) (*models.TableInfo, error)

func (*Provider) ListTables

func (p *Provider) ListTables(ctx context.Context) ([]string, error)

func (*Provider) PutItem

func (p *Provider) PutItem(ctx context.Context, name string, item models.Item) error

func (*Provider) PutItems

func (p *Provider) PutItems(ctx context.Context, name string, items []models.Item) error

func (*Provider) QueryItems

func (p *Provider) QueryItems(
	ctx context.Context,
	tableName string,
	indexName string,
	filterExpr *expression.Expression,
	exclusiveStartKey map[string]types.AttributeValue,
	maxItems int,
) ([]models.Item, map[string]types.AttributeValue, error)

func (*Provider) ScanItems

func (p *Provider) ScanItems(
	ctx context.Context,
	tableName string,
	filterExpr *expression.Expression,
	exclusiveStartKey map[string]types.AttributeValue,
	maxItems int,
) ([]models.Item, map[string]types.AttributeValue, error)