integration: move cap enabling to init
parent
2d47211589
commit
ac2859057a
|
@ -85,6 +85,11 @@ type cluster struct {
|
||||||
Members []*member
|
Members []*member
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
// manually enable v3 capability since we know the cluster members all support v3.
|
||||||
|
api.EnableCapability(api.V3rpcCapability)
|
||||||
|
}
|
||||||
|
|
||||||
func (c *cluster) fillClusterForMembers() error {
|
func (c *cluster) fillClusterForMembers() error {
|
||||||
if c.cfg.DiscoveryURL != "" {
|
if c.cfg.DiscoveryURL != "" {
|
||||||
// cluster will be discovered
|
// cluster will be discovered
|
||||||
|
@ -761,9 +766,6 @@ func NewClusterV3(t *testing.T, cfg *ClusterConfig) *ClusterV3 {
|
||||||
}
|
}
|
||||||
clus.Launch(t)
|
clus.Launch(t)
|
||||||
|
|
||||||
// manually enable v3 capability since we know we are starting a v3 cluster here.
|
|
||||||
api.EnableCapability(api.V3rpcCapability)
|
|
||||||
|
|
||||||
return clus
|
return clus
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue