Method updateRing

ring/partition_instance_lifecycler.go:255–267

(ctx context.Context, update func(ring *PartitionRingDesc) (bool, error))

}

func (l *PartitionInstanceLifecycler) updateRing(ctx context.Context, update func(ring *PartitionRingDesc) (bool, error)) error {
	return l.store.CAS(ctx, l.ringKey, func(in interface{}) (out interface{}, retry bool, err error) {
		ringDesc := GetOrCreatePartitionRingDesc(in)

		if changed, err := update(ringDesc); err != nil {
			return nil, false, err
		} else if !changed {
			return nil, false, nil
		}

		return ringDesc, true, nil
	})
}

// partitionOwnerID returns the instance ID used to register the owner in the ring.
func (l *PartitionInstanceLifecycler) partitionOwnerID() string {