gateway

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)