server

Index ¶

• Constants
• func LocalIp() (string, error)
• type Options
• • func BuffSize(buffSize int) Options
  • func Codec(cc codec.Codec) Options
  • func E(e *endpoint.Endpoint) Options
  • func Error(err parcel.ErrorPackager) Options
  • func Exit(exit ...func()) Options
  • func Id(id string) Options
  • func Namespace(name string) Options
  • func Port(port [2]int) Options
  • func Registry(registry registry.Registry) Options
  • func Signal(signal ...os.Signal) Options
  • func TCPAddress(address string) Options
  • func Transport(transport transport.Server) Options
  • func Version(version string) Options
  • func Wrapper(wrappers ...parcel.Wrapper) Options
  • func WssAddress(address, path string) Options
• type RocServer
• • func NewRocServer(opts ...Options) *RocServer
• • func (r *RocServer) Close()
  • func (r *RocServer) Codec() codec.Codec
  • func (r *RocServer) E() *endpoint.Endpoint
  • func (r *RocServer) Id() string
  • func (r *RocServer) Name() string
  • func (r *RocServer) Register() registry.Registry
  • func (r *RocServer) RegisterChannelHandler(method string, rs parcel.ChannelHandler)
  • func (r *RocServer) RegisterHandler(method string, rr parcel.Handler)
  • func (r *RocServer) RegisterStreamHandler(method string, rs parcel.StreamHandler)
  • func (r *RocServer) Run() error
  • func (r *RocServer) TCPAddress() string
  • func (r *RocServer) Transport() transport.Server
  • func (r *RocServer) Version() string
  • func (r *RocServer) WssAddress() string
  • func (r *RocServer) WssPath() string