transactions

Documentation

Index

• Constants
• type Builder
  • func New(opt ...options.Option) *Builder
  • func (builder *Builder) Delete(keys ...foundations.WriteItemFunc) *Builder
  • func (builder *Builder) Error() error
  • func (builder *Builder) HasError() bool
  • func (builder *Builder) Put(keys ...foundations.WriteItemFunc) *Builder
  • func (builder *Builder) Run(ctx context.Context, cli Client) (out *dynamodb.TransactWriteItemsOutput, err error)
  • func (builder *Builder) Update(keys ...foundations.WriteItemFunc) *Builder
• type Client
• type GetBuilder
  • func Get(keys ...foundations.GetItemFunc) *GetBuilder
  • func (builder *GetBuilder) HasError() bool
  • func (builder *GetBuilder) Run(ctx context.Context, cli Client, fetch foundations.FetchItemFunc) (out *dynamodb.TransactGetItemsOutput, err error)
• type Transaction

Constants

const (
	MaxGetItems = 100
)

const (
	MaxItems = 25
)

Types

type Builder

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

func New

func New(opt ...options.Option) *Builder

func (*Builder) Delete

func (builder *Builder) Delete(keys ...foundations.WriteItemFunc) *Builder

Delete 削除用

func (*Builder) Error

func (builder *Builder) Error() error

func (*Builder) HasError

func (builder *Builder) HasError() bool

func (*Builder) Put

func (builder *Builder) Put(keys ...foundations.WriteItemFunc) *Builder

Put 追加用

func (*Builder) Run

func (builder *Builder) Run(ctx context.Context, cli Client) (out *dynamodb.TransactWriteItemsOutput, err error)

func (*Builder) Update

func (builder *Builder) Update(keys ...foundations.WriteItemFunc) *Builder

Update 更新用

type Client

type Client interface {
	TransactWriteItems(ctx context.Context, params *dynamodb.TransactWriteItemsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.TransactWriteItemsOutput, error)
	TransactGetItems(ctx context.Context, params *dynamodb.TransactGetItemsInput, optFns ...func(*dynamodb.Options)) (*dynamodb.TransactGetItemsOutput, error)
}

type GetBuilder

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

func Get

func Get(keys ...foundations.GetItemFunc) *GetBuilder

func (*GetBuilder) HasError

func (builder *GetBuilder) HasError() bool

func (*GetBuilder) Run

func (builder *GetBuilder) Run(ctx context.Context, cli Client, fetch foundations.FetchItemFunc) (out *dynamodb.TransactGetItemsOutput, err error)

type Transaction

type Transaction interface {
	PutItem(ctx context.Context, expiredAt ...time.Time) foundations.WriteItemFunc
	DeleteItem(ctx context.Context) foundations.WriteItemFunc
	UpdateItem(ctx context.Context, fields ...foundations.UpdateField) foundations.WriteItemFunc
}