|
1 | | -package datadog |
| 1 | +// package datadog |
2 | 2 |
|
3 | | -import ( |
4 | | - "context" |
5 | | - "log" |
6 | | - "time" |
| 3 | +// import ( |
| 4 | +// "context" |
| 5 | +// "log" |
| 6 | +// "time" |
7 | 7 |
|
8 | | - "go.opentelemetry.io/otel/api/global" |
9 | | - export "go.opentelemetry.io/otel/sdk/export/metric" |
10 | | - "go.opentelemetry.io/otel/sdk/metric/controller/push" |
11 | | - integrator "go.opentelemetry.io/otel/sdk/metric/integrator/simple" |
12 | | - "go.opentelemetry.io/otel/sdk/metric/selector/simple" |
13 | | -) |
| 8 | +// "go.opentelemetry.io/otel/api/global" |
| 9 | +// export "go.opentelemetry.io/otel/sdk/export/metric" |
| 10 | +// "go.opentelemetry.io/otel/sdk/metric/controller/push" |
| 11 | +// integrator "go.opentelemetry.io/otel/sdk/metric/integrator/simple" |
| 12 | +// "go.opentelemetry.io/otel/sdk/metric/selector/simple" |
| 13 | +// ) |
14 | 14 |
|
15 | | -func InstallNewPipeline() (*push.Controller, error) { |
16 | | - controller, err := NewExportPipeline() |
17 | | - if err != nil { |
18 | | - return controller, err |
19 | | - } |
| 15 | +// func InstallNewPipeline() (*push.Controller, error) { |
| 16 | +// controller, err := NewExportPipeline() |
| 17 | +// if err != nil { |
| 18 | +// return controller, err |
| 19 | +// } |
20 | 20 |
|
21 | | - global.SetMeterProvider(controller) |
| 21 | +// global.SetMeterProvider(controller) |
22 | 22 |
|
23 | | - return controller, err |
24 | | -} |
| 23 | +// return controller, err |
| 24 | +// } |
25 | 25 |
|
26 | | -func NewExportPipeline() (*push.Controller, error) { |
27 | | - exp, err := NewMeterExpoter() |
28 | | - if err != nil { |
29 | | - return nil, err |
30 | | - } |
| 26 | +// func NewExportPipeline() (*push.Controller, error) { |
| 27 | +// exp, err := NewMeterExpoter() |
| 28 | +// if err != nil { |
| 29 | +// return nil, err |
| 30 | +// } |
31 | 31 |
|
32 | | - selector := simple.NewWithExactMeasure() |
| 32 | +// selector := simple.NewWithExactMeasure() |
33 | 33 |
|
34 | | - integrator := integrator.New(selector, export.NewDefaultLabelEncoder(), true) |
| 34 | +// integrator := integrator.New(selector, export.NewDefaultLabelEncoder(), true) |
35 | 35 |
|
36 | | - pusher := push.New(integrator, exp, time.Minute) |
37 | | - pusher.Start() |
| 36 | +// pusher := push.New(integrator, exp, time.Minute) |
| 37 | +// pusher.Start() |
38 | 38 |
|
39 | | - return pusher, nil |
40 | | -} |
| 39 | +// return pusher, nil |
| 40 | +// } |
41 | 41 |
|
42 | | -// MeterExporter exports metrics to DataDog |
43 | | -type MeterExporter struct { |
44 | | -} |
| 42 | +// // MeterExporter exports metrics to DataDog |
| 43 | +// type MeterExporter struct { |
| 44 | +// } |
45 | 45 |
|
46 | | -// NewMeterExpoter constructs a NewMeterExpoter |
47 | | -func NewMeterExpoter() (*MeterExporter, error) { |
48 | | - return &MeterExporter{}, nil |
49 | | -} |
| 46 | +// // NewMeterExpoter constructs a NewMeterExpoter |
| 47 | +// func NewMeterExpoter() (*MeterExporter, error) { |
| 48 | +// return &MeterExporter{}, nil |
| 49 | +// } |
50 | 50 |
|
51 | | -// Export exports the provide metric record to DataDog. |
52 | | -func (e *MeterExporter) Export(ctx context.Context, checkpoint export.CheckpointSet) error { |
53 | | - log.Printf("Export Checkpoint: %+v\n", checkpoint) |
54 | | - return nil |
55 | | -} |
| 51 | +// // Export exports the provide metric record to DataDog. |
| 52 | +// func (e *MeterExporter) Export(ctx context.Context, checkpoint export.CheckpointSet) error { |
| 53 | +// log.Printf("Export Checkpoint: %+v\n", checkpoint) |
| 54 | +// return nil |
| 55 | +// } |
0 commit comments