srpc

package module

Go to main page

Versions in this module

v0

v0.0.6

May 8, 2025

v0.0.5

May 7, 2025

v0.0.4

May 7, 2025

v0.0.3

May 7, 2025

Changes in this version

type ServerOption

+ func GlobalHandler(h func(next http.Handler) http.Handler) ServerOption

v0.0.2

May 7, 2025

Changes in this version

+ func ResponseWriterFromContext(ctx context.Context) (http.ResponseWriter, bool)

v0.0.1

Apr 22, 2025

Changes in this version

+ var ErrServerStopped = errors.New("srpc: the server has been stopped")

+ func NewClient(target string, opt ...ClientOption) (*client, error)

+ func NewServer(opt ...ServerOption) *server

+ type CallOption = grpc.CallOption

+ type Client interface

+ type ClientConn = grpc.ClientConn

+ type ClientOption func(o *clientOptions)

+ func WithChainStreamInterceptor(Interceptors ...StreamClientInterceptor) ClientOption

+ func WithChainUnaryInterceptor(Interceptors ...UnaryClientInterceptor) ClientOption

+ func WithGRPCOptions(opts ...DialOption) ClientOption

+ func WithStreamInterceptor(interceptor StreamClientInterceptor) ClientOption

+ func WithUnaryInterceptor(interceptor UnaryClientInterceptor) ClientOption

+ type ClientStream = grpc.ClientStream

+ type DialOption = grpc.DialOption

+ type GRPCStreamDesc = grpc.StreamDesc

+ type Handler struct

+ func (h *Handler) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)

+ type Implementation func(ctx context.Context, stream protocol.StreamingHandlerConn) error

+ type Interceptor struct

+ func (i *Interceptor) ChainStreamInterceptor(ints ...StreamServerInterceptor) *Interceptor

+ func (i *Interceptor) ChainUnaryInterceptor(ints ...UnaryServerInterceptor) *Interceptor

+ func (i *Interceptor) StreamClientInterceptor() StreamClientInterceptor

+ func (i *Interceptor) StreamInterceptor() StreamServerInterceptor

+ func (i *Interceptor) UnaryClientInterceptor() UnaryClientInterceptor

+ func (i *Interceptor) UnaryInterceptor() UnaryServerInterceptor

+ func (i *Interceptor) WithChainStreamInterceptor(ints ...StreamClientInterceptor) *Interceptor

+ func (i *Interceptor) WithChainUnaryInterceptor(ints ...UnaryClientInterceptor) *Interceptor

+ type Server interface

+ GracefulStop func()

+ Handle func(pattern string, handler http.Handler)

+ Serve func(l net.Listener) error

+ Stop func()

+ type ServerOption func(o *serverOptions)

+ func ChainStreamInterceptor(ints ...StreamServerInterceptor) ServerOption

+ func ChainUnaryInterceptor(ints ...UnaryServerInterceptor) ServerOption

+ func Codec(codecs ...encoding.Codec) ServerOption

+ func Compression(name string, decompressor compress.Decompressor, ...) ServerOption

+ func CompressionMinBytes(n int) ServerOption

+ func Creds(c credentials.TransportCredentials) ServerOption

+ func EnableTracing() ServerOption

+ func IdleTimeout(d time.Duration) ServerOption

+ func MaxConcurrentStreams(n uint32) ServerOption

+ func MaxRecvMsgSize(n int) ServerOption

+ func MaxSendMsgSize(n int) ServerOption

+ func ReadTimeout(d time.Duration) ServerOption

+ func StreamInterceptor(i StreamServerInterceptor) ServerOption

+ func UnaryInterceptor(i UnaryServerInterceptor) ServerOption

+ func UnknownHandler(h http.Handler) ServerOption

+ func WriteTimeout(d time.Duration) ServerOption

+ type ServerStream = grpc.ServerStream

+ type StreamClientInterceptor = grpc.StreamClientInterceptor

+ type StreamHandler = grpc.StreamHandler

+ type StreamServerInfo = grpc.StreamServerInfo

+ type StreamServerInterceptor = grpc.StreamServerInterceptor

+ type Streamer = grpc.Streamer

+ type UnaryClientInterceptor = grpc.UnaryClientInterceptor

+ type UnaryHandler = grpc.UnaryHandler

+ type UnaryInvoker = grpc.UnaryInvoker

+ type UnaryServerInfo = grpc.UnaryServerInfo

+ type UnaryServerInterceptor = grpc.UnaryServerInterceptor

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