grpcutil

Documentation

Index

• func EnumVal[T ~int32](v T) *T
• func IsStreamDoneErr(err error) bool
• func StreamRetryBackoff() *backoff.ExponentialBackOff

Functions

func EnumVal

func EnumVal[T ~int32](v T) *T

Make a pointer from an enum value, for the purpose of creating protobuf messages. Compare with the wrappers in the google.golang.org/protobuf/proto package.

func IsStreamDoneErr

func IsStreamDoneErr(err error) bool

Returns true if the error is one of the errors that can happen if a gRPC stream is ended by the client, or the associated context is cancelled during send/receive operation.

func StreamRetryBackoff

func StreamRetryBackoff() *backoff.ExponentialBackOff

Returns exponential backoff policy suitable for retrying send/receive operations on gRPC streams.