connectgrpc

package

v1.14.0 Latest Latest Go to latest Published: Jun 25, 2025 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func CloneRequest[Req any](base *connect.Request[Req], msg *Req) *connect.Request[Req]

func CodeToHTTP(code connect.Code) int32

func HTTPToCode(httpCode int32) connect.Code

func HandleUnary[Req any, Res any](ctx context.Context, req *httpgrpc.HTTPRequest, u UnaryHandler[Req, Res]) (*httpgrpc.HTTPResponse, error)

func NewClient(transport GRPCRoundTripper) connect.HTTPClient

func ProcedureFromContext(ctx context.Context) string

func RoundTripUnary[Req any, Res any](ctx context.Context, rt GRPCRoundTripper, in *connect.Request[Req]) (*connect.Response[Res], error)

func WithProcedure(ctx context.Context, u string) context.Context

type GRPCHandler interface {
	Handle(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
}

func NewHandler(h http.Handler) GRPCHandler

type GRPCRoundTripper interface {
	RoundTripGRPC(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
}

type UnaryHandler[Req any, Res any] func(context.Context, *connect.Request[Req]) (*connect.Response[Res], error)