-
Notifications
You must be signed in to change notification settings - Fork 142
/
webapi.go
56 lines (44 loc) · 1.62 KB
/
webapi.go
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
package metrics
import (
"fmt"
"time"
"github.com/iotaledger/wasp/packages/isc"
)
type IWebAPIMetrics interface {
WebAPIRequest(operation string, httpStatusCode int, duration time.Duration)
EvmRPCCall(operation string, success bool, duration time.Duration)
}
var (
_ IWebAPIMetrics = &emptyWebAPIChainMetrics{}
_ IWebAPIMetrics = &webAPIChainMetrics{}
)
type emptyWebAPIChainMetrics struct{}
func NewEmptyWebAPIMetrics() IWebAPIMetrics {
return &emptyWebAPIChainMetrics{}
}
func (m *emptyWebAPIChainMetrics) WebAPIRequest(operation string, httpStatusCode int, duration time.Duration) {
}
func (m *emptyWebAPIChainMetrics) EvmRPCCall(operation string, success bool, duration time.Duration) {
}
type webAPIChainMetrics struct {
provider *ChainMetricsProvider
chainID isc.ChainID
}
func newWebAPIChainMetrics(provider *ChainMetricsProvider, chainID isc.ChainID) *webAPIChainMetrics {
return &webAPIChainMetrics{
provider: provider,
chainID: chainID,
}
}
func (m *webAPIChainMetrics) WebAPIRequest(operation string, httpStatusCode int, duration time.Duration) {
labels := getChainLabels(m.chainID)
labels[labelNameWebapiRequestOperation] = operation
labels[labelNameWebapiRequestStatusCode] = fmt.Sprintf("%d", httpStatusCode)
m.provider.webAPIRequests.With(labels).Observe(duration.Seconds())
}
func (m *webAPIChainMetrics) EvmRPCCall(operation string, success bool, duration time.Duration) {
labels := getChainLabels(m.chainID)
labels[labelNameWebapiRequestOperation] = operation
labels[labelNameWebapiEvmRPCSuccess] = fmt.Sprintf("%v", success)
m.provider.webAPIEvmRPCCalls.With(labels).Observe(duration.Seconds())
}