pendingOperation

Documentation

Index

• Variables
• type PendingOperation
  • func TrackOperation(fn func() error) PendingOperation
• type WithCancel
  • func TrackOperationWithCancel(ctx context.Context, fn func(ctx context.Context) error) WithCancel

Variables

var ErrOperationStillPending = errors.New("operation is still pending")

Types

type PendingOperation

type PendingOperation interface {
	Done() <-chan struct{}
	Err() error
	Wait(ctx context.Context) error
}

func TrackOperation

func TrackOperation(fn func() error) PendingOperation

type WithCancel

type WithCancel interface {
	PendingOperation
	Cancel()
}

func TrackOperationWithCancel

func TrackOperationWithCancel(ctx context.Context, fn func(ctx context.Context) error) WithCancel