rpctimeout

Documentation

Overview

Package rpctimeout provides helpers to have timeouts on rpc streams.

Index

• func Run(ctx context.Context, timeout time.Duration, fn func(ctx context.Context) error) error

Functions

func Run

func Run(ctx context.Context, timeout time.Duration, fn func(ctx context.Context) error) error

Run runs the provided function with a context that will be canceled after the provided duration or when the provided function returns. It returns either the error from the context or the error from the function. It runs the function in its own goroutine and DOES NOT wait for it to exit. This is on purpose to get around some grpc brain damage with respect to canceling operations on server streams.