Function newTestOlricCluster

olric_test.go:81–94

(t *testing.T)

}

func newTestOlricCluster(t *testing.T) *testOlricCluster {
	cl := &testOlricCluster{members: make(map[string]*Olric)}
	t.Cleanup(func() {
		cl.mtx.Lock()
		defer cl.mtx.Unlock()
		for _, member := range cl.members {
			ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
			err := member.Shutdown(ctx)
			cancel()
			require.NoError(t, err)
		}
	})
	return cl
}

func (cl *testOlricCluster) addMemberWithConfig(t *testing.T, c *config.Config) *Olric {
	cl.mtx.Lock()