effect

Documentation

Index

• type Buffer
  • func (b *Buffer) Apply(ctx context.Context)
  • func (b *Buffer) Cancel(ctx context.Context)
  • func (b *Buffer) OnAfterCommit(effect func(context.Context))
  • func (b *Buffer) OnAfterRollback(effect func(context.Context))
• type Controller
  • func Immediate(ctx context.Context) Controller

Types

type Buffer

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

Buffer holds a set of effect and rollback functions that can be invoked as a batch with a defined order. Once either Apply or Cancel is called, all buffered effects are cleared. This type is not threadsafe. The zero-value of a Buffer is a valid state.

func (*Buffer) Apply

func (b *Buffer) Apply(ctx context.Context)

Apply invokes the buffered effect functions in the order that they were added to this Buffer.

func (*Buffer) Cancel

func (b *Buffer) Cancel(ctx context.Context)

Cancel invokes the buffered rollback functions in the reverse of the order that they were added to this Buffer.

func (*Buffer) OnAfterCommit

func (b *Buffer) OnAfterCommit(effect func(context.Context))

OnAfterCommit adds the provided effect function to set of such functions to be invoked when Buffer.Apply is called.

func (*Buffer) OnAfterRollback

func (b *Buffer) OnAfterRollback(effect func(context.Context))

OnAfterRollback adds the provided effect function to set of such functions to be invoked when Buffer.Cancel is called.

type Controller

type Controller interface {
	OnAfterCommit(func(context.Context))
	OnAfterRollback(func(context.Context))
}

func Immediate

func Immediate(ctx context.Context) Controller

Immediate returns an effects.Set that executes effects immdiately upon insertion. Useful in contexts where you don't actually want to delay effect application and in tests.