rpc

package

v1.0.5 Latest Latest Go to latest Published: Jun 26, 2022 License: MIT Imports: 9 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.

This section is empty.

This section is empty.

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

func NewClient(discovery proxy.Discovery, name string, serviceName string, options ...ClientOptionFunc) (*Client, error)

func (c *Client) Broadcast(ctx context.Context, method string, args interface{}, reply interface{}) error

func (c *Client) Callback(ctx context.Context, method string, args interface{}, reply interface{}, f func(reply interface{}, err error))

func (c *Client) Close() error

func (c *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}) error

func (c *Client) OneWay(ctx context.Context, method string, args interface{}) error

func (c *Client) WithHashKey(ctx context.Context, val string) context.Context

func (c *Client) WithSoftStateKey(ctx context.Context, val string) context.Context

type ClientOption struct {
	SelectMode ClientSelectMode
	GroupName  string
}

type ClientOptionFunc func(*ClientOption)

func ClientWithGroupName(groupName string) ClientOptionFunc

func ClientWithSelectMode(selectMode ClientSelectMode) ClientOptionFunc

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

func NewClientProxy(discovery proxy.Discovery, groupName string) *ClientProxy

func (cp *ClientProxy) Close()

func (cp *ClientProxy) GetClient(ctx context.Context, name string, serviceName string, selectMode ClientSelectMode) (*Client, error)

type ClientSelectMode uint8

const (
	ClientSelectModeRoundRobin ClientSelectMode = iota
	ClientSelectModeHash
	ClientSelectModeSoftState
)

type Server struct {
	Ip     string
	Port   uint16
	Server *server.Server
	// contains filtered or unexported fields
}

func NewServer(ip string, port uint16) *Server

func (s *Server) Addr() (string, uint16)

func (s *Server) Close() error

func (s *Server) Run() error

func (s *Server) SetHandler(handler interface{}) error

Path	Synopsis
selector