service

Documentation

Index

• func Context() (ctx context.Context, cancel context.CancelFunc)
• func RegisterOnContextDone(ctx context.Context, fn func())
• type Function
  • func Wrap[IN, OUT any](fn func(in IN) (out OUT, err error)) Function[IN, OUT]

Functions

func Context

func Context() (ctx context.Context, cancel context.CancelFunc)

Context creates a new context with a cancel function that listens for SIGTERM, SIGINT, SIGQUIT, and SIGKILL signals.

func RegisterOnContextDone

func RegisterOnContextDone(ctx context.Context, fn func())

RegisterOnContextDone waits for the context to be done and then calls the function.

Types

type Function

type Function[IN, OUT any] func(ctx context.Context, in IN) (out OUT, err error)

Function gathers together things that change for the same reasons. A context must be handled to be "cloud native" because it allows propagation of deadlines, cancellation signals, and other request-scoped values across API boundaries and between processes. This ensures efficient resource utilization and proper handling of asynchronous workflows in distributed systems.

func Wrap

func Wrap[IN, OUT any](fn func(in IN) (out OUT, err error)) Function[IN, OUT]

Wrap converts a simple function into one that respects a provided context. This enables the wrapped function to respond to context cancellation or timeout.