func google.golang.org/grpc/status.New
30 uses
google.golang.org/grpc/status (current package)
status.go#L48: func New(c codes.Code, msg string) *Status {
status.go#L54: return New(c, fmt.Sprintf(format, a...))
status.go#L59: return New(c, msg).Err()
status.go#L108: return New(codes.Unknown, err.Error()), false
status.go#L120: return New(codes.Unknown, err.Error()), false
status.go#L126: return New(codes.Unknown, err.Error()), false
status.go#L156: return New(codes.DeadlineExceeded, err.Error())
status.go#L159: return New(codes.Canceled, err.Error())
status.go#L161: return New(codes.Unknown, err.Error())
google.golang.org/grpc
rpc_util.go#L913: return status.New(codes.Internal, "grpc: compressed flag set with identity or empty encoding")
server.go#L94: var statusOK = status.New(codes.OK, "")
server.go#L1788: if err := stream.WriteStatus(status.New(codes.Unimplemented, errDesc)); err != nil {
server.go#L1881: if err := stream.WriteStatus(status.New(codes.Unimplemented, errDesc)); err != nil {
google.golang.org/grpc/internal/transport
client_stream.go#L77: return status.New(s.nonGRPCStatus.Code(), msg)
http2_client.go#L1069: st = status.New(codes.Unavailable, err.Error())
http2_client.go#L1231: t.closeStream(s, io.EOF, true, http2.ErrCodeFlowControl, status.New(codes.Internal, err.Error()), nil, false)
http2_client.go#L1268: t.closeStream(s, io.EOF, rstStream, http2.ErrCodeNo, status.New(codes.Internal, "server closed the stream without sending trailers"), nil, true)
http2_client.go#L1482: st := status.New(codes.Internal, "a HEADERS frame cannot appear in the middle of a stream")
http2_client.go#L1490: se := status.New(codes.Internal, "peer header list size exceeded limit")
http2_client.go#L1537: se := status.New(codes.Unknown, fmt.Sprintf("transport: malformed grpc-status: %v", err))
http2_client.go#L1572: se := status.New(grpcErrorCode, fmt.Sprintf("transport: malformed http-status: %v", err))
http2_client.go#L1578: se := status.New(codes.Internal, fmt.Sprintf(
http2_client.go#L1605: se := status.New(grpcErrorCode, strings.Join(errs, "; "))
http2_client.go#L1616: se := status.New(codes.Internal, headerError)
http2_client.go#L1731: t.closeStream(s, status.Error(code, msg), true, http2.ErrCodeProtocol, status.New(code, msg), nil, false)
http2_server.go#L490: t.writeEarlyAbort(streamID, s.contentSubtype, status.New(codes.Internal, errMsg), http.StatusBadRequest, !frame.StreamEnded())
http2_server.go#L562: t.writeEarlyAbort(streamID, s.contentSubtype, status.New(codes.Internal, errMsg), http.StatusMethodNotAllowed, !frame.StreamEnded())
http2_server.go#L575: stat = status.New(codes.PermissionDenied, err.Error())
http2_server.go#L584: st := status.New(codes.DeadlineExceeded, context.DeadlineExceeded.Error())
transport.go#L734: statusGoAway = status.New(codes.Unavailable, "the stream is rejected because server is draining the connection")