xrpc

package

v0.0.0-...-2b30333 Latest Latest Go to latest Published: Dec 8, 2016 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrRpc        = errors.New("rpc is not available")
	ErrRpcTimeout = errors.New("rpc call timeout")
)

View Source

var (
	ErrNoClient = errors.New("rpc is not available")
)

This section is empty.

type Client struct {
	*rpc.Client
	// contains filtered or unexported fields
}

Client is rpc client.

func Dial(options ClientOptions) (c *Client)

Dial connects to an RPC server at the specified network address.

func (c *Client) Call(serviceMethod string, args interface{}, reply interface{}) (err error)

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

func (c *Client) Close()

Close client connection.

func (c *Client) Error() error

Return client error.

func (c *Client) Ping(serviceMethod string)

ping ping the rpc connect and reconnect when has an error.

type ClientOptions struct {
	Proto string
	Addr  string
}

Rpc client options.

type Clients struct {
	// contains filtered or unexported fields
}

func Dials(options []ClientOptions) *Clients

Dials connects to RPC servers at the specified network address.

func (c *Clients) Available() (err error)

has a available client.

func (c *Clients) Call(serviceMethod string, args interface{}, reply interface{}) (err error)

Call invokes the named function, waits for it to complete, and returns its error status. this include rpc.Client.Call method, and takes a timeout.

func (c *Clients) Ping(serviceMethod string)

Ping the rpc connect and reconnect when has an error.