IsASelectMode returns "true" if the value is listed in the enum definition. "false" otherwise

IsNotify returns true if this request is a notification.

JumpConsistentHash selects a server by serviceMethod and args

Log reports metrics into logs. p.Log( 5 * time.Second, log.New(os.Stderr, "metrics: ", log.Lmicroseconds))

Metadata returns the metadata.

MuxMatch adds cmux Match.

NewAliasPlugin creates a new NewAliasPlugin

NewBidirectionalOneClientPool creates a BidirectionalOneClient pool with fixed size.

NewBidirectionalXClientPool creates a BidirectionalXClient pool with fixed size.

NewClient returns a new Client with the option.

NewFileTransfer creates a FileTransfer with given parameters.

NewMDNSRegisterPlugin return a new MDNSRegisterPlugin. If domain is empty, use "local." in default.

NewMetricsPlugin creates a new MetricsPlugin

NewRateLimitingPlugin creates a new RateLimitingPlugin

NewRedisRateLimitingPlugin creates a new RateLimitingPlugin

NewRedisRateLimitingPlugin creates a new RateLimitingPlugin

NewReqRateLimitingPlugin creates a new RateLimitingPlugin

NewServiceError creates a ServiceError with the error message.

NewStreamService creates a stream service.

Oneshot invokes the named function, ** DOEST NOT ** wait for it to complete, and returns immediately.

ParseRpcxAddress parses rpcx address such as tcp@127.0.0.1:8972 quic@192.168.1.1:9981

Payload returns the payload.

PostReadRequest can limit request processing.

PostReadRequest converts the alias of this service.

PostReadRequest can limit request processing.

PostReadRequest counts read

PostWriteResponse count write

PreCall can limit request processing.

PreCall handles rpc call from clients

PreCall handles rpc call from clients

PreReadRequest marks start time of calling service

PreWriteResponse restore servicePath and serviceMethod.

Register handles registering event. this service is registered at BASE/serviceName/thisIpAddress node

Register handles registering event.

RegisterFunction publishes a function that satisfy the following conditions: - three arguments, the first is of context.Context, both of exported type

RegisterFunctionName is like RegisterFunction but uses the provided name for the function instead of the function's concrete type.

RegisterMakeListener registers a MakeListener for network.

RegisterOnRestart registers a function to call on Restart.

RegisterServerMessageChan registers the channel that receives server requests.

RemoteAddr returns the remote address.

Remove removes a plugin by its name.

Remove removes a plugin by it's name.

Reset clean data of this message but keep allocated data

Restart restarts this server gracefully. It starts a new rpcx server with the same port with SO_REUSEPORT socket option, and shutdown this rpcx server