dynamodb

package

v0.0.0-...-e5c234f Latest Latest Go to latest Published: Jun 15, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/virgaio/go-aws

Links

Open Source Insights

Documentation ¶

Index ¶

type Attributes
- func (a Attributes) ToItem() Item
type Item
- func (i Item) Merge(i2 Item)
type ItemBase
- func (i *ItemBase) GetKey() Item
- func (i *ItemBase) GetPuttableItem() Item
type ItemCreateInput
type ItemReaderInput
- func NewItemReaderInput(itemTypeName, tableName, hashKeyName, sortKeyName string, ...) *ItemReaderInput
type ItemWriterInput
- func NewItemWriterInput(itemTypeName, tableName, hashKeyName, sortKeyName string, ...) *ItemWriterInput
type Items
type RecordParamHelper

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Attributes ¶

type Attributes map[string]interface{}

func (Attributes) ToItem ¶

func (a Attributes) ToItem() Item

type Item ¶

type Item map[string]*dynamodb.AttributeValue

func (Item) Merge ¶

func (i Item) Merge(i2 Item)

type ItemBase ¶

type ItemBase struct {
	TableName    string
	HashKeyName  string
	HashKeyValue interface{}
	SortKeyName  string
	SortKeyValue interface{}
	ItemTypeName string
	Attributes   Attributes
}

func (*ItemBase) GetKey ¶

func (i *ItemBase) GetKey() Item

func (*ItemBase) GetPuttableItem ¶

func (i *ItemBase) GetPuttableItem() Item

type ItemCreateInput ¶

type ItemCreateInput struct {
	ItemBase
}

type ItemReaderInput ¶

type ItemReaderInput struct {
	IndexName string
	ItemBase
}

func NewItemReaderInput ¶

func NewItemReaderInput(itemTypeName, tableName, hashKeyName, sortKeyName string, hashKeyValue, sortKeyValue interface{}) *ItemReaderInput

func (*ItemReaderInput) Get ¶

func (i *ItemReaderInput) Get(sess *session.Session) (*dynamodb.GetItemOutput, error)

func (*ItemReaderInput) List ¶

func (i *ItemReaderInput) List(sess *session.Session, limit int64, reverse bool) (*dynamodb.QueryOutput, error)

func (*ItemReaderInput) Scan ¶

func (i *ItemReaderInput) Scan(sess *session.Session, limit int64) (*dynamodb.ScanOutput, error)

type ItemWriterInput ¶

type ItemWriterInput struct {
	ItemBase
}

func NewItemWriterInput ¶

func NewItemWriterInput(itemTypeName, tableName, hashKeyName, sortKeyName string, hashKeyValue, sortKeyValue interface{}) *ItemWriterInput

func (*ItemWriterInput) Create ¶

func (i *ItemWriterInput) Create(sess *session.Session) (*dynamodb.PutItemOutput, error)

func (*ItemWriterInput) CreateWithItem ¶

func (i *ItemWriterInput) CreateWithItem(sess *session.Session,
	item Item) (*dynamodb.PutItemOutput, error)

func (*ItemWriterInput) Delete ¶

func (i *ItemWriterInput) Delete(sess *session.Session) (*dynamodb.DeleteItemOutput, error)

func (*ItemWriterInput) Update ¶

func (i *ItemWriterInput) Update(sess *session.Session) (*dynamodb.UpdateItemOutput, error)

func (*ItemWriterInput) UpdateWithBuilder ¶

func (i *ItemWriterInput) UpdateWithBuilder(sess *session.Session, builder *expression.UpdateBuilder) (*dynamodb.UpdateItemOutput, error)

func (*ItemWriterInput) Upsert ¶

func (i *ItemWriterInput) Upsert(sess *session.Session) (*dynamodb.PutItemOutput, error)

type Items ¶

type Items []map[string]*dynamodb.AttributeValue

type RecordParamHelper ¶

type RecordParamHelper struct {
	Params  url.Values
	Builder *expression.UpdateBuilder
	Changed bool
}

func (*RecordParamHelper) AddToBuilder ¶

func (rph *RecordParamHelper) AddToBuilder(key, val string)

func (*RecordParamHelper) SetBoolFromParam ¶

func (rph *RecordParamHelper) SetBoolFromParam(loc *bool, key string)

func (*RecordParamHelper) SetFloatFromParam ¶

func (rph *RecordParamHelper) SetFloatFromParam(loc *float64, key string)

func (*RecordParamHelper) SetInt64FromParam ¶

func (rph *RecordParamHelper) SetInt64FromParam(loc *int64, key string)

func (*RecordParamHelper) SetIntFromParam ¶

func (rph *RecordParamHelper) SetIntFromParam(loc *int, key string)

func (*RecordParamHelper) SetStringFromParam ¶

func (rph *RecordParamHelper) SetStringFromParam(loc *string, key string)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL