Method mergeBytesValueForKey

kv/memberlist/memberlist_client.go:1721–1738

(key string, incomingData []byte, codec codec.Codec, deleted bool, updateTime time.Time)

}

func (m *KV) mergeBytesValueForKey(key string, incomingData []byte, codec codec.Codec, deleted bool, updateTime time.Time) (Mergeable, uint, bool, time.Time, error) {
	// Even if there is no change to the Mergeable, we still may need to update the timestamp and deleted state.
	if len(incomingData) == 0 {
		incomingData = emptySnappyEncodedData
	}
	decodedValue, err := codec.Decode(incomingData)
	if err != nil {
		return nil, 0, false, time.Time{}, fmt.Errorf("failed to decode value: %v", err)
	}

	incomingValue, ok := decodedValue.(Mergeable)
	if !ok {
		return nil, 0, false, time.Time{}, fmt.Errorf("expected Mergeable, got: %T", decodedValue)
	}

	// No need to clone this "incomingValue", since we have just decoded it from bytes, and won't be using it.
	return m.mergeValueForKey(key, incomingValue, false, 0, codec.CodecID(), deleted, updateTime)
}

// Merges incoming value with value we have in our store. Returns "a change" that can be sent to other
// cluster members to update their state, and new version of the value.