@@ -19,6 +19,7 @@ import (
19
19
"fmt"
20
20
21
21
atlas "github.com/mongodb/go-client-mongodb-atlas/mongodbatlas"
22
+ om "github.com/mongodb/go-client-mongodb-ops-manager/opsmngr"
22
23
"github.com/mongodb/mongocli/internal/config"
23
24
)
24
25
@@ -46,6 +47,9 @@ func (s *Store) Alert(projectID, alertID string) (*atlas.Alert, error) {
46
47
case config .CloudService :
47
48
result , _ , err := s .client .(* atlas.Client ).Alerts .Get (context .Background (), projectID , alertID )
48
49
return result , err
50
+ case config .OpsManagerService , config .CloudManagerService :
51
+ result , _ , err := s .client .(* om.Client ).Alerts .Get (context .Background (), projectID , alertID )
52
+ return result , err
49
53
default :
50
54
return nil , fmt .Errorf ("unsupported service: %s" , s .service )
51
55
}
@@ -57,6 +61,9 @@ func (s *Store) Alerts(projectID string, opts *atlas.ListOptions) ([]atlas.Alert
57
61
case config .CloudService :
58
62
result , _ , err := s .client .(* atlas.Client ).Alerts .List (context .Background (), projectID , opts )
59
63
return result , err
64
+ case config .OpsManagerService , config .CloudManagerService :
65
+ result , _ , err := s .client .(* om.Client ).Alerts .List (context .Background (), projectID , opts )
66
+ return result , err
60
67
default :
61
68
return nil , fmt .Errorf ("unsupported service: %s" , s .service )
62
69
}
@@ -68,6 +75,9 @@ func (s *Store) AcknowledgeAlert(projectID, alertID string, body *atlas.Acknowle
68
75
case config .CloudService :
69
76
result , _ , err := s .client .(* atlas.Client ).Alerts .Acknowledge (context .Background (), projectID , alertID , body )
70
77
return result , err
78
+ case config .OpsManagerService , config .CloudManagerService :
79
+ result , _ , err := s .client .(* om.Client ).Alerts .Acknowledge (context .Background (), projectID , alertID , body )
80
+ return result , err
71
81
default :
72
82
return nil , fmt .Errorf ("unsupported service: %s" , s .service )
73
83
}
0 commit comments