Documentation ¶ Index ¶ Variables func GRPCResponse[I, O any](ctx context.Context, l *zap.Logger, result chan I, chErrs []chan error, ...) (*O, error) func StreamRecvToChan[K any](ctx context.Context, recv func() (K, error)) (chan K, chan error) Constants ¶ This section is empty. Variables ¶ View Source var ( ErrTimeout = status.Errorf(codes.DeadlineExceeded, "") ErrInternal = status.Errorf(codes.Internal, "") ) Functions ¶ func GRPCResponse ¶ func GRPCResponse[I, O any](ctx context.Context, l *zap.Logger, result chan I, chErrs []chan error, responseBuilder func(i I) (*O, error)) (*O, error) func StreamRecvToChan ¶ func StreamRecvToChan[K any](ctx context.Context, recv func() (K, error)) (chan K, chan error) Types ¶ This section is empty. Source Files ¶ View all Source files grpc_response.go stream_recv_to_chan.go Click to show internal directories. Click to hide internal directories.