Method AddMember

internal/testcluster/testcluster.go:121–172

(e *environment.Environment)

}

func (t *TestCluster) AddMember(e *environment.Environment) service.Service {
	t.mu.Lock()
	defer t.mu.Unlock()

	if e == nil {
		e = NewEnvironment(nil)
	}
	c := e.Get("config").(*config.Config)
	partitions.SetHashFunc(c.Hasher)

	port, err := testutil.GetFreePort()
	if err != nil {
		panic(fmt.Sprintf("failed to a random port: %v", err))
	}
	c.MemberlistConfig.BindPort = port

	var peers []string
	for _, peerPort := range t.memberPorts {
		peers = append(peers, net.JoinHostPort("127.0.0.1", strconv.Itoa(peerPort)))
	}
	c.Peers = peers

	s := t.newService(e)
	rt := e.Get("routingtable").(*routingtable.RoutingTable)
	err = rt.Join()
	if err != nil {
		panic(fmt.Sprintf("failed to join the Olric cluster: %v", err))
	}
	err = rt.Start()
	if err != nil {
		panic(fmt.Sprintf("failed to start the routing table: %v", err))
	}

	t.errGr.Go(func() error {
		<-t.ctx.Done()
		return rt.Shutdown(context.Background())
	})

	t.errGr.Go(func() error {
		return s.Start()
	})

	t.errGr.Go(func() error {
		<-t.ctx.Done()
		return s.Shutdown(context.Background())
	})

	t.environments = append(t.environments, e)
	t.memberPorts = append(t.memberPorts, port)
	t.syncCluster()
	return s
}

func (t *TestCluster) Shutdown() {
	t.cancel()