Versions in this module Expand all Collapse all v0 v0.0.2 Mar 10, 2022 Changes in this version + var ErrKeyTagNotFound = errors.New("key tag not found") type DynamoDB + func (d *DynamoDB) GetStruct(ctx context.Context, in interface{}, result interface{}) (err error) + func (d *DynamoDB) ListStruct(ctx context.Context, in interface{}, result interface{}) (err error) v0.0.1 Feb 23, 2022 Changes in this version + const KEY_TAG + var DefaultTimeout = 10 * time.Second + var ErrKeyNotFound = errors.New("key not found") + var ErrNothingToCommit = errors.New("nothing to commit") + var ErrUnexpectedInput = errors.New("unexpected input") + var ErrUnsupported = errors.New("unsupported") + func IsExistingTable(err error) (bool, error) + type BatchWriter struct + func (b *BatchWriter) Contents() interface{} + func (b *BatchWriter) DeleteStruct(in interface{}) (err error) + func (b *BatchWriter) InsertStruct(in interface{}) (err error) + func (b *BatchWriter) Len() int + func (b *BatchWriter) Put(ctx context.Context, in interface{}) (err error) + func (b *BatchWriter) UpdateStruct(in interface{}) (err error) + type DynamoDB struct + func NewDynamoDB(ctx context.Context, confOpts []func(*config.LoadOptions) error, ...) (d DynamoDB, err error) + func (d *DynamoDB) Commit(ctx context.Context, writer *BatchWriter) (out interface{}, err error) + func (d *DynamoDB) CreateTable(ctx context.Context, arg *dynamodb.CreateTableInput) (out interface{}, err error) + func (d *DynamoDB) CreateTableFromStruct(ctx context.Context, in interface{}) (out interface{}, err error) + func (d *DynamoDB) DescribeTable(ctx context.Context, arg *dynamodb.DescribeTableInput) (out interface{}, err error) + func (d *DynamoDB) DescribeTableFromStruct(ctx context.Context, in interface{}) (out interface{}, err error) + func (d *DynamoDB) DropTable(ctx context.Context, arg *dynamodb.DeleteTableInput) (out interface{}, err error) + func (d *DynamoDB) DropTableFromStruct(ctx context.Context, in interface{}) (out interface{}, err error) + func (d *DynamoDB) Get(ctx context.Context, arg *dynamodb.GetItemInput) (out interface{}, err error) + func (d *DynamoDB) List(ctx context.Context, arg *dynamodb.ScanInput) (out interface{}, err error) + func (d *DynamoDB) WaitForTableCreation(ctx context.Context, in interface{}) error + func (d *DynamoDB) WaitForTableDeletion(ctx context.Context, in interface{}) error + func (d *DynamoDB) Writer(ctx context.Context) (out BatchWriter, err error) + type Handler func(ctx context.Context, in interface{}) (out interface{}, err error) + type Logger zerolog.Logger + func WithLogger(logger zerolog.Logger) Logger + func (o Logger) Apply(d *DynamoDB) error + type Middleware func(next Handler) Handler + type Option interface + Apply func(*DynamoDB) error + type Timeout time.Duration + func WithTimeout(timeout time.Duration) Timeout + func (o Timeout) Apply(d *DynamoDB) error