middleware

func CallbackInterceptor ¶

func CallbackInterceptor(logger *zerolog.Logger, onCallback func(ctx context.Context) error) connect.UnaryInterceptorFunc

CallbackInterceptor creates an interceptor that can receive callbacks from handlers

func TriggerCallback ¶

func TriggerCallback(ctx context.Context)

func TriggerResourceCallback ¶ added in v0.119.3

func TriggerResourceCallback(ctx context.Context, resourceType constants.ResourceTypeValue, resourceID string, correlationID *string)

TriggerResourceCallback reports one committed resource to the request's callback. Each call builds its own context, so resources reported in a loop don't share values.

func WithCallback ¶

func WithCallback(ctx context.Context, callback CallbackFunc) context.Context