/
service.go
62 lines (52 loc) · 1.75 KB
/
service.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
package server
import (
"context"
cloudhub "github.com/snetsystems/cloudhub/backend"
"github.com/snetsystems/cloudhub/backend/influx"
)
// Service handles REST calls to the persistence
type Service struct {
Store DataStore
TimeSeriesClient TimeSeriesClient
Logger cloudhub.Logger
UseAuth bool
SuperAdminProviderGroups superAdminProviderGroups
Env cloudhub.Environment
Databases cloudhub.Databases
AddonURLs map[string]string
MailSubject string
MailBody string
ExternalExec string
ExternalExecArgs string
LoginAuthType string
BasicPasswordResetType string
}
type superAdminProviderGroups struct {
auth0 string
}
// TimeSeriesClient returns the correct client for a time series database.
// todo(glinton): should this be always reconnecting?
type TimeSeriesClient interface {
New(cloudhub.Source, cloudhub.Logger) (cloudhub.TimeSeries, error)
}
// ErrorMessage is the error response format for all service errors
type ErrorMessage struct {
Code int `json:"code"`
Message string `json:"message"`
}
// TimeSeries returns a new client connected to a time series database
func (s *Service) TimeSeries(src cloudhub.Source) (cloudhub.TimeSeries, error) {
return s.TimeSeriesClient.New(src, s.Logger)
}
// InfluxClient returns a new client to connect to OSS
type InfluxClient struct{}
// New creates a client to connect to OSS
func (c *InfluxClient) New(src cloudhub.Source, logger cloudhub.Logger) (cloudhub.TimeSeries, error) {
client := &influx.Client{
Logger: logger,
}
if err := client.Connect(context.TODO(), &src); err != nil {
return nil, err
}
return client, nil
}