cluster

func Query ¶

func Query(node string) *client.Client

Query query a registed node in cluster

Returns a *client.Client

func Register ¶

func Register(node string, address string, opts ...client.Option) (*client.Client, error)

Register register skynet cluster node default withArgsCodec(json) and Timeout(5*second)

Examples:

Register("node1", "192.0.2.1:6789", client.WithArgsCodec(&client.ArgsCodecJson{})

If you want to reload node address to port:6790, old client will close after 30s Register("node1", "192.0.2.1:6790")

func ReloadCluster ¶

func ReloadCluster(nodes map[string]string, opts ...client.Option) map[string]error

ReloadCluster register multi skynet cluster node

Default withArgsCodec(json) and Timeout(5*second)

# It's safely to Reload multi times with same config # If client connecting. It will closed after 30s

Examples:

ReloadCluster("node1", map[string]string{"node":"127.0.0.1:8080"}, client.WithArgsCodec(&client.ArgsCodecJson{})

Returns register fail nodesErr

func Remove ¶

func Remove(node string)

Remove remove cluster registed node

Client connecting will break afeter 30s