transactions

Documentation

Index

• Constants
• Variables
• func Begin(ctx context.Context, db Client, opt ...options.Option) context.Context
• func DelayedDelete(ctx context.Context, keys ...foundations.WriteItemFunc)
• func DelayedPut(ctx context.Context, keys ...foundations.WriteItemFunc)
• func DelayedUpdate(ctx context.Context, keys ...foundations.WriteItemFunc)
• func Delete(ctx context.Context, keys ...foundations.WriteItemFunc)
• func Put(ctx context.Context, keys ...foundations.WriteItemFunc)
• func Run(ctx context.Context, opt ...options.Option) (*dynamodb.TransactWriteItemsOutput, error)
• func Update(ctx context.Context, keys ...foundations.WriteItemFunc)
• func With(ctx context.Context, f func(t *Builder))
• type Builder
  • func New(opt ...options.Option) *Builder
  • func (builder *Builder) DelayedDelete(keys ...foundations.WriteItemFunc) *Builder
  • func (builder *Builder) DelayedPut(keys ...foundations.WriteItemFunc) *Builder
  • func (builder *Builder) DelayedUpdate(keys ...foundations.WriteItemFunc) *Builder
  • func (builder *Builder) Delete(keys ...foundations.WriteItemFunc) *Builder
  • func (builder *Builder) Error() error
  • func (builder *Builder) HasError() bool
  • func (builder *Builder) Monitor(monitor Monitor) *Builder
  • 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 Context
  • func From(ctx context.Context) (*Context, bool)
  • func (t *Context) DB() 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 Monitor
• type Transaction

Constants

const (
	MaxGetItems = 100
)

const (
	MaxItems = 25
)

Variables

var NotBegan = errors.New("Transaction not began")

Functions

func Begin

func Begin(ctx context.Context, db Client, opt ...options.Option) context.Context

func DelayedDelete

func DelayedDelete(ctx context.Context, keys ...foundations.WriteItemFunc)

func DelayedPut

func DelayedPut(ctx context.Context, keys ...foundations.WriteItemFunc)

func DelayedUpdate

func DelayedUpdate(ctx context.Context, keys ...foundations.WriteItemFunc)

func Delete

func Delete(ctx context.Context, keys ...foundations.WriteItemFunc)

func Put

func Put(ctx context.Context, keys ...foundations.WriteItemFunc)

func Run

func Run(ctx context.Context, opt ...options.Option) (*dynamodb.TransactWriteItemsOutput, error)

func Update

func Update(ctx context.Context, keys ...foundations.WriteItemFunc)

func With

func With(ctx context.Context, f func(t *Builder))

Types

type Builder

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

func New

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

func (*Builder) DelayedDelete

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

func (*Builder) DelayedPut

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

func (*Builder) DelayedUpdate

func (builder *Builder) DelayedUpdate(keys ...foundations.WriteItemFunc) *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) Monitor

func (builder *Builder) Monitor(monitor Monitor) *Builder

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 Context

type Context struct {
	*Builder `json:"-" dynamodbav:"-"`
	// contains filtered or unexported fields
}

func From

func From(ctx context.Context) (*Context, bool)

func (*Context) DB

func (t *Context) DB() Client

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 Monitor

type Monitor func(items []types.TransactWriteItem, 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
}