Method Delete

kv/memberlist/memberlist_client.go:1255–1284

(key string)

}

func (m *KV) Delete(key string) error {
	m.storeMu.Lock()
	val, ok := m.store[key]
	m.storeMu.Unlock()

	if !ok || val.Deleted {
		return nil
	}

	c := m.GetCodec(val.CodecID)
	if c == nil {
		level.Error(m.logger).Log("msg", "could not mark key for deletion due to an invalid codec", "key", key, "codec", val.CodecID)
		return fmt.Errorf("invalid codec: %s", val.CodecID)
	}

	change, newver, deleted, updated, err := m.mergeValueForKey(key, val.value, false, 0, val.CodecID, true, time.Now())
	if err != nil {
		level.Error(m.logger).Log("msg", "could not mark key for deletion due to error while trying to merge new value", "key", key, "err", err)
		return err
	}

	if newver > 0 {
		m.notifyWatchers(key)
		m.broadcastNewValue(key, change, newver, c, false, deleted, updated)
	}

	level.Info(m.logger).Log("msg", "successfully marked key for deletion", "key", key)

	return nil
}

// CAS implements Compare-And-Set/Swap operation.
//