Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v6

v6.1.0

Feb 9, 2021

Changes in this version

type FileTransfer

+ AdvertiseAddr string

v6.0.1

Jan 12, 2021

v6.0.0

Dec 19, 2020

Changes in this version

+ const CodeInternalJSONRPCError

+ const CodeInvalidParams

+ const CodeInvalidjsonrpcRequest

+ const CodeMethodNotFound

+ const CodeParseJSONRPCError

+ const CodeUnknownJSONRPCError

+ 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 HttpConnContextKey = &contextKey

+ var RemoteConnContextKey = &contextKey

+ var StartRequestContextKey = &contextKey

+ var StartSendRequestContextKey = &contextKey

+ var TagContextKey = &contextKey

+ var UsePool bool

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

+ func RegisterMakeListener(network string, ml MakeListener)

+ 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

+ 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 MakeListener func(s *Server, address string) (ln net.Listener, err error)

+ type OptionFn func(*Server)

+ func WithReadTimeout(readTimeout time.Duration) OptionFn

+ func WithTCPKeepAlivePeriod(period 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

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

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

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

+ DoPostConnClose func(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

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

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

+ DoPreReadRequest func(ctx context.Context) error

+ DoPreWriteRequest func(ctx context.Context) error

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

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

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

+ DoUnregister func(name string) error

+ Remove func(plugin Plugin)

+ type PostCallPlugin interface

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

+ type PostConnAcceptPlugin interface

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

+ type PostConnClosePlugin interface

+ HandleConnClose func(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 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 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, *protocol.Message, error) error

+ type RegisterFunctionPlugin interface

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

+ type RegisterPlugin interface

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

+ Unregister func(name string) error

+ type Reset interface

+ Reset func()

+ type Server struct

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

+ DisableHTTPGateway bool

+ DisableJSONRPC bool

+ Plugins PluginContainer

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

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

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

+ func (s *Server) Close() error

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

+ 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) RegisterOnRestart(f func(s *Server))

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

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

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

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

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

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

+ func (s *Server) UnregisterAll() error

+ type VersionTag struct

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

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

Other modules containing this package

github.com/smallnest/rpcx

github.com/smallnest/rpcx/v5