def k8s_message()

in tsdb/_tools/anonymize.py [0:0]


def k8s_message(message):
    if message in K8S_MESSAGE_PASSTHROUGH:
        return message
    if "Error: secret" in message and "not found" in message:
        return "Error: secret <snip> not found"
    if "Container image " in message and "already present on machine" in message:
        return "Container image <snip> already present on machine"
    if '"unmanaged"' in message:
        return str(uuid.uuid4())
    for trigger, replacement in K8S_MESSAGE_SNIP.items():
        if trigger in message:
            return replacement
    raise ValueError(f"unsupported k8s.event.message [{message}]")