forked from fnproject/fn
-
Notifications
You must be signed in to change notification settings - Fork 0
/
metrics.go
117 lines (96 loc) · 3.94 KB
/
metrics.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
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
package datastoreutil
import (
"context"
"io"
"github.com/fnproject/fn/api/models"
"github.com/jmoiron/sqlx"
"github.com/opentracing/opentracing-go"
)
func MetricDS(ds models.Datastore) models.Datastore {
return &metricds{ds}
}
type metricds struct {
ds models.Datastore
}
func (m *metricds) GetApp(ctx context.Context, appName string) (*models.App, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_app")
defer span.Finish()
return m.ds.GetApp(ctx, appName)
}
func (m *metricds) GetApps(ctx context.Context, filter *models.AppFilter) ([]*models.App, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_apps")
defer span.Finish()
return m.ds.GetApps(ctx, filter)
}
func (m *metricds) InsertApp(ctx context.Context, app *models.App) (*models.App, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_insert_app")
defer span.Finish()
return m.ds.InsertApp(ctx, app)
}
func (m *metricds) UpdateApp(ctx context.Context, app *models.App) (*models.App, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_update_app")
defer span.Finish()
return m.ds.UpdateApp(ctx, app)
}
func (m *metricds) RemoveApp(ctx context.Context, appName string) error {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_remove_app")
defer span.Finish()
return m.ds.RemoveApp(ctx, appName)
}
func (m *metricds) GetRoute(ctx context.Context, appName, routePath string) (*models.Route, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_route")
defer span.Finish()
return m.ds.GetRoute(ctx, appName, routePath)
}
func (m *metricds) GetRoutesByApp(ctx context.Context, appName string, filter *models.RouteFilter) (routes []*models.Route, err error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_routes_by_app")
defer span.Finish()
return m.ds.GetRoutesByApp(ctx, appName, filter)
}
func (m *metricds) InsertRoute(ctx context.Context, route *models.Route) (*models.Route, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_insert_route")
defer span.Finish()
return m.ds.InsertRoute(ctx, route)
}
func (m *metricds) UpdateRoute(ctx context.Context, route *models.Route) (*models.Route, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_update_route")
defer span.Finish()
return m.ds.UpdateRoute(ctx, route)
}
func (m *metricds) RemoveRoute(ctx context.Context, appName, routePath string) error {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_remove_route")
defer span.Finish()
return m.ds.RemoveRoute(ctx, appName, routePath)
}
func (m *metricds) InsertCall(ctx context.Context, call *models.Call) error {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_insert_call")
defer span.Finish()
return m.ds.InsertCall(ctx, call)
}
func (m *metricds) UpdateCall(ctx context.Context, from *models.Call, to *models.Call) error {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_update_call")
defer span.Finish()
return m.ds.UpdateCall(ctx, from, to)
}
func (m *metricds) GetCall(ctx context.Context, appName, callID string) (*models.Call, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_call")
defer span.Finish()
return m.ds.GetCall(ctx, appName, callID)
}
func (m *metricds) GetCalls(ctx context.Context, filter *models.CallFilter) ([]*models.Call, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_calls")
defer span.Finish()
return m.ds.GetCalls(ctx, filter)
}
func (m *metricds) InsertLog(ctx context.Context, appName, callID string, callLog io.Reader) error {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_insert_log")
defer span.Finish()
return m.ds.InsertLog(ctx, appName, callID, callLog)
}
func (m *metricds) GetLog(ctx context.Context, appName, callID string) (io.Reader, error) {
span, ctx := opentracing.StartSpanFromContext(ctx, "ds_get_log")
defer span.Finish()
return m.ds.GetLog(ctx, appName, callID)
}
// instant & no context ;)
func (m *metricds) GetDatabase() *sqlx.DB { return m.ds.GetDatabase() }