dynamodb

Documentation

Index

• Constants
• type DB
  • func Open(opt *types.DynamoDBOpt) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) Get(ctx context.Context, opt online.GetOpt) (dbutil.RowMap, error)
  • func (db *DB) Import(ctx context.Context, opt online.ImportOpt) error
  • func (db *DB) MultiGet(ctx context.Context, opt online.MultiGetOpt) (map[string]dbutil.RowMap, error)
  • func (db *DB) Ping(ctx context.Context) error
  • func (db *DB) PrepareStreamTable(ctx context.Context, opt online.PrepareStreamTableOpt) error
  • func (db *DB) Purge(ctx context.Context, revisionID int) error
  • func (db *DB) Push(ctx context.Context, opt online.PushOpt) error

Constants

const (
	Backend = types.BackendDynamoDB
)

const (
	BatchGetItemCapacity = 100
)

const (
	BatchWriteItemCapacity = 25
)

Types

type DB

type DB struct {
	*dynamodb.Client
}

func Open

func Open(opt *types.DynamoDBOpt) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

dynamodb is serverless so Close won't do anything

func (*DB) Get

func (db *DB) Get(ctx context.Context, opt online.GetOpt) (dbutil.RowMap, error)

func (*DB) Import

func (db *DB) Import(ctx context.Context, opt online.ImportOpt) error

func (*DB) MultiGet

func (db *DB) MultiGet(ctx context.Context, opt online.MultiGetOpt) (map[string]dbutil.RowMap, error)

response: map[entity_key]map[feature_name]feature_value

func (*DB) Ping

func (db *DB) Ping(ctx context.Context) error

func (*DB) PrepareStreamTable

func (db *DB) PrepareStreamTable(ctx context.Context, opt online.PrepareStreamTableOpt) error

func (*DB) Purge

func (db *DB) Purge(ctx context.Context, revisionID int) error

func (*DB) Push

func (db *DB) Push(ctx context.Context, opt online.PushOpt) error