Function casWithErr

kv/memberlist/memberlist_client_test.go:233–249

(ctx context.Context, kv *Client, key string, updateFn func(*data) (*data, bool, error))

}

func casWithErr(ctx context.Context, kv *Client, key string, updateFn func(*data) (*data, bool, error)) error {
	fn := func(in interface{}) (out interface{}, retry bool, err error) {
		var r *data
		if in != nil {
			r = in.(*data)
		}

		d, rt, e := updateFn(r)
		if d == nil {
			// translate nil pointer to nil interface value
			return nil, rt, e
		}
		return d, rt, e
	}

	return kv.CAS(ctx, key, fn)
}

func getLocalhostAddr() string {
	return getLocalhostAddrs()[0]