func Clusterize() error {
	err := resetManager(
		PullFromGlobalManager,
		config.PullFromEndpoints,
		"MGLOBAL",
	)
	if err != nil {
		return err
	}

	err = resetManager(
		PushToManager,
		config.PushToEndpoints,
		"ALISTENTOME",
		config.MyEndpoint.String(),
	)
	if err != nil {
		return err
	}

	return nil
}
// Reads the cluster information from the config and attempts to set it up. If
// this isn't the first time this function has been called it will do a diff and
// open/close whatever connections are needed, and leave the remaining ones
// untouched.
Reads the cluster information from the config and attempts to set it up. If
this isn't the first time this function has been called it will do a diff and
open/close whatever connections are needed, and leave the remaining ones
untouched.
// Reads the cluster information from the config and attempts to set it up . If // this isn ' t the first time this function has been called it will do a diff and // open / close whatever connections are needed and leave the remaining ones // untouched .
func Clusterize() error {
	err := resetManager(
		PullFromGlobalManager,
		config.PullFromEndpoints,
		"MGLOBAL",
	)
	if err != nil {
		return err
	}
	err = resetManager(
		PushToManager,
		config.PushToEndpoints,
		"ALISTENTOME",
		config.MyEndpoint.String(),
	)
	if err != nil {
		return err
	}
	return nil
}
func Clusterize ( ) error { err := resetManager ( PullFromGlobalManager , config . PullFromEndpoints , " " , ) if err != nil { return err } err = resetManager ( PushToManager , config . PushToEndpoints , " " , config . MyEndpoint . String ( ) , ) if err != nil { return err } return nil }
Reads the cluster information from the config and attempts to set it up.
Reads the cluster information from the config and attempts to set it up .