larking

package

Go to main page

Versions in this module

v0

v0.3.1

May 17, 2023

Changes in this version

+ func AsHTTPBodyReader(stream grpc.ServerStream, msg proto.Message) (body io.Reader, err error)

+ func AsHTTPBodyWriter(stream grpc.ServerStream, msg proto.Message) (body io.Writer, err error)

v0.3.0

May 15, 2023

Changes in this version

+ 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 MuxOption

+ func CompressorOption(contentEncoding string, c Compressor) MuxOption

v0.2.0

May 12, 2023

Changes in this version

type CodecJSON

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

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

type CodecProto

+ 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 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)

v0.1.0

May 9, 2023

Changes in this version

+ func HTTPStatusCode(c codes.Code) int

+ func NewOSSignalContext(ctx context.Context) (context.Context, func())

+ func NewStreamContext(ctxFn NewContextFunc) grpc.StreamServerInterceptor

+ func NewUnaryContext(ctxFn NewContextFunc) grpc.UnaryServerInterceptor

+ func WSStatusCode(c codes.Code) ws.StatusCode

+ 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) SizeRead(b []byte, r io.Reader, limit int) ([]byte, int, error)

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

+ func (c CodecJSON) Unmarshal(data []byte, v interface{}) 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) SizeRead(b []byte, r io.Reader, limit int) ([]byte, int, error)

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

+ type Mux struct

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

+ func (m *Mux) DropConn(ctx context.Context, cc *grpc.ClientConn) bool

+ func (m *Mux) RegisterConn(ctx context.Context, cc *grpc.ClientConn) error

+ func (m *Mux) RegisterReflectionServer(s *grpc.Server)

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

+ func (m *Mux) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (m *Mux) StreamHandler() grpc.StreamHandler

+ type MuxOption func(*muxOptions)

+ func CodecOption(contentType string, c Codec) MuxOption

+ func ConnectionTimeoutOption(d time.Duration) MuxOption

+ func FilesOption(f *protoregistry.Files) MuxOption

+ func MaxReceiveMessageSizeOption(s int) MuxOption

+ func MaxSendMessageSizeOption(s int) MuxOption

+ func ServiceConfigOption(sc *serviceconfig.Service) MuxOption

+ func StatsOption(h stats.Handler) MuxOption

+ func StreamServerInterceptorOption(interceptor grpc.StreamServerInterceptor) MuxOption

+ func TypesOption(t protoregistry.MessageTypeResolver) MuxOption

+ func UnaryServerInterceptorOption(interceptor grpc.UnaryServerInterceptor) MuxOption

+ type NewContextFunc func(ctx context.Context, fullMethod string, isClientStream, isServerStream bool) context.Context

+ type Server struct

+ func NewServer(mux *Mux, opts ...ServerOption) (*Server, error)

+ func (s *Server) Close() error

+ func (s *Server) Serve(l net.Listener) error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerOption func(*serverOptions) error

+ func HTTPHandlerOption(pattern string, handler http.Handler) ServerOption

+ func InsecureServerOption() ServerOption

+ func MuxHandleOption(patterns ...string) ServerOption

+ func TLSCredsOption(c *tls.Config) ServerOption

+ type SizeCodec interface

+ SizeRead func(dst []byte, r io.Reader, limit int) ([]byte, int, error)

+ SizeWrite func(w io.Writer, src []byte) (int, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL