dtable

Documentation

Index

• func GetKeysAndAttributes(pk, sk string, keys []Key) []map[string]*dynamodb.AttributeValue
• type BatchGetItemInput
• type BatchGetItemOutput
• type Key
• type Table
  • func New(conn *dynamodb.DynamoDB, name string, log logrus.FieldLogger) *Table
  • func (t *Table) BatchGetItem(ctx aws.Context, in *BatchGetItemInput) (*BatchGetItemOutput, error)
  • func (t *Table) Conn() *dynamodb.DynamoDB
  • func (t *Table) DeleteItem(ctx aws.Context, in *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)
  • func (t *Table) GetItem(ctx aws.Context, in *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)
  • func (t *Table) PutItem(ctx aws.Context, in *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)
  • func (t *Table) Query(ctx aws.Context, in *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)
  • func (t *Table) UpdateItem(ctx aws.Context, in *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

Functions

func GetKeysAndAttributes

func GetKeysAndAttributes(pk, sk string, keys []Key) []map[string]*dynamodb.AttributeValue

Types

type BatchGetItemInput

type BatchGetItemInput struct {
	KeysAndAttributes      *dynamodb.KeysAndAttributes
	ReturnConsumedCapacity *string
}

type BatchGetItemOutput

type BatchGetItemOutput struct {
	ConsumedCapacity []*dynamodb.ConsumedCapacity
	Responses        []map[string]*dynamodb.AttributeValue
	UnprocessedKeys  map[string]*dynamodb.KeysAndAttributes
}

type Key

type Key struct {
	PK string
	SK string
}

type Table

type Table struct {
	Name string
	// contains filtered or unexported fields
}

func New

func New(conn *dynamodb.DynamoDB, name string, log logrus.FieldLogger) *Table

func (*Table) BatchGetItem

func (t *Table) BatchGetItem(ctx aws.Context, in *BatchGetItemInput) (*BatchGetItemOutput, error)

func (*Table) Conn

func (t *Table) Conn() *dynamodb.DynamoDB

func (*Table) DeleteItem

func (t *Table) DeleteItem(ctx aws.Context, in *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)

func (*Table) GetItem

func (t *Table) GetItem(ctx aws.Context, in *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)

func (*Table) PutItem

func (t *Table) PutItem(ctx aws.Context, in *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)

func (*Table) Query

func (t *Table) Query(ctx aws.Context, in *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

func (*Table) UpdateItem

func (t *Table) UpdateItem(ctx aws.Context, in *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)