Passed
Push — master ( ad04e3...c5b8de )
by eval
01:47
created

cloudwatchlogs.New   A

Complexity

Conditions 3

Size

Total Lines 15
Code Lines 11

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 3
eloc 11
nop 1
dl 0
loc 15
rs 9.85
c 0
b 0
f 0
1
package cloudwatchlogs
2
3
import (
4
	SDK "github.com/aws/aws-sdk-go-v2/service/cloudwatchlogs"
5
6
	"github.com/evalphobia/aws-sdk-go-v2-wrapper/config"
7
	"github.com/evalphobia/aws-sdk-go-v2-wrapper/errors"
8
	"github.com/evalphobia/aws-sdk-go-v2-wrapper/log"
9
)
10
11
const (
12
	serviceName = "CloudwatchLogs"
13
)
14
15
// CloudwatchLogs has CloudwatchLogs client.
16
type CloudwatchLogs struct {
17
	client *SDK.Client
18
19
	logger  log.Logger
20
	errWrap func(errors.ErrorData) error
21
}
22
23
// New returns initialized *CloudwatchLogs.
24
func New(conf config.Config) (*CloudwatchLogs, error) {
25
	c, err := conf.AWSConfig()
26
	if err != nil {
27
		return nil, err
28
	}
29
	if conf.Endpoints.HasCloudwatchLogs() {
30
		c.EndpointResolver = conf.Endpoints.GetCloudwatchLogs()
31
	}
32
33
	svc := &CloudwatchLogs{
34
		client:  SDK.New(c),
35
		logger:  conf.GetLogger(),
36
		errWrap: conf.GetErrWrap(),
37
	}
38
	return svc, nil
39
}
40
41
// GetClient gets original SDK client.
42
func (svc *CloudwatchLogs) GetClient() *SDK.Client {
43
	return svc.client
44
}
45
46
// SetLogger sets logger.
47
func (svc *CloudwatchLogs) SetLogger(logger log.Logger) {
48
	svc.logger = logger
49
}
50
51
// Infof logging information.
52
func (svc *CloudwatchLogs) Infof(format string, v ...interface{}) {
53
	svc.logger.Infof(serviceName, format, v...)
54
}
55
56
// Errorf logging error information.
57
func (svc *CloudwatchLogs) Errorf(format string, v ...interface{}) {
58
	svc.logger.Errorf(serviceName, format, v...)
0 ignored issues
show
introduced by
no formatting directive in Errorf call
Loading history...
59
}
60