server

package

Go to main page

Versions in this module

v1

v1.6.43

Jul 26, 2021

v1.6.42

Jul 22, 2021

v1.6.41

Jul 22, 2021

Changes in this version

+ const CodeInternalJSONRPCError

+ const CodeInvalidParams

+ const CodeInvalidjsonrpcRequest

+ const CodeMethodNotFound

+ const CodeParseJSONRPCError

+ const CodeUnknownJSONRPCError

+ var ErrNotAccept = errors.New("server refused the connection")

+ var HttpConnContextKey = &contextKey

+ var TagContextKey = &contextKey

+ type CMuxPlugin interface

+ MuxMatch func(m cmux.CMux)

+ type CORSOptions struct

+ AllowCredentials bool

+ AllowOriginFunc func(origin string) bool

+ AllowOriginRequestFunc func(r *http.Request, origin string) bool

+ AllowedHeaders []string

+ AllowedMethods []string

+ AllowedOrigins []string

+ Debug bool

+ ExposedHeaders []string

+ MaxAge int

+ OptionsPassthrough bool

+ func AllowAllCORSOptions() *CORSOptions

+ type DownloadFileHandler func(conn net.Conn, args *share.DownloadFileArgs)

+ type FileTransfer struct

+ Addr string

+ AdvertiseAddr string

+ func NewFileTransfer(addr string, handler FileTransferHandler, ...) *FileTransfer

+ func (s *FileTransfer) Start() error

+ func (s *FileTransfer) Stop() error

+ type FileTransferHandler func(conn net.Conn, args *share.FileTransferArgs)

+ type FileTransferService struct

+ FileTransfer *FileTransfer

+ func (s *FileTransferService) DownloadFile(ctx context.Context, args *share.DownloadFileArgs, ...) error

+ func (s *FileTransferService) TransferFile(ctx context.Context, args *share.FileTransferArgs, ...) error

+ type HeartbeatPlugin interface

+ HeartbeatRequest func(ctx context.Context, req *protocol.Message) error

+ type ID struct

+ Name string

+ Number int64

+ func (id *ID) MarshalJSON() ([]byte, error)

+ func (id *ID) String() string

+ func (id *ID) UnmarshalJSON(data []byte) error

+ type JSONRPCError struct

+ Code int64

+ Data *json.RawMessage

+ Message string

+ func (err *JSONRPCError) JSONRPCError() string

type OptionFn

+ func WithTCPKeepAlivePeriod(period time.Duration) OptionFn

type PluginContainer

+ DoHeartbeatRequest func(ctx context.Context, req *protocol.Message) error

+ DoPostCall func(ctx context.Context, serviceName, methodName string, args, reply interface{}) (interface{}, error)

+ DoPostConnClose func(net.Conn) bool

+ DoPreCall func(ctx context.Context, serviceName, methodName string, args interface{}) (interface{}, error)

+ DoPreHandleRequest func(ctx context.Context, req *protocol.Message) error

+ DoUnregister func(name string) error

+ MuxMatch func(m cmux.CMux)

+ type PostCallPlugin interface

+ PostCall func(ctx context.Context, serviceName, methodName string, args, reply interface{}) (interface{}, error)

+ type PostConnClosePlugin interface

+ HandleConnClose func(net.Conn) bool

+ type PreCallPlugin interface

+ PreCall func(ctx context.Context, serviceName, methodName string, args interface{}) (interface{}, error)

+ type PreHandleRequestPlugin interface

+ PreHandleRequest func(ctx context.Context, r *protocol.Message) error

type RegisterPlugin

+ Unregister func(name string) error

type Server

+ DisableHTTPGateway bool

+ DisableJSONRPC bool

+ HandleServiceError func(error)

+ func (s *Server) ActiveClientConn() []net.Conn

+ func (s *Server) EnableFileTransfer(serviceName string, fileTransfer *FileTransfer)

+ func (s *Server) EnableStreamService(serviceName string, streamService *StreamService)

+ func (s *Server) RegisterOnRestart(f func(s *Server))

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

+ func (s *Server) ServeListener(network string, ln net.Listener) (err error)

+ func (s *Server) ServeWS(conn *websocket.Conn)

+ func (s *Server) SetCORS(options *CORSOptions)

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

+ func (s *Server) UnregisterAll() error

+ type StreamAcceptor func(ctx context.Context, args *share.StreamServiceArgs) bool

+ type StreamHandler func(conn net.Conn, args *share.StreamServiceArgs)

+ type StreamService struct

+ Addr string

+ AdvertiseAddr string

+ func NewStreamService(addr string, streamHandler StreamHandler, acceptor StreamAcceptor, waitNum int) *StreamService

+ func (s *StreamService) Start() error

+ func (s *StreamService) Stop() error

+ func (s *StreamService) Stream(ctx context.Context, args *share.StreamServiceArgs, ...) error

+ type VersionTag struct

+ func (VersionTag) MarshalJSON() ([]byte, error)

+ func (VersionTag) UnmarshalJSON(data []byte) error

v1.3.1

Feb 22, 2018

Changes in this version

+ const ReaderBuffsize

+ const WriterBuffsize

+ const XErrorMessage

+ const XHeartbeat

+ const XMessageID

+ const XMessageStatusType

+ const XMessageType

+ const XMeta

+ const XOneway

+ const XSerializeType

+ const XServiceMethod

+ const XServicePath

+ const XVersion

+ var ErrServerClosed = errors.New("http: Server closed")

+ var RemoteConnContextKey = &contextKey

+ var StartRequestContextKey = &contextKey

+ var StartSendRequestContextKey = &contextKey

+ var UsePool bool

+ func HTTPRequest2RpcxRequest(r *http.Request) (*protocol.Message, error)

+ func RegisterMakeListener(network string, ml MakeListener)

+ type MakeListener func(s *Server, address string) (ln net.Listener, err error)

+ type OptionFn func(*Server)

+ func WithReadTimeout(readTimeout time.Duration) OptionFn

+ func WithTLSConfig(cfg *tls.Config) OptionFn

+ func WithWriteTimeout(writeTimeout time.Duration) OptionFn

+ type Plugin interface

+ type PluginContainer interface

+ Add func(plugin Plugin)

+ All func() []Plugin

+ DoPostConnAccept func(net.Conn) (net.Conn, bool)

+ DoPostReadRequest func(ctx context.Context, r *protocol.Message, e error) error

+ DoPostWriteRequest func(ctx context.Context, r *protocol.Message, e error) error

+ DoPostWriteResponse func(context.Context, *protocol.Message, *protocol.Message, error) error

+ DoPreReadRequest func(ctx context.Context) error

+ DoPreWriteRequest func(ctx context.Context) error

+ DoPreWriteResponse func(context.Context, *protocol.Message) error

+ DoRegister func(name string, rcvr interface{}, metadata string) error

+ DoRegisterFunction func(name string, fn interface{}, metadata string) error

+ Remove func(plugin Plugin)

+ type PostConnAcceptPlugin interface

+ HandleConnAccept func(net.Conn) (net.Conn, bool)

+ type PostReadRequestPlugin interface

+ PostReadRequest func(ctx context.Context, r *protocol.Message, e error) error

+ type PostWriteRequestPlugin interface

+ PostWriteRequest func(ctx context.Context, r *protocol.Message, e error) error

+ type PostWriteResponsePlugin interface

+ PostWriteResponse func(context.Context, *protocol.Message, *protocol.Message, error) error

+ type PreReadRequestPlugin interface

+ PreReadRequest func(ctx context.Context) error

+ type PreWriteRequestPlugin interface

+ PreWriteRequest func(ctx context.Context) error

+ type PreWriteResponsePlugin interface

+ PreWriteResponse func(context.Context, *protocol.Message) error

+ type RegisterFunctionPlugin interface

+ RegisterFunction func(name string, fn interface{}, metadata string) error

+ type RegisterPlugin interface

+ Register func(name string, rcvr interface{}, metadata string) error

+ type Reset interface

+ Reset func()

+ type Server struct

+ AuthFunc func(ctx context.Context, req *protocol.Message, token string) error

+ Plugins PluginContainer

+ func NewServer(options ...OptionFn) *Server

+ func (s *Server) Address() net.Addr

+ func (s *Server) Close() error

+ func (s *Server) Register(rcvr interface{}, metadata string) error

+ func (s *Server) RegisterFunction(servicePath string, fn interface{}, metadata string) error

+ func (s *Server) RegisterFunctionName(servicePath string, name string, fn interface{}, metadata string) error

+ func (s *Server) RegisterName(name string, rcvr interface{}, metadata string) error

+ func (s *Server) RegisterOnShutdown(f func())

+ func (s *Server) SendMessage(conn net.Conn, servicePath, serviceMethod string, metadata map[string]string, ...) error

+ func (s *Server) Serve(network, address string) (err error)

+ func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

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