SetMessageType sets message type.

NewMessage creates an empty message.

SerializeType returns serialization type of payload.

CompressType returns compression type of messages.

Serve starts and listens RPC requests. It is blocked until receiving connections from clients.

IsOneway returns whether the message is one-way message. If true, server won't send responses.

RegisterName is like Register but uses the provided name for the type instead of the receiver's concrete type.

String returns the error message.

PutData puts the byte slice into pool.

Seq returns sequence number of messages.

SetCompressType sets the compression type.

NewServer returns a server.

SetSerializeType sets the serialization type.

Encode encodes an object into slice of bytes.

EncodeSlicePointer encodes messages as a byte slice pointer we can use pool to improve.

Get returns a xclient. It does not remove this xclient from its cache so you don't need to put it back. Don't close this xclient because maybe other g

SetOneway sets the oneway flag.

Shutdown gracefully shuts down the server without interrupting any active connections. Shutdown works by first closing the listener, then closing all

SetSeq sets sequence number.

String returns a string representation of the ID. The representation is non ambiguous, string forms are quoted, number forms are preceded by a #

Call invokes the named function, waits for it to complete, and returns its error status.

NewMultipleServersDiscovery returns a new MultipleServersDiscovery.

SetMessageStatusType sets message status type.

selects a client from candidates base on c.selectMode

Address returns listened address.

Close immediately closes all active net.Listeners.

GetPlugins returns client's plugins.

GetPlugins returns client's plugins.

NewXClient creates a XClient that supports service discovery and service governance.

SetHeartbeat sets the heartbeat flag.

Zip zips data.