Method SetNetConn

export_test.go:18–20

(netConn net.Conn)

}

func (c *PubSub) SetNetConn(netConn net.Conn) {
	c.cn = pool.NewConn(netConn)
}

func (c *ClusterClient) LoadState(ctx context.Context) (*clusterState, error) {
	// return c.state.Reload(ctx)