Method casRing

ring/ring.go:1452–1454

(ctx context.Context, f func(in interface{}) (out interface{}, retry bool, err error))

}

func (r *Ring) casRing(ctx context.Context, f func(in interface{}) (out interface{}, retry bool, err error)) error {
	return r.KVClient.CAS(ctx, r.key, f)
}

func (r *Ring) getRing(_ context.Context) (*Desc, error) {
	r.mtx.RLock()