pjsip_outbound_registrations.c File Reference

Prometheus PJSIP Outbound Registration Metrics. More...

#include "asterisk.h"
#include "asterisk/stasis_message_router.h"
#include "asterisk/stasis_system.h"
#include "asterisk/res_prometheus.h"
#include "prometheus_internal.h"

Include dependency graph for pjsip_outbound_registrations.c:

Go to the source code of this file.

Functions
int	pjsip_outbound_registration_metrics_init (void)
	Initialize PJSIP outbound registration metrics. More...
static void	pjsip_outbound_registration_metrics_unload_cb (void)

Variables
static struct prometheus_metrics_provider	provider

Detailed Description

Prometheus PJSIP Outbound Registration Metrics.

Author

Matt Jordan mjord.nosp@m.an@d.nosp@m.igium.nosp@m..com

Definition in file pjsip_outbound_registrations.c.

Function Documentation

pjsip_outbound_registration_metrics_init()

int pjsip_outbound_registration_metrics_init

(

void

)

Initialize PJSIP outbound registration metrics.

Return values

0	success
-1	error

Definition at line 342 of file pjsip_outbound_registrations.c.

{
    prometheus_metrics_provider_register(&provider);
 
#ifdef HAVE_PJPROJECT
    router = stasis_message_router_create(ast_system_topic());
    if (!router) {
        goto cleanup;
    }
 
    if (stasis_message_router_add(router, ast_system_registry_type(), registry_message_cb, NULL)) {
        goto cleanup;
    }
 
    if (ast_sorcery_instance_observer_add(ast_sip_get_sorcery(), &observer_callbacks_registrations)) {
        goto cleanup;
    }
 
    if (ast_sorcery_observer_add(ast_sip_get_sorcery(), "registration", &registration_observer)) {
        goto cleanup;
    }
#endif /* HAVE_PJPROJECT */
    return 0;
 
#ifdef HAVE_PJPROJECT
cleanup:
    ao2_cleanup(router);
    router = NULL;
    ast_sorcery_instance_observer_remove(ast_sip_get_sorcery(), &observer_callbacks_registrations);
    ast_sorcery_observer_remove(ast_sip_get_sorcery(), "registration", &registration_observer);
 
    return -1;
#endif /* HAVE_PJPROJECT */
}

References ao2_cleanup, ast_sip_get_sorcery(), ast_sorcery_instance_observer_add(), ast_sorcery_instance_observer_remove(), ast_sorcery_observer_add(), ast_sorcery_observer_remove(), ast_system_registry_type(), ast_system_topic(), cleanup(), NULL, observer_callbacks_registrations, prometheus_metrics_provider_register(), provider, registration_observer, router, stasis_message_router_add(), and stasis_message_router_create.

Referenced by load_module().

pjsip_outbound_registration_metrics_unload_cb()

static void pjsip_outbound_registration_metrics_unload_cb ( void  )

static

Definition at line 323 of file pjsip_outbound_registrations.c.

{
#ifdef HAVE_PJPROJECT
    stasis_message_router_unsubscribe_and_join(router);
    router = NULL;
    ast_sorcery_instance_observer_remove(ast_sip_get_sorcery(), &observer_callbacks_registrations);
    ast_sorcery_observer_remove(ast_sip_get_sorcery(), "registration", &registration_observer);
#endif /* HAVE_PJPROJECT */
}

References ast_sip_get_sorcery(), ast_sorcery_instance_observer_remove(), ast_sorcery_observer_remove(), NULL, observer_callbacks_registrations, registration_observer, router, and stasis_message_router_unsubscribe_and_join().

Variable Documentation

provider

struct prometheus_metrics_provider provider

static

Initial value:

= {
    .name = "pjsip_outbound_registration",
    .unload_cb = pjsip_outbound_registration_metrics_unload_cb,
}

Definition at line 337 of file pjsip_outbound_registrations.c.

Referenced by pjsip_outbound_registration_metrics_init().