inputbuilder

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 14, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type QueryBuilder

type QueryBuilder struct {
	TableName         string
	HashKeyCondition  *conditionexpression.EqualComparisonOperator
	RangeKeyCondition conditionexpression.RangeKeyConditionExpressionItem
	FilterExpression  conditionexpression.ExpressionItem
	ConsistentRead    bool
	IndexName         *string
	Limit             *int32
	ForwardScan       *bool
}

func NewQueryBuilder

func NewQueryBuilder() QueryBuilder

func (*QueryBuilder) Build

func (b *QueryBuilder) Build(queryInput *dynamodb.QueryInput) error

func (*QueryBuilder) SetConsistentRead

func (b *QueryBuilder) SetConsistentRead()

func (*QueryBuilder) WithFilterExpression

func (b *QueryBuilder) WithFilterExpression(filterExpression conditionexpression.ExpressionItem)

func (*QueryBuilder) WithForwardScan

func (b *QueryBuilder) WithForwardScan(forwardScan bool)

func (*QueryBuilder) WithHashKeyCondition

func (b *QueryBuilder) WithHashKeyCondition(hashKeyCondition *conditionexpression.EqualComparisonOperator)

func (*QueryBuilder) WithIndexName

func (b *QueryBuilder) WithIndexName(indexName string)

func (*QueryBuilder) WithLimit

func (b *QueryBuilder) WithLimit(limit int32)

func (*QueryBuilder) WithRangeKeyCondition

func (b *QueryBuilder) WithRangeKeyCondition(rangeKeyCondition conditionexpression.RangeKeyConditionExpressionItem)

func (*QueryBuilder) WithTableName

func (b *QueryBuilder) WithTableName(tableName string)

type ScanBuilder

type ScanBuilder struct {
	TableName        string
	FilterExpression conditionexpression.ExpressionItem
	ConsistentRead   bool
	IndexName        *string
	Limit            *int32
}

func NewScanBuilder

func NewScanBuilder() ScanBuilder

func (*ScanBuilder) Build

func (b *ScanBuilder) Build(input *dynamodb.ScanInput) error

func (*ScanBuilder) SetConsistentRead

func (b *ScanBuilder) SetConsistentRead()

func (*ScanBuilder) WithFilterExpression

func (b *ScanBuilder) WithFilterExpression(filterExpression conditionexpression.ExpressionItem)

func (*ScanBuilder) WithIndexName

func (b *ScanBuilder) WithIndexName(indexName string)

func (*ScanBuilder) WithLimit

func (b *ScanBuilder) WithLimit(limit int32)

func (*ScanBuilder) WithTableName

func (b *ScanBuilder) WithTableName(tableName string)

type UpdateBuilder

type UpdateBuilder struct {
	TableName string
	Key       map[string]interface{}

	Set    []*updateexpression.SetOperationItem
	Add    []*updateexpression.AddOperationItem
	Delete []*updateexpression.DeleteOperationItem
	Remove []expressionutils.AttributePath

	ConditionExpression conditionexpression.ExpressionItem
}

func NewUpdateBuilder

func NewUpdateBuilder() *UpdateBuilder

func (*UpdateBuilder) AppendAdd

func (b *UpdateBuilder) AppendAdd(addOperations ...*updateexpression.AddOperationItem)

func (*UpdateBuilder) AppendDelete

func (b *UpdateBuilder) AppendDelete(deleteOperations ...*updateexpression.DeleteOperationItem)

func (*UpdateBuilder) AppendRemove

func (b *UpdateBuilder) AppendRemove(removeOperations ...expressionutils.AttributePath)

func (*UpdateBuilder) AppendSet

func (b *UpdateBuilder) AppendSet(setOperations ...*updateexpression.SetOperationItem)

func (*UpdateBuilder) BuildUpdateItemInput

func (b *UpdateBuilder) BuildUpdateItemInput(input *dynamodb.UpdateItemInput) error

func (*UpdateBuilder) BuildUpdateTransactItem

func (b *UpdateBuilder) BuildUpdateTransactItem(input *types.Update) error

func (*UpdateBuilder) WithConditionExpression

func (b *UpdateBuilder) WithConditionExpression(conditionExpression conditionexpression.ExpressionItem)

func (*UpdateBuilder) WithKey

func (b *UpdateBuilder) WithKey(attribute expressionutils.AttributePath, value interface{})

func (*UpdateBuilder) WithKeyMap

func (b *UpdateBuilder) WithKeyMap(key map[string]interface{})

func (*UpdateBuilder) WithTableName

func (b *UpdateBuilder) WithTableName(tableName string)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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