Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var RPC_CLIENT_SIZE = 1
Functions ¶
func SetDialTimeout ¶
func SetDialTimeout(timeout int)
Types ¶
type Client ¶
type Client interface {
Close() error
Call(serviceMethod string, args interface{}, reply interface{}) error
}
func GetCachedClient ¶
GetCachedClient createa or gets a cached Client.
func NewReconnectingClient ¶
NewReconnectingClient creates a client that reuses the same connection and does not close the underlying connection unless an error occurs. If an RPC call results in an RPC error the underlying connection is reset.
Source Files
Click to show internal directories.
Click to hide internal directories.