table

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxBatchWritesPerRequest = 25
	MaxBatchReadsPerRequest  = 100
)
View Source 
const (
	MaxTransactWriteItems = 100
	MaxTransactReadItems  = 100
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Addable 

type Addable interface {
	// contains filtered or unexported methods
}

type AddableFunc 

type AddableFunc func() expression.ValueBuilder

func Number 

func Number[T number](value T) AddableFunc

type BatchGetBuilder 

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

func BatchGet 

func BatchGet(readers ...procedure.BatchGetModifier) BatchGetBuilder

func (BatchGetBuilder) Build 

func (b BatchGetBuilder) Build() procedure.MultiBatchGet

type BatchWriteBuilder 

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

func BatchWrite 

func BatchWrite(writers ...procedure.BatchWriteModifier) BatchWriteBuilder

func (BatchWriteBuilder) Build 

func (b BatchWriteBuilder) Build() procedure.MultiBatchWrite

type BeginsWithExpression 

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

func BeginsWith 

func BeginsWith(value string) BeginsWithExpression

type BetweenExpression 

type BetweenExpression[T keytype] struct {
	// contains filtered or unexported fields
}

func Between 

func Between[T keytype](lower, upper T) BetweenExpression[T]

type Builder 

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

func New 

func New(tableName string, options ...Option) Builder

func (Builder) Check 

func (b Builder) Check(key ItemKeyProvider) ConditionCheckBuilder

func (Builder) Delete 

func (b Builder) Delete(key ItemKeyProvider) DeleteBuilder

func (Builder) Get 

func (b Builder) Get(key ItemKeyProvider) GetBuilder

func (Builder) Put 

func (b Builder) Put(data any) PutBuilder

func (Builder) Query 

func (b Builder) Query(attribute string, expr HashExpression) QueryBuilder

func (Builder) TableName 

func (b Builder) TableName() string

func (Builder) Update 

func (b Builder) Update(key ItemKeyProvider) UpdateBuilder

type ConditionCheckBuilder 

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

func (ConditionCheckBuilder) And 

func (c ConditionCheckBuilder) And(attribute string, eval FilterExpression) ConditionCheckBuilder

func (ConditionCheckBuilder) AndNot 

func (c ConditionCheckBuilder) AndNot(attribute string, eval FilterExpression) ConditionCheckBuilder

func (ConditionCheckBuilder) If 

func (c ConditionCheckBuilder) If(attribute string, eval FilterExpression) ConditionCheckBuilder

func (ConditionCheckBuilder) ModifyTransactWriteItemsInput 

func (c ConditionCheckBuilder) ModifyTransactWriteItemsInput(ctx context.Context,
	input *dynamodb.TransactWriteItemsInput) error

func (ConditionCheckBuilder) Or 

func (c ConditionCheckBuilder) Or(attribute string, eval FilterExpression) ConditionCheckBuilder

func (ConditionCheckBuilder) OrNot 

func (c ConditionCheckBuilder) OrNot(attribute string, eval FilterExpression) ConditionCheckBuilder

type DeleteBuilder 

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

func (DeleteBuilder) Build 

func (d DeleteBuilder) Build() procedure.Delete

func (DeleteBuilder) Execute 

func (d DeleteBuilder) Execute(ctx context.Context, deleter ezddb.Deleter) error

func (DeleteBuilder) If 

func (d DeleteBuilder) If(condition expression.ConditionBuilder) DeleteBuilder

type EqualsExpression 

type EqualsExpression[T any] struct {
	// contains filtered or unexported fields
}

func Equals 

func Equals(value any) EqualsExpression[any]

type FilterExpression 

type FilterExpression interface {
	// contains filtered or unexported methods
}

type FilterExpressionFunc 

type FilterExpressionFunc func(attribute string) expression.ConditionBuilder

func Contains 

func Contains(value string) FilterExpressionFunc

func ContainsElement 

func ContainsElement(value string) FilterExpressionFunc

func ContainsSubstring 

func ContainsSubstring(value string) FilterExpressionFunc

func Exists 

func Exists() FilterExpressionFunc

func IsType 

func IsType(value expression.DynamoDBAttributeType) FilterExpressionFunc

func LessThan 

func LessThan[T keytype](value T) FilterExpressionFunc

func NotExists 

func NotExists() FilterExpressionFunc

type GetBuilder 

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

func (GetBuilder) Build 

func (g GetBuilder) Build() procedure.Get

func (GetBuilder) Execute 

func (g GetBuilder) Execute(ctx context.Context, getter ezddb.Getter) GetResult

type GetResult 

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

func (GetResult) Error 

func (g GetResult) Error() error

func (GetResult) UnmarshalItem 

func (g GetResult) UnmarshalItem(out any) error

type GreaterThanEqualExpression 

type GreaterThanEqualExpression[T keytype] struct {
	// contains filtered or unexported fields
}

func GreaterThanEqual 

func GreaterThanEqual[T keytype](value T) GreaterThanEqualExpression[T]

type GreaterThanExpression 

type GreaterThanExpression[T keytype] struct {
	// contains filtered or unexported fields
}

func GreaterThan 

func GreaterThan[T keytype](value T) GreaterThanExpression[T]

type HashExpression 

type HashExpression interface {
	RangeExpression
	// contains filtered or unexported methods
}

type InExpression 

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

func In 

func In(values ...any) InExpression

type ItemKeyProvider 

type ItemKeyProvider interface {
	DynamoItemKey() ezddb.Item
}

type KeyEqualsExpression 

type KeyEqualsExpression[T keytype] EqualsExpression[T]

func KeyEquals 

func KeyEquals[T keytype](value T) KeyEqualsExpression[T]

type LessThanEqualExpression 

type LessThanEqualExpression[T keytype] struct {
	// contains filtered or unexported fields
}

func LessThanEqual 

func LessThanEqual[T keytype](value T) LessThanEqualExpression[T]

type LessThanExpression 

type LessThanExpression[T keytype] struct {
	// contains filtered or unexported fields
}

type NotEqualsExpression 

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

func NotEquals 

func NotEquals(value any) NotEqualsExpression

type NotExpression 

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

func Not 

func Not(expr FilterExpression) NotExpression

type Option 

type Option func(*Builder)

func WithExpressionBuilder 

func WithExpressionBuilder(builder expressionBuilder) Option

func WithMapListUnmarshaler 

func WithMapListUnmarshaler(unmarshaler mapListUnmarshaler) Option

func WithMapMarshaler 

func WithMapMarshaler(marshaler mapMarshaler) Option

func WithMapUnmarshaler 

func WithMapUnmarshaler(unmarshaler mapUnmarshaler) Option

func WithStartKeyProvider 

func WithStartKeyProvider(provider procedure.StartKeyProvider) Option

func WithStartTokenProvider 

func WithStartTokenProvider(provider procedure.StartKeyTokenProvider) Option

type PutBuilder 

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

func (PutBuilder) And 

func (p PutBuilder) And(attribute string, expr FilterExpression) PutBuilder

func (PutBuilder) Build 

func (p PutBuilder) Build() procedure.Put

func (PutBuilder) Execute 

func (p PutBuilder) Execute(ctx context.Context, putter ezddb.Putter) error

func (PutBuilder) If 

func (p PutBuilder) If(attribute string, expr FilterExpression) PutBuilder

func (PutBuilder) Or 

func (p PutBuilder) Or(attribute string, expr FilterExpression) PutBuilder

func (PutBuilder) WithCondition 

func (p PutBuilder) WithCondition(expr expression.ConditionBuilder) PutBuilder

type QueryBuilder 

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

func (QueryBuilder) And 

func (q QueryBuilder) And(attribute string, expr FilterExpression) QueryBuilder

func (QueryBuilder) Build 

func (q QueryBuilder) Build() procedure.Query

func (QueryBuilder) Execute 

func (q QueryBuilder) Execute(ctx context.Context, querier ezddb.Querier) QueryResult

func (QueryBuilder) Forward 

func (q QueryBuilder) Forward() QueryBuilder

func (QueryBuilder) Index 

func (q QueryBuilder) Index(name string) QueryBuilder

func (QueryBuilder) Limit 

func (q QueryBuilder) Limit(count int) QueryBuilder

func (QueryBuilder) Or 

func (q QueryBuilder) Or(attribute string, expr FilterExpression) QueryBuilder

func (QueryBuilder) Range 

func (q QueryBuilder) Range(attribute string, expr RangeExpression) QueryBuilder

func (QueryBuilder) StartFromKey 

func (q QueryBuilder) StartFromKey(key ezddb.Item) QueryBuilder

func (QueryBuilder) StartFromToken 

func (q QueryBuilder) StartFromToken(token string) QueryBuilder

func (QueryBuilder) Where 

func (q QueryBuilder) Where(attribute string, expr FilterExpression) QueryBuilder

func (QueryBuilder) WithFilterCondition 

func (q QueryBuilder) WithFilterCondition(cond expression.ConditionBuilder) QueryBuilder

type QueryResult 

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

func (QueryResult) Error 

func (q QueryResult) Error() error

func (QueryResult) HasNext 

func (q QueryResult) HasNext() bool

func (QueryResult) LastStartKey 

func (q QueryResult) LastStartKey() ezddb.Item

func (QueryResult) LastStartToken 

func (q QueryResult) LastStartToken(ctx context.Context) (string, error)

func (QueryResult) NextPage 

func (q QueryResult) NextPage(ctx context.Context) QueryResult

func (QueryResult) Output 

func (q QueryResult) Output() *dynamodb.QueryOutput

func (QueryResult) UnmarshalItems 

func (q QueryResult) UnmarshalItems(out any) error

type RangeExpression 

type RangeExpression interface {
	// contains filtered or unexported methods
}

type ScanBuilder 

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

func (ScanBuilder) And 

func (s ScanBuilder) And(attribute string, expr FilterExpression) ScanBuilder

func (ScanBuilder) AndNot 

func (s ScanBuilder) AndNot(attribute string, expr FilterExpression) ScanBuilder

func (ScanBuilder) Build 

func (q ScanBuilder) Build() procedure.Scan

func (ScanBuilder) Execute 

func (s ScanBuilder) Execute(ctx context.Context, scanner ezddb.Scanner) ScanResult

func (ScanBuilder) Index 

func (s ScanBuilder) Index(name string) ScanBuilder

func (ScanBuilder) Limit 

func (s ScanBuilder) Limit(count int) ScanBuilder

func (ScanBuilder) Or 

func (s ScanBuilder) Or(attribute string, expr FilterExpression) ScanBuilder

func (ScanBuilder) OrNot 

func (s ScanBuilder) OrNot(attribute string, expr FilterExpression) ScanBuilder

func (ScanBuilder) StartFromKey 

func (s ScanBuilder) StartFromKey(key ezddb.Item) ScanBuilder

func (ScanBuilder) StartFromToken 

func (s ScanBuilder) StartFromToken(token string) ScanBuilder

func (ScanBuilder) Where 

func (s ScanBuilder) Where(attribute string, expr FilterExpression) ScanBuilder

func (ScanBuilder) WithFilterCondition 

func (s ScanBuilder) WithFilterCondition(cond expression.ConditionBuilder) ScanBuilder

type ScanResult 

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

func (ScanResult) Error 

func (s ScanResult) Error() error

func (ScanResult) HasNext 

func (s ScanResult) HasNext() bool

func (ScanResult) LastStartKey 

func (s ScanResult) LastStartKey() ezddb.Item

func (ScanResult) LastStartToken 

func (s ScanResult) LastStartToken(ctx context.Context) (string, error)

func (ScanResult) NextPage 

func (s ScanResult) NextPage(ctx context.Context) ScanResult

func (ScanResult) Output 

func (s ScanResult) Output() *dynamodb.ScanOutput

func (ScanResult) UnmarshalItems 

func (s ScanResult) UnmarshalItems(out any) error

type SizeExpression 

type SizeExpression interface {
	// contains filtered or unexported methods
}

type TransactGetBuilder 

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

func TransactGet 

func TransactGet(readers ...procedure.TransactionGetModifier) TransactGetBuilder

func (TransactGetBuilder) Build 

func (t TransactGetBuilder) Build() procedure.MultiTransactionGet

type TransactWriteBuilder 

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

func TransactWrite 

func TransactWrite(writers ...procedure.TransactionWriteModifier) TransactWriteBuilder

func (TransactWriteBuilder) Build 

func (t TransactWriteBuilder) Build() procedure.MultiTransactionWrite

func (TransactWriteBuilder) If 

func (t TransactWriteBuilder) If(tableName string, attribute string, expr FilterExpression) TransactWriteBuilder

type UpdateBuilder 

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

func (UpdateBuilder) AddElement 

func (u UpdateBuilder) AddElement(attribute string, value any) UpdateBuilder

func (UpdateBuilder) Build 

func (u UpdateBuilder) Build() procedure.Update

func (UpdateBuilder) DeleteElements 

func (u UpdateBuilder) DeleteElements(attribute string, values ...any) UpdateBuilder

func (UpdateBuilder) If 

func (u UpdateBuilder) If(builder expression.ConditionBuilder) UpdateBuilder

func (UpdateBuilder) Increment 

func (u UpdateBuilder) Increment(attribute string, addable Addable) UpdateBuilder

func (UpdateBuilder) Remove 

func (u UpdateBuilder) Remove(attribute string) UpdateBuilder

func (UpdateBuilder) RemoveElementsAtIndex 

func (u UpdateBuilder) RemoveElementsAtIndex(attribute string, indices ...int) UpdateBuilder

func (UpdateBuilder) Set 

func (u UpdateBuilder) Set(attribute string, value any) UpdateBuilder

func (UpdateBuilder) SetIf 

func (u UpdateBuilder) SetIf(attribute string) UpdateSetBuilder

func (UpdateBuilder) Then 

func (u UpdateBuilder) Then() UpdateBuilder

func (UpdateBuilder) WithUpdateExpression 

func (u UpdateBuilder) WithUpdateExpression(builder expression.UpdateBuilder) UpdateBuilder

type UpdateSetBuilder 

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

func (UpdateSetBuilder) AttributeNotExists 

func (u UpdateSetBuilder) AttributeNotExists(attribute string) UpdateSetBuilder

func (UpdateSetBuilder) NotExists 

func (u UpdateSetBuilder) NotExists() UpdateSetBuilder

func (UpdateSetBuilder) Value 

func (u UpdateSetBuilder) Value(value any) UpdateBuilder

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.