rpc

package

v0.0.0-...-6fdbc3c Latest Latest Go to latest Published: May 23, 2022 License: MIT Imports: 7 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 (
	// ErrResponse is thrown on a connection time out
	ErrResponse = errors.New("no response from server")
)

View Source

var (
	// Services is a list of exported services
	// registered by the RPC server at runtime
	Services = []interface{}{
		Ping{},
	}
)

This section is empty.

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

Client wraps an RPC client

func (c *Client) Close() error

Close an RPC connection

func (c *Client) Init(addr string) (err error)

Init an RPC connection

func (c *Client) Ping(ctx context.Context) (ack bool, err error)

Ping an RPC server

type Ping struct{}

Ping is a basic RPC service for checking the health of a node

func (p Ping) Ping(data []byte, ack *bool) error

Ping an rpc server

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

Server wraps a JSON RPC server

func (s *Server) Close() error

Close an RPC connection

func (s *Server) Init(host string, port uint16) (err error)

Init an RPC server

func (s *Server) Run(ctx context.Context) error

Run the server's main loop