Skip to content

Commit

Permalink
feat: Add metrics for conference/endpoint duration. (#1197)
Browse files Browse the repository at this point in the history
  • Loading branch information
bgrozev authored Dec 5, 2024
1 parent dd2d778 commit 880d143
Show file tree
Hide file tree
Showing 3 changed files with 29 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@
import org.jivesoftware.smackx.caps.packet.*;
import org.jxmpp.jid.*;

import java.time.*;
import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.*;
Expand Down Expand Up @@ -253,6 +254,8 @@ public class JitsiMeetConferenceImpl
*/
private boolean visitorsBroadcastEnabled = VisitorsConfig.config.getAutoEnableBroadcast();

@NotNull private final Instant createdInstant = Instant.now();

/**
* The unique meeting ID for this conference. We expect this to be set by the XMPP server in the MUC config form.
* If for some reason it's not present, we'll generate a local UUID. The field is nullable, but always non-null
Expand Down Expand Up @@ -478,6 +481,11 @@ public void stop()
}

logger.info("Stopped.");
if (includeInStatistics())
{
ConferenceMetrics.conferenceSeconds.addAndGet(
Duration.between(createdInstant, Instant.now()).toMillis() / 1000.0);
}
if (listener != null)
{
listener.conferenceEnded(this);
Expand Down Expand Up @@ -1058,6 +1066,10 @@ private void terminateParticipant(
"Removed participant " + participant.getChatMember().getName() + " removed=" + (removed != null));
if (!willReinvite && removed != null)
{
if (includeInStatistics())
{
ConferenceMetrics.endpointSeconds.addAndGet(participant.durationSeconds());
}
if (removed.isUserParticipant())
{
userParticipantRemoved();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,18 @@ class ConferenceMetrics {
"The number of conferences created on this Jicofo since it was started"
)

@JvmField
val conferenceSeconds = metricsContainer.registerDoubleGauge(
"conferences_seconds",
"The duration of completed conferences in seconds."
)

@JvmField
val endpointSeconds = metricsContainer.registerDoubleGauge(
"endpoint_seconds",
"The duration of endpoints in a conferences in seconds."
)

@JvmField
val participants = metricsContainer.registerCounter(
"participants",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,8 +71,12 @@ open class Participant @JvmOverloads constructor(
/** The list of XMPP features supported by this participant. */
val supportedFeatures: Set<Features> = Features.defaultFeatures,
/** The [Clock] used by this participant. */
clock: Clock = Clock.systemUTC()
private val clock: Clock = Clock.systemUTC()
) {
private val createdInstant: Instant = clock.instant()

fun durationSeconds(): Double = Duration.between(createdInstant, clock.instant()).toMillis() / 1000.0

/** The endpoint ID for this participant in the videobridge (Colibri) context. */
val endpointId: String = chatMember.name

Expand Down

0 comments on commit 880d143

Please sign in to comment.