async

Documentation

Index

• func LogTermination(name string, logger *zap.Logger)
• func Run(ctx context.Context, wg *sync.WaitGroup, f Runner)
• type Operations
  • func NewOperations(ctx context.Context, logger *zap.Logger) Operations
• type Runner

Functions

func LogTermination

func LogTermination(name string, logger *zap.Logger)

func Run

func Run(ctx context.Context, wg *sync.WaitGroup, f Runner)

Run runs the provided function in a goroutine, and call wg.Done() when it returns. Stopping the async function is meant to be handled by the provided context.

Types

type Operations

type Operations interface {
	Run(name string, f Runner)
	Wait()
}

func NewOperations

func NewOperations(ctx context.Context, logger *zap.Logger) Operations

type Runner

type Runner func(ctx context.Context)

Runner is a function callable by async.Run()