app-lib-dotnet/src/Altinn.App.Core/Features/Telemetry/Telemetry.Processes.cs at 8888c85bab3d16389123c76e9b7c93ca3f8e1c86 · Altinn/app-lib-dotnet · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
using System.Diagnostics;
using Altinn.App.Core.Models;
using Altinn.App.Core.Models.Process;
using Altinn.Platform.Storage.Interface.Models;
using static Altinn.App.Core.Features.Telemetry.Processes;

namespace Altinn.App.Core.Features;

partial class Telemetry
{
    private void InitProcesses(InitContext context)
    {
        InitMetricCounter(context, MetricNameProcessesStarted, static m => m.Add(0));
        InitMetricCounter(context, MetricNameProcessesEnded, static m => m.Add(0));

        InitMetricHistogram(context, MetricNameProcessesDuration);
    }

    internal void ProcessStarted()
    {
        _counters[MetricNameProcessesStarted].Add(1);
    }

    internal void ProcessEnded(ProcessStateChange processChange)
    {
        if (processChange?.NewProcessState?.Started is null || processChange?.NewProcessState?.Ended is null)
        {
            return;
        }
        var state = processChange.NewProcessState;

        _counters[MetricNameProcessesEnded].Add(1);
        var duration = state.Ended.Value - state.Started.Value;
        _histograms[MetricNameProcessesDuration].Record(duration.TotalSeconds);
    }

    internal Activity? StartProcessStartActivity(Instance instance)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.Start");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal Activity? StartProcessStartExecutionActivity(Instance instance)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.StartExecution");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal Activity? StartProcessNextActivity(Instance instance, string? action)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.Next");
        activity?.SetInstanceId(instance);
        activity?.SetTag(InternalLabels.ProcessAction, action);
        return activity;
    }

    internal Activity? StartApiProcessNextActivity(InstanceIdentifier instanceIdentifier)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.ApiNext");
        activity?.SetInstanceId(instanceIdentifier.InstanceGuid);
        return activity;
    }

    internal Activity? StartApiProcessCompleteActivity(InstanceIdentifier instanceIdentifier)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.ApiComplete");
        activity?.SetInstanceId(instanceIdentifier.InstanceGuid);
        return activity;
    }

    internal Activity? StartProcessHandleEventsActivity(Instance instance)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.HandleEvents");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal Activity? StartProcessStoreEventsActivity(Instance instance)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.StoreEvents");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal Activity? StartProcessExecuteServiceTaskActivity(Instance instance, string serviceTaskType)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.ExecuteServiceTask");
        activity?.SetInstanceId(instance);
        activity?.SetTag(InternalLabels.ProcessServiceTaskType, serviceTaskType);
        return activity;
    }

    internal Activity? StartProcessEndActivity(Instance instance)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.End");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal Activity? StartProcessEndHandlersActivity(Instance instance)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.EndHandlers");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal Activity? StartProcessEndHandlerActivity(Instance instance, IProcessEnd handler)
    {
        var activity = ActivitySource.StartActivity($"{Prefix}.EndHandler.{handler.GetType()}");
        activity?.SetInstanceId(instance);
        return activity;
    }

    internal static class Processes
    {
        internal const string Prefix = "Process";

        internal static readonly string MetricNameProcessesStarted = Metrics.CreateLibName("processes_started");
        internal static readonly string MetricNameProcessesEnded = Metrics.CreateLibName("processes_ended");
        internal static readonly string MetricNameProcessesDuration = Metrics.CreateLibName("processes_duration");
    }
}