Method GetZeroState

dgraphtest/zero_state.go:47–72

GetZeroState queries the /state endpoint on the specified Zero and returns the parsed membership snapshot.

(id int)

// GetZeroState queries the /state endpoint on the specified Zero and returns
// the parsed membership snapshot.
func (c *LocalCluster) GetZeroState(id int) (*ZeroState, error) {
	stateURL, err := c.GetZeroStateURL(id)
	if err != nil {
		return nil, err
	}

	resp, err := http.Get(stateURL)
	if err != nil {
		return nil, errors.Wrapf(err, "GET %s", stateURL)
	}
	defer func() { _ = resp.Body.Close() }()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, errors.Wrap(err, "reading /state body")
	}
	if resp.StatusCode != http.StatusOK {
		return nil, fmt.Errorf("/state HTTP %d: %s", resp.StatusCode, body)
	}

	var state ZeroState
	if err := json.Unmarshal(body, &state); err != nil {
		return nil, errors.Wrapf(err, "unmarshal /state (body: %s)", string(body))
	}
	return &state, nil
}

// ZeroLocator identifies a Zero by its container index and Raft ID.
type ZeroLocator struct {