gateway

Sep 21, 2024

Changes in this version

+ const MetadataHeaderPrefix

+ const MetadataPrefix

+ const MetadataTrailerPrefix

+ var DefaultContextTimeout = 0 * time.Second

+ func HTTPPathPattern(ctx context.Context) (string, bool)

+ func NewContextWithServerTransportStream(ctx context.Context, s grpc.ServerStream, method string) context.Context

+ func NewServerMetadataContext(ctx context.Context, md ServerMetadata) context.Context

+ func RPCMethod(ctx context.Context) (string, bool)

+ func TransparentHandler(cli grpc.ClientConnInterface, inType, outType protoreflect.MessageType, ...) grpc.StreamHandler

+ type AnnotateContextOption func(ctx context.Context) context.Context

+ func WithHTTPPathPattern(pattern string) AnnotateContextOption

type Gateway

+ GetOperation func(operation string) *GrpcMethod

+ type GrpcMethod struct

+ GrpcFullMethod string

+ GrpcMethodDesc *grpc.MethodDesc

+ GrpcStreamDesc *grpc.StreamDesc

+ Meta *lavapbv1.RpcMeta

+ MethodDesc protoreflect.MethodDescriptor

+ Srv any

+ SrvDesc *grpc.ServiceDesc

+ type GrpcMethodHandler = func(srv any, ctx context.Context, dec func(any) error, ...) (any, error)

+ type GrpcStreamHandler = grpc.StreamHandler

+ type MatchOperation = routertree.MatchOperation

type Mux

+ func (m *Mux) GetOperation(operation string) *GrpcMethod

+ func (m *Mux) GetOperationByName(name string) *GrpcMethod

+ func (m *Mux) MatchOperation(method string, path string) (r result.Result[*MatchOperation])

+ func (m *Mux) RegisterProxy(sd *grpc.ServiceDesc, proxy lava.GrpcRouter, cli grpc.ClientConnInterface)

+ type PathFieldVar = routertree.PathFieldVar

+ type RouteOperation = routertree.RouteOperation

+ type ServerMetadata struct

+ HeaderMD metadata.MD

+ TrailerMD metadata.MD

+ func ServerMetadataFromContext(ctx context.Context) (md ServerMetadata, ok bool)

+ type ServerTransportStream struct

+ func (s *ServerTransportStream) Header() metadata.MD

+ func (s *ServerTransportStream) Method() string

+ func (s *ServerTransportStream) SendHeader(md metadata.MD) error

+ func (s *ServerTransportStream) SetHeader(md metadata.MD) error

+ func (s *ServerTransportStream) SetTrailer(md metadata.MD) error

+ func (s *ServerTransportStream) Trailer() metadata.MD

+ type StreamDirector func(ctx context.Context, fullMethodName string) (context.Context, grpc.ClientConnInterface, error)

Apr 29, 2024

Changes in this version

+ func FieldMaskFromRequestBody(r io.Reader, msg proto.Message) (*fieldmask.FieldMask, error)

+ func HTTPStatusCode(c codes.Code) int

+ func HTTPStatusFromCode(code codes.Code) int

+ func PopulateFieldFromPath(msg proto.Message, fieldPathString, value string) error

+ func PopulateQueryParameters(msg proto.Message, values url.Values, filter *utilities.DoubleArray) error

+ type Codec interface

+ MarshalAppend func([]byte, interface{}) ([]byte, error)

+ type CodecJSON struct

+ func (CodecJSON) Name() string

+ func (c CodecJSON) Marshal(v interface{}) ([]byte, error)

+ func (c CodecJSON) MarshalAppend(b []byte, v interface{}) ([]byte, error)

+ func (c CodecJSON) ReadNext(b []byte, r io.Reader, limit int) ([]byte, int, error)

+ func (c CodecJSON) Unmarshal(data []byte, v interface{}) error

+ func (c CodecJSON) WriteNext(w io.Writer, b []byte) (int, error)

+ type CodecProto struct

+ func (CodecProto) Name() string

+ func (CodecProto) Unmarshal(data []byte, v interface{}) error

+ func (c CodecProto) Marshal(v interface{}) ([]byte, error)

+ func (c CodecProto) MarshalAppend(b []byte, v interface{}) ([]byte, error)

+ func (c CodecProto) ReadNext(b []byte, r io.Reader, limit int) ([]byte, int, error)

+ func (c CodecProto) WriteNext(w io.Writer, b []byte) (int, error)

+ type Compressor interface

+ type CompressorGzip struct

+ Level *int

+ func (*CompressorGzip) Name() string

+ func (c *CompressorGzip) Compress(w io.Writer) (io.WriteCloser, error)

+ func (c *CompressorGzip) Decompress(r io.Reader) (io.Reader, error)

+ type DefaultQueryParser struct

+ func (*DefaultQueryParser) Parse(msg proto.Message, values url.Values, filter *utilities.DoubleArray) error

+ type Gateway interface

+ GetRouteMethods func() []*routex.RouteTarget

+ Handler func(*fiber.Ctx) error

+ RegisterService func(sd *grpc.ServiceDesc, ss interface{})

+ ServeHTTP func(http.ResponseWriter, *http.Request)

+ SetRequestDecoder func(protoreflect.FullName, func(ctx *fiber.Ctx, msg proto.Message) error)

+ SetResponseEncoder func(protoreflect.FullName, func(ctx *fiber.Ctx, msg proto.Message) error)

+ SetStreamInterceptor func(interceptor grpc.StreamServerInterceptor)

+ SetUnaryInterceptor func(interceptor grpc.UnaryServerInterceptor)

+ type Mux struct

+ func NewMux(opts ...MuxOption) *Mux

+ func (m *Mux) GetRouteMethods() []*routex.RouteTarget

+ func (m *Mux) Handler(ctx *fiber.Ctx) error

+ func (m *Mux) Invoke(ctx context.Context, method string, args, reply any, opts ...grpc.CallOption) error

+ func (m *Mux) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

+ func (m *Mux) RegisterService(sd *grpc.ServiceDesc, ss interface{})

+ func (m *Mux) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ func (m *Mux) SetRequestDecoder(name protoreflect.FullName, f func(ctx *fiber.Ctx, msg proto.Message) error)

+ func (m *Mux) SetResponseEncoder(name protoreflect.FullName, f func(ctx *fiber.Ctx, msg proto.Message) error)

+ func (m *Mux) SetStreamInterceptor(interceptor grpc.StreamServerInterceptor)

+ func (m *Mux) SetUnaryInterceptor(interceptor grpc.UnaryServerInterceptor)

+ type MuxOption func(*muxOptions)

+ func CodecOption(contentType string, c Codec) MuxOption

+ func CompressorOption(contentEncoding string, c Compressor) MuxOption

+ func ConnectionTimeoutOption(d time.Duration) MuxOption

+ func FilesOption(f *protoregistry.Files) MuxOption

+ func MaxReceiveMessageSizeOption(s int) MuxOption

+ func MaxSendMessageSizeOption(s int) MuxOption

+ func TypesOption(t protoregistry.MessageTypeResolver) MuxOption

+ type QueryParameterParser interface

+ Parse func(msg proto.Message, values url.Values, filter *utilities.DoubleArray) error

+ type RouteTarget = routex.RouteTarget

+ func GetRouterTarget(mux *Mux, kind, path string) (*RouteTarget, error)

+ type StreamCodec interface

+ ReadNext func(buf []byte, r io.Reader, limit int) (dst []byte, n int, err error)

+ WriteNext func(w io.Writer, src []byte) (n int, err error)