Documentation ¶
Index ¶
- Variables
- func GRPCResponse[I, O any](ctx context.Context, l *zap.Logger, result chan I, chErrs []chan error, ...) (*O, error)
- func NewClient[T any](e env.Env, portNumber int, f func(grpc.ClientConnInterface) T, ...) (T, func() error, 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 ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.