Documentation ¶
Index ¶
- type Client
- 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{}, ...)
- 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
- type ClientOptionFunc
- type ClientProxy
- type ClientSelectMode
- type Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) WithHashKey ¶
type ClientOption ¶
type ClientOption struct { SelectMode ClientSelectMode GroupName string }
type ClientOptionFunc ¶
type ClientOptionFunc func(*ClientOption)
func ClientWithGroupName ¶
func ClientWithGroupName(groupName string) ClientOptionFunc
func ClientWithSelectMode ¶
func ClientWithSelectMode(selectMode ClientSelectMode) ClientOptionFunc
type ClientProxy ¶
type ClientProxy struct {
// contains filtered or unexported fields
}
func NewClientProxy ¶
func NewClientProxy(discovery proxy.Discovery, groupName string) *ClientProxy
func (*ClientProxy) Close ¶
func (cp *ClientProxy) Close()
func (*ClientProxy) GetClient ¶
func (cp *ClientProxy) GetClient(ctx context.Context, name string, serviceName string, selectMode ClientSelectMode) (*Client, error)
type ClientSelectMode ¶
type ClientSelectMode uint8
const ( ClientSelectModeRoundRobin ClientSelectMode = iota ClientSelectModeHash ClientSelectModeSoftState )
Click to show internal directories.
Click to hide internal directories.