INNER CODE UNIT · Python

start_event_listeners

ChrispyBacon-dev/DockFlare · dockflare-agent/app/main.py:568

def start_event_listeners(client):
    threads = []
    label_prefixes = ["dockflare.", "cloudflare.tunnel."]
    for index, prefix in enumerate(label_prefixes):
        thread = Thread(target=listen_for_docker_events, args=(client, prefix, index == 0), daemon=True)
        threads.append(thread)
    return threads


def post_decommission_ack(operation_id, payload):
    global last_successful_master_contact
    endpoint = f"{MASTER_URL}/api/v2/agents/{AGENT_ID}/decommission/{operation_id}/ack"
    body = dict(payload)
    body["operation_id"] = operation_id
    if PROTOCOL_VERSION == 2:
        body["agent_session_id"] = AGENT_SESSION_ID
    try:
        response = requests.post(endpoint, json=body, headers=get_headers(), timeout=60)

View source record →