baidurpc

package module

Go to main page

Versions in this module

v1

v1.4.0

Dec 8, 2022

Changes in this version

+ const MagicSize

+ const Shutdown_Timeout

v1.3.4

Sep 24, 2021

v1.3.3

Sep 24, 2021

v1.3.2

Sep 6, 2021

Changes in this version

type TcpServer

+ EnablePerformanceLog bool

v1.3.1

Aug 26, 2021

v1.3.0

Aug 26, 2021

Changes in this version

+ var File_brpc_meta_proto protoreflect.FileDescriptor

+ var File_go_proto protoreflect.FileDescriptor

type ChunkInfo

+ func (x *ChunkInfo) ProtoReflect() protoreflect.Message

type QpsData

+ func (*QpsData) Descriptor() ([]byte, []int)

+ func (x *QpsData) GetQpsinfo() map[int64]int32

+ func (x *QpsData) ProtoReflect() protoreflect.Message

type RPCMethod

+ func (*RPCMethod) Descriptor() ([]byte, []int)

+ func (x *RPCMethod) GetInTypeMeta() string

+ func (x *RPCMethod) GetMethod() string

+ func (x *RPCMethod) GetReturnTypeMeta() string

+ func (x *RPCMethod) GetService() string

+ func (x *RPCMethod) ProtoReflect() protoreflect.Message

type RPCStatus

+ func (*RPCStatus) Descriptor() ([]byte, []int)

+ func (x *RPCStatus) GetHost() string

+ func (x *RPCStatus) GetMethods() []*RPCMethod

+ func (x *RPCStatus) GetPort() int32

+ func (x *RPCStatus) GetTimeout() int32

+ func (x *RPCStatus) ProtoReflect() protoreflect.Message

type Request

+ func (x *Request) GetParentSpanId() int64

+ func (x *Request) GetRpcRequestMetaExt() []*RpcRequestMetaExtField

+ func (x *Request) GetSpanId() int64

+ func (x *Request) GetTraceId() int64

+ func (x *Request) ProtoReflect() protoreflect.Message

type Response

+ func (x *Response) ProtoReflect() protoreflect.Message

type RpcDataPackage

+ func (r *RpcDataPackage) ChuckInfo(streamId int64, chunkId int64) *RpcDataPackage

type RpcMeta

+ ChuckInfo *ChunkInfo

+ func (x *RpcMeta) GetChuckInfo() *ChunkInfo

+ func (x *RpcMeta) ProtoReflect() protoreflect.Message

type RpcRequestMetaExtField

+ func (*RpcRequestMetaExtField) Descriptor() ([]byte, []int)

+ func (x *RpcRequestMetaExtField) ProtoReflect() protoreflect.Message

v1.2.2

Sep 24, 2021

v1.2.1

Sep 6, 2021

Changes in this version

type Connection

+ Reconnect func() error

type TCPConnection

+ func (c *TCPConnection) Reconnect() error

type TCPConnectionPool

+ func (c *TCPConnectionPool) Reconnect() error

v1.2.0

Aug 23, 2021

v1.1.3

Aug 23, 2021

Changes in this version

+ const Auth_key

+ const HttpRpcPath

+ const LogId_key

+ const Request_Meta_Key

+ const Trace_Id_key

+ const Trace_Parent_key

+ const Trace_Span_key

+ func BindLogId(c context.Context, logid int64) context.Context

+ func LogID(context context.Context) int64

+ func UnescapeUnicode(raw []byte) ([]byte, error)

+ type HttpServer struct

+ func (h *HttpServer) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type ResponseData struct

+ Data interface{}

+ ErrNo int

+ Message string

type TcpServer

+ func (s *TcpServer) EnableHttp()

v1.1.2

Aug 19, 2021

v1.1.1

Aug 6, 2021

Changes in this version

+ const Proto2_Version

+ const ST_AUTH_ERROR

+ const ST_READ_TIMEOUT

+ var LOG_TIMECOST_INFO = "[server-101]Server name '%s' method '%s' process cost '%.5g' seconds"

+ var LOG_TIMECOST_INFO2 = "[server-102]Server name '%s' method '%s' process cost '%.5g' seconds.(without net cost) "

+ type AuthService interface

+ Authenticate func(service, name string, authToken []byte) bool

type Connection

+ Receive func() (*RpcDataPackage, error)

+ Send func(rpcDataPackage *RpcDataPackage) error

type HaRpcClient

+ func NewHaRpcCientWithTimewheelSetting(connections []Connection, timewheelInterval time.Duration, ...) (*HaRpcClient, error)

+ func (c *HaRpcClient) Close()

+ func (c *HaRpcClient) SendRpcRequestWithTimeout(timeout time.Duration, rpcInvocation *RpcInvocation, ...) (*RpcDataPackage, error)

type RPCRequestStatus

+ func (r *RPCRequestStatus) Stop()

type Request

+ ParentSpanId *int64

+ RpcRequestMetaExt []*RpcRequestMetaExtField

+ SpanId *int64

+ TraceId *int64

type RpcClient

+ func NewRpcCientWithTimeWheelSetting(connection Connection, timewheelInterval time.Duration, timewheelSlot uint16) (*RpcClient, error)

+ func (c *RpcClient) Close()

+ func (c *RpcClient) SendRpcRequestAsyc(rpcInvocation *RpcInvocation, responseMessage proto.Message) <-chan *RpcResult

+ func (c *RpcClient) SendRpcRequestWithTimeout(timeout time.Duration, rpcInvocation *RpcInvocation, ...) (*RpcDataPackage, error)

type RpcDataPackage

+ func (r *RpcDataPackage) Chunk(chunkSize int) []*RpcDataPackage

+ func (r *RpcDataPackage) ClearChunkStatus()

+ func (r *RpcDataPackage) GetChunkStreamId() int64

+ func (r *RpcDataPackage) GetParentSpanId() *int64

+ func (r *RpcDataPackage) GetRpcRequestMetaExt() map[string]string

+ func (r *RpcDataPackage) GetSpanId() *int64

+ func (r *RpcDataPackage) GetTraceId() *int64

+ func (r *RpcDataPackage) IsChunkPackage() bool

+ func (r *RpcDataPackage) IsFinalPackage() bool

+ func (r *RpcDataPackage) ParentSpanId(parentSpanId int64) *RpcDataPackage

+ func (r *RpcDataPackage) RpcRequestMetaExt(ext map[string]string) *RpcDataPackage

+ func (r *RpcDataPackage) SpanId(spanId int64) *RpcDataPackage

+ func (r *RpcDataPackage) TraceId(traceId int64) *RpcDataPackage

type RpcDataPackageProtocol

+ func NewRpcDataPackageProtocol() (*RpcDataPackageProtocol, error)

+ func (r *RpcDataPackageProtocol) Stop()

type RpcInvocation

+ AuthenticateData []byte

+ ChunkSize uint32

+ ParentSpanId int64

+ RpcRequestMetaExt map[string]string

+ SpanId int64

+ TraceId int64

+ type RpcRequestMetaExtField struct

+ Key string

+ Value string

+ func (*RpcRequestMetaExtField) ProtoMessage()

+ func (m *RpcRequestMetaExtField) GetKey() string

+ func (m *RpcRequestMetaExtField) GetValue() string

+ func (m *RpcRequestMetaExtField) Reset()

+ func (m *RpcRequestMetaExtField) String() string

+ type RpcResult struct

+ func (rr *RpcResult) Get() proto.Message

+ func (rr *RpcResult) GetErr() error

+ func (rr *RpcResult) GetRpcDataPackage() *RpcDataPackage

type ServerMeta

+ ChunkSize uint32

+ IdleTimeoutSeconds *int

+ TimeoutSeconds uint32

type TCPConnection

+ func (c *TCPConnection) Receive() (*RpcDataPackage, error)

+ func (c *TCPConnection) Send(rpcDataPackage *RpcDataPackage) error

type TCPConnectionPool

+ func (c *TCPConnectionPool) Receive() (*RpcDataPackage, error)

+ func (c *TCPConnectionPool) Send(rpcDataPackage *RpcDataPackage) error

type TcpServer

+ func (s *TcpServer) SetAuthService(authservice AuthService)

+ func (s *TcpServer) SetTraceService(traceService TraceService)

+ type TraceInfo struct

+ ParentSpanId *int64

+ RpcRequestMetaExt map[string]string

+ SpanId *int64

+ TraceId *int64

+ type TraceService interface

+ Trace func(service, name string, traceInfo *TraceInfo) *TraceInfo

v1.1.0

Aug 5, 2021

v1.0.14

Aug 4, 2021

v1.0.13

Aug 3, 2021

v1.0.12

Jul 29, 2021

Changes in this version

+ type PbFieldMeta struct

+ HasSub bool

+ Name string

+ Opt string

+ SubFieldMeta []*PbFieldMeta

+ Tag int

+ Type string

+ Version string

type RPCMethod

+ InTypeMeta string

+ ReturnTypeMeta string

v1.0.11

Jul 27, 2021

Changes in this version

+ const RPC_STATUS_SERVICENAME

+ const Reqeust_QPS_Expire

+ type HttpStatusView struct

+ func (hsv *HttpStatusView) QpsDataStatus(c context.Context, method *RPCMethod) (*QpsData, context.Context)

+ func (hsv *HttpStatusView) Status(c context.Context) (*RPCStatus, context.Context)

+ type QpsData struct

+ Qpsinfo map[int64]int32

+ func (*QpsData) ProtoMessage()

+ func (m *QpsData) Reset()

+ func (m *QpsData) String() string

+ type RPCMethod struct

+ Method string

+ Service string

+ func (*RPCMethod) ProtoMessage()

+ func (m *RPCMethod) Reset()

+ func (m *RPCMethod) String() string

+ type RPCMethodReuqestStatus struct

+ QpsStatus map[int64]int32

+ type RPCRequestStatus struct

+ Methods map[string]*RPCMethodReuqestStatus

+ func NewRPCRequestStatus(services map[string]Service) *RPCRequestStatus

+ func (r *RPCRequestStatus) Close()

+ func (r *RPCRequestStatus) RequestIn(methodName string, t time.Time, count int) error

+ func (r *RPCRequestStatus) Start() error

+ type RPCStatus struct

+ Host string

+ Methods []*RPCMethod

+ Port int32

+ TimeoutSenconds int32

+ func (*RPCStatus) ProtoMessage()

+ func (m *RPCStatus) Reset()

+ func (m *RPCStatus) String() string

type ServerMeta

+ QPSExpireInSecs int

v1.0.10

Jul 24, 2021

v1.0.9

Jul 24, 2021

v1.0.8

Jul 23, 2021

Changes in this version

type TcpServer

+ func (s *TcpServer) StartServer(l net.Listener) error

v1.0.7

Jul 23, 2021

v1.0.6

Jul 23, 2021

Changes in this version

+ type ErrorContext struct

v1.0.5

Jul 23, 2021

Changes in this version

+ const COMPRESS_GZIP

+ const COMPRESS_NO

+ const COMPRESS_SNAPPY

+ const KT_LOGID

+ const MAGIC_CODE

+ const REQUIRED_TYPE

+ const SIZE

+ const ST_ERROR

+ const ST_SERVICE_NOTFOUND

+ const ST_SUCCESS

+ var DEAFULT_IDLE_TIME_OUT_SECONDS = 10

+ var ERR_DESTORY_OBJECT_NIL = errors.New("[connpool-003]Destroy object failed due to target object is nil.")

+ var ERR_GET_CONN_FAIL = errors.New(...)

+ var ERR_IGNORE_ERR = errors.New("[marshal-001]Ingore error")

+ var ERR_INVALID_PORT = errors.New("[server-002]port of server is nil or invalid")

+ var ERR_INVALID_TYPE = errors.New("[codec-001]type mismatch, target type should be 'baidurpc.RpcDataPackage'")

+ var ERR_INVALID_URL = errors.New("[conn-002]parameter 'url' of host property is nil")

+ var ERR_META = errors.New("[marshal-003]Get nil value from Meta struct after marshal")

+ var ERR_NEED_INIT = errors.New(...)

+ var ERR_NO_SNAPPY = errors.New("[marshal-002]Snappy compress not support yet")

+ var ERR_POOL_NOT_INIT = errors.New("[connpool-001]Object pool is nil maybe not init Connect() function.")

+ var ERR_POOL_URL_NIL = errors.New("[connpool-004]Can not create object cause of URL is nil.")

+ var ERR_RESPONSE_NIL = errors.New("[client-003]No response result, mybe net work break error")

+ var ERR_RESPONSE_TO_CLIENT = errors.New("[server-003]response call session.Send to client failed")

+ var ERR_SERVER_NOT_INIT = errors.New("[server-001]serverMeta is nil. please use NewTpcServer() to create TcpServer")

+ var ERR_SESSION_IS_NIL = errors.New("[conn-001]Session is nil, maybe not init Connect() function")

+ var Empty_Head = make([]byte, SIZE)

+ var HB_METHOD_NAME = "__beat"

+ var HB_SERVICE_NAME = "__heartbeat"

+ var LOG_CLIENT_TIMECOUST_INFO = "[client-101]Server name '%s' method '%s' process cost '%.5g' seconds"

+ var LOG_CLOSE_CONNECT_INFO = "[codec-100]Do close connection. connection info:%v"

+ var LOG_INTERNAL_ERROR = "[server-" + strconv.Itoa(ST_ERROR) + "] unknown internal error:'%s'"

+ var LOG_INVALID_BYTES = "[marshal-004]Invalid byte array. maybe a broken byte stream. Received '%b'"

+ var LOG_INVALID_PORT = "[conn-003]invalid parameter 'url' of port property is '%d'"

+ var LOG_SERVER_REPONSE_ERROR = "[client-002]Server response error. code=%d, msg='%s'"

+ var LOG_SERVER_STARTED_INFO = "[server-100]Server started on '%s' of port '%d'"

+ var LOG_SERVICE_DUPLICATE = "[server-004]Service name '%s' or method name '%s' already exist"

+ var LOG_SERVICE_NOTFOUND = "[server-" + strconv.Itoa(ST_SERVICE_NOTFOUND) + "]Service name '%s' or method name '%s' not found"

+ var LOG_TIMECOUST_INFO = "[server-101]Server name '%s' method '%s' process cost '%.5g' seconds"

+ var LOG_TIMECOUST_INFO2 = "[server-102]Server name '%s' method '%s' process cost '%.5g' seconds.(without net cost) "

+ var MessageType = reflect.TypeOf(m)

+ var NANO_IN_SECONDS = 1000000000.0

+ func Attachement(context context.Context) []byte

+ func BindAttachement(c context.Context, attachement interface{}) context.Context

+ func BindError(c context.Context, err error) context.Context

+ func CloseBatchConnection(connections []Connection)

+ func EnableGLog(enabled bool)

+ func Error(args ...interface{})

+ func Errorf(format string, args ...interface{})

+ func Errors(c context.Context) error

+ func GUNZIP(b []byte) ([]byte, error)

+ func GZIP(b []byte) ([]byte, error)

+ func GetServiceId(serviceName, methodName string) string

+ func Info(args ...interface{})

+ func Infof(format string, args ...interface{})

+ func TimetookInSeconds(currentNano int64) float64

+ func Warning(args ...interface{})

+ func Warningf(format string, args ...interface{})

+ type ChunkInfo struct

+ ChunkId *int64

+ StreamId *int64

+ XXX_unrecognized []byte

+ func (*ChunkInfo) Descriptor() ([]byte, []int)

+ func (*ChunkInfo) ProtoMessage()

+ func (m *ChunkInfo) GetChunkId() int64

+ func (m *ChunkInfo) GetStreamId() int64

+ func (m *ChunkInfo) Reset()

+ func (m *ChunkInfo) String() string

+ type Connection interface

+ Close func() error

+ SendReceive func(rpcDataPackage *RpcDataPackage) (*RpcDataPackage, error)

+ func NewBatchTCPConnection(urls []URL, timeout time.Duration) ([]Connection, error)

+ type ConnectionPoolFactory struct

+ func (c *ConnectionPoolFactory) ActivateObject(ctx context.Context, object *pool.PooledObject) error

+ func (c *ConnectionPoolFactory) DestroyObject(ctx context.Context, object *pool.PooledObject) error

+ func (c *ConnectionPoolFactory) MakeObject(ctx context.Context) (*pool.PooledObject, error)

+ func (c *ConnectionPoolFactory) PassivateObject(ctx context.Context, object *pool.PooledObject) error

+ func (c *ConnectionPoolFactory) ValidateObject(ctx context.Context, object *pool.PooledObject) bool

+ type ConnectionTester interface

+ TestConnection func() error

+ type DefaultService struct

+ func (s *DefaultService) DoService(message proto.Message, attachment []byte, logId *int64) (proto.Message, []byte, error)

+ func (s *DefaultService) GetMethodName() string

+ func (s *DefaultService) GetServiceName() string

+ func (s *DefaultService) NewParameter() proto.Message

+ type HaRpcClient struct

+ func NewHaRpcCient(connections []Connection) (*HaRpcClient, error)

+ func (c *HaRpcClient) SendRpcRequest(rpcInvocation *RpcInvocation, responseMessage proto.Message) (*RpcDataPackage, error)

+ type Header struct

+ MagicCode []byte

+ MessageSize int32

+ MetaSize int32

+ func EmptyHead() *Header

+ func (h *Header) GetMagicCode() []byte

+ func (h *Header) GetMessageSize() int32

+ func (h *Header) GetMetaSize() int32

+ func (h *Header) Read(bytes []byte) error

+ func (h *Header) SetMagicCode(MagicCode []byte)

+ func (h *Header) SetMessageSize(MessageSize int32)

+ func (h *Header) SetMetaSize(MetaSize int32)

+ func (h *Header) Write() ([]byte, error)

+ type RPCFN func(msg proto.Message, attachment []byte, logId *int64) (proto.Message, []byte, error)

+ type Readable interface

+ Read func(bytes []byte) error

+ type Request struct

+ ExtraParam []byte

+ LogId *int64

+ MethodName *string

+ ServiceName *string

+ XXX_unrecognized []byte

+ func (*Request) Descriptor() ([]byte, []int)

+ func (*Request) ProtoMessage()

+ func (m *Request) GetExtraParam() []byte

+ func (m *Request) GetLogId() int64

+ func (m *Request) GetMethodName() string

+ func (m *Request) GetServiceName() string

+ func (m *Request) Reset()

+ func (m *Request) String() string

+ type Response struct

+ ErrorCode *int32

+ ErrorText *string

+ XXX_unrecognized []byte

+ func (*Response) Descriptor() ([]byte, []int)

+ func (*Response) ProtoMessage()

+ func (m *Response) GetErrorCode() int32

+ func (m *Response) GetErrorText() string

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ type RpcClient struct

+ Session Connection

+ func NewRpcCient(connection Connection) (*RpcClient, error)

+ func (c *RpcClient) SendRpcRequest(rpcInvocation *RpcInvocation, responseMessage proto.Message) (*RpcDataPackage, error)

+ type RpcDataPackage struct

+ Attachment []byte

+ Data []byte

+ Head *Header

+ Meta *RpcMeta

+ func NewRpcDataPackage() *RpcDataPackage

+ func (r *RpcDataPackage) AuthenticationData(authenticationData []byte) *RpcDataPackage

+ func (r *RpcDataPackage) ChunkInfo(streamId int64, chunkId int64) *RpcDataPackage

+ func (r *RpcDataPackage) CompressType(compressType int32) *RpcDataPackage

+ func (r *RpcDataPackage) CorrelationId(correlationId int64) *RpcDataPackage

+ func (r *RpcDataPackage) ErrorCode(errorCode int32) *RpcDataPackage

+ func (r *RpcDataPackage) ErrorText(errorText string) *RpcDataPackage

+ func (r *RpcDataPackage) ExtraParams(extraParams []byte) *RpcDataPackage

+ func (r *RpcDataPackage) GetAttachment() []byte

+ func (r *RpcDataPackage) GetData() []byte

+ func (r *RpcDataPackage) GetHead() *Header

+ func (r *RpcDataPackage) GetLogId() int64

+ func (r *RpcDataPackage) GetMagicCode() string

+ func (r *RpcDataPackage) GetMeta() *RpcMeta

+ func (r *RpcDataPackage) LogId(logId int64) *RpcDataPackage

+ func (r *RpcDataPackage) MagicCode(magicCode string)

+ func (r *RpcDataPackage) MethodName(methodName string) *RpcDataPackage

+ func (r *RpcDataPackage) Read(b []byte) error

+ func (r *RpcDataPackage) ReadIO(rw io.Reader) error

+ func (r *RpcDataPackage) ServiceName(serviceName string) *RpcDataPackage

+ func (r *RpcDataPackage) SetAttachment(Attachment []byte) *RpcDataPackage

+ func (r *RpcDataPackage) SetData(Data []byte) *RpcDataPackage

+ func (r *RpcDataPackage) Write() ([]byte, error)

+ func (r *RpcDataPackage) WriteIO(rw io.Writer) error

+ type RpcDataPackageCodec struct

+ func (r *RpcDataPackageCodec) Close() error

+ func (r *RpcDataPackageCodec) Receive() (interface{}, error)

+ func (r *RpcDataPackageCodec) Send(msg interface{}) error

+ func (r *RpcDataPackageCodec) SetTimeout(timeout *time.Duration)

+ type RpcDataPackageProtocol struct

+ func (r *RpcDataPackageProtocol) NewCodec(rw io.ReadWriter) (link.Codec, error)

+ type RpcInvocation struct

+ Attachment []byte

+ CompressType *int32

+ LogId *int64

+ MethodName *string

+ ParameterIn *proto.Message

+ ServiceName *string

+ func NewRpcInvocation(serviceName, methodName *string) *RpcInvocation

+ func (r *RpcInvocation) GetRequestRpcDataPackage() (*RpcDataPackage, error)

+ func (r *RpcInvocation) SetParameterIn(parameterIn proto.Message)

+ type RpcMeta struct

+ AttachmentSize *int32

+ AuthenticationData []byte

+ ChunkInfo *ChunkInfo

+ CompressType *int32

+ CorrelationId *int64

+ Request *Request

+ Response *Response

+ XXX_unrecognized []byte

+ func (*RpcMeta) Descriptor() ([]byte, []int)

+ func (*RpcMeta) ProtoMessage()

+ func (m *RpcMeta) GetAttachmentSize() int32

+ func (m *RpcMeta) GetAuthenticationData() []byte

+ func (m *RpcMeta) GetChunkInfo() *ChunkInfo

+ func (m *RpcMeta) GetCompressType() int32

+ func (m *RpcMeta) GetCorrelationId() int64

+ func (m *RpcMeta) GetRequest() *Request

+ func (m *RpcMeta) GetResponse() *Response

+ func (m *RpcMeta) Reset()

+ func (m *RpcMeta) String() string

+ type Server interface

+ Register func(service *Service) (bool, error)

+ Start func() error

+ Stop func() error

+ type ServerMeta struct

+ Host *string

+ IdleTimeoutSenconds *int

+ Port *int

+ type Service interface

+ DoService func(message proto.Message, attachment []byte, logId *int64) (proto.Message, []byte, error)

+ GetMethodName func() string

+ GetServiceName func() string

+ NewParameter func() proto.Message

+ type TCPConnection struct

+ func NewTCPConnection(url URL, timeout *time.Duration) (*TCPConnection, error)

+ func (c *TCPConnection) Close() error

+ func (c *TCPConnection) GetId() uint64

+ func (c *TCPConnection) SendReceive(rpcDataPackage *RpcDataPackage) (*RpcDataPackage, error)

+ func (c *TCPConnection) TestConnection() error

+ type TCPConnectionPool struct

+ Config *pool.ObjectPoolConfig

+ func NewDefaultTCPConnectionPool(url URL, timeout *time.Duration) (*TCPConnectionPool, error)

+ func NewTCPConnectionPool(url URL, timeout *time.Duration, config *pool.ObjectPoolConfig) (*TCPConnectionPool, error)

+ func (c *TCPConnectionPool) Close() error

+ func (c *TCPConnectionPool) GetNumActive() int

+ func (c *TCPConnectionPool) SendReceive(rpcDataPackage *RpcDataPackage) (*RpcDataPackage, error)

+ type TcpServer struct

+ func NewTpcServer(serverMeta *ServerMeta) *TcpServer

+ func (s *TcpServer) Register(service interface{}) (bool, error)

+ func (s *TcpServer) RegisterName(name string, rcvr interface{}) (bool, error)

+ func (s *TcpServer) RegisterNameWithMethodMapping(name string, rcvr interface{}, mapping map[string]string) (bool, error)

+ func (s *TcpServer) RegisterRpc(sname, mname string, callback RPCFN, inType proto.Message) (bool, error)

+ func (s *TcpServer) Start() error

+ func (s *TcpServer) StartAndBlock() error

+ func (s *TcpServer) Stop() error

+ type URL struct

+ Host *string

+ Port *int

+ func (u *URL) SetHost(host *string) *URL

+ func (u *URL) SetPort(port *int) *URL

+ type Writable interface

+ Write func() ([]byte, error)

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