Dev vk travis test

.gitignore

@@ -1,2 +1,5 @@
 build
 coverage.txt
+coverage.html
+pkg/mocks
+**/gomock*

.travis.yml

@@ -16,6 +16,9 @@ install:
   - rsync -az ${TRAVIS_BUILD_DIR}/ $GOPATH/src/github.com/autonomy/conform/
   - export TRAVIS_BUILD_DIR=$GOPATH/src/github.com/autonomy/conform
   - cd $GOPATH/src/github.com/autonomy/conform
+  - cat /etc/apt/sources.list
+  - ls -l /etc/apt/sources.list.d
+  - sudo rm -rf /etc/apt/sources.list.d
   - sudo apt-get -y remove docker docker-engine
   - sudo apt-get -y update
   - sudo apt-get -y install apt-transport-https ca-certificates curl software-properties-common

Dockerfile

@@ -7,8 +7,10 @@ RUN GOOS=linux GOARCH=amd64 CGO_ENABLED=0 go build -o /argus -ldflags "-X \"gith
 FROM golang:1.14 as test
 WORKDIR $GOPATH/src/github.com/logicmonitor/k8s-argus
 RUN go get -u github.com/alecthomas/gometalinter
+RUN go get github.com/golang/mock/mockgen
 RUN gometalinter --install
 COPY --from=build $GOPATH/src/github.com/logicmonitor/k8s-argus ./
+RUN go generate ./...
 RUN chmod +x ./scripts/test.sh; sync; ./scripts/test.sh
 RUN cp coverage.txt /coverage.txt
 

Makefile

@@ -1,14 +1,31 @@
 NAMESPACE  := logicmonitor
 REPOSITORY := argus
-VERSION    := 1.0.0
+VERSION       ?= $(shell git describe --tags --always --dirty)
 
-all:
-	docker build --build-arg VERSION=$(VERSION) -t $(NAMESPACE)/$(REPOSITORY):v2latest .
-	docker tag $(NAMESPACE)/$(REPOSITORY):v2latest $(NAMESPACE)/$(REPOSITORY):$(VERSION)
+default: build
+
+lint:
+ifeq ($(shell uname -s), Darwin)
+	find pkg/ -type f | grep go | egrep -v "mocks|gomock" | xargs gofmt -l -d -s -w
+	find pkg/ -type f | grep go | egrep -v "mocks|gomock" | xargs goimports -l -d -w
+endif
+
+build: lint
+
+	docker build --build-arg VERSION=$(VERSION) -t $(NAMESPACE)/$(REPOSITORY):$(VERSION) .
+
+dev: lint
+	docker build --build-arg VERSION=$(VERSION) -t $(NAMESPACE)/$(REPOSITORY):$(VERSION) -f Dockerfile.dev .
+
+mockgen:
+	go generate ./...
+test: mockgen lint
+	go test ./... -v -coverprofile=coverage.txt -race
+	go tool cover -html=coverage.txt -o coverage.html
+
+devsetup:
+	go get github.com/golang/mock/mockgen
 
-dev:
-	docker build --build-arg VERSION=$(VERSION) -t $(NAMESPACE)/$(REPOSITORY):v2latest -f Dockerfile.dev .
-	docker tag $(NAMESPACE)/$(REPOSITORY):v2latest $(NAMESPACE)/$(REPOSITORY):$(VERSION)
 
 .PHONY: docs
 docs:

go.mod

@@ -7,6 +7,7 @@ require (
 	github.com/coreos/etcd v3.3.13+incompatible
 	github.com/go-openapi/runtime v0.19.11
 	github.com/go-openapi/strfmt v0.19.4
+	github.com/golang/mock v1.4.4
 	github.com/golang/protobuf v1.4.2 // indirect
 	github.com/google/uuid v1.1.1
 	github.com/googleapis/gnostic v0.4.0 // indirect

go.sum

@@ -140,7 +140,10 @@ github.com/golang/groupcache v0.0.0-20160516000752-02826c3e7903/go.mod h1:cIg4er
 github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef h1:veQD95Isof8w9/WXiA+pa3tz3fJXkt5B7QaRBrM62gk=
 github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
 github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/mock v1.2.0 h1:28o5sBqPkBsMGnC6b4MvE2TzSr5/AT4c/1fLqVGIwlk=
 github.com/golang/mock v1.2.0/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/mock v1.4.4 h1:l75CXGRSwbaYNpl/Z2X1XIIAMSCquvXgpVZDhwEIJsc=
+github.com/golang/mock v1.4.4/go.mod h1:l3mdAwkq5BuhzHwde/uurv3sEJeZMXNpwsxVWU71h+4=
 github.com/golang/protobuf v0.0.0-20161109072736-4bd1920723d7/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
@@ -220,14 +223,8 @@ github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/logicmonitor/k8s-collectorset-controller v2.0.0+incompatible h1:0zX0S8yYyxImnLCb22PZ9p21FGBlyAjH59KawhzrNTU=
 github.com/logicmonitor/k8s-collectorset-controller v2.0.0+incompatible/go.mod h1:Lttrp2s4kBgrI+Bo3mzlURp/BGs7Op3ncCL1mIGegEU=
-github.com/logicmonitor/lm-sdk-go v2.0.0-argus1+incompatible h1:/aHD5h0X5PxKVB7NBurv/UUyxR42fFIsJar/5t8ac0s=
-github.com/logicmonitor/lm-sdk-go v2.0.0-argus1+incompatible/go.mod h1:gpLvWtDkb4lq+ezlvG79A953MZHoq/3XLTff4AIUF+M=
-github.com/logicmonitor/lm-sdk-go v2.0.0-argus2+incompatible h1:BPoEW3DbfjtiBRgpygjOo1S0vj7+nWV7i+wprziuCxQ=
-github.com/logicmonitor/lm-sdk-go v2.0.0-argus2+incompatible/go.mod h1:gpLvWtDkb4lq+ezlvG79A953MZHoq/3XLTff4AIUF+M=
 github.com/logicmonitor/lm-sdk-go v2.0.0-argus3+incompatible h1:Z5LJO+g30WyL4rG8bOsu6X3dwUpO0pHWtP6ZoCJFQh0=
 github.com/logicmonitor/lm-sdk-go v2.0.0-argus3+incompatible/go.mod h1:gpLvWtDkb4lq+ezlvG79A953MZHoq/3XLTff4AIUF+M=
-github.com/logicmonitor/lm-sdk-go v2.0.0+incompatible h1:g/8iONuJKtUWGQ3MVdSRXhE5ovtxF2voi4OCZFwEDDM=
-github.com/logicmonitor/lm-sdk-go v2.0.0+incompatible/go.mod h1:gpLvWtDkb4lq+ezlvG79A953MZHoq/3XLTff4AIUF+M=
 github.com/magiconair/properties v1.8.0 h1:LLgXmsheXeRoUOBOjtwPQCWIYqM/LU1ayDtDePerRcY=
 github.com/magiconair/properties v1.8.0/go.mod h1:PppfXfuXeibc/6YijjN8zIbojt8czPbwD3XqdrwzmxQ=
 github.com/mailru/easyjson v0.0.0-20160728113105-d5b7844b561a/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
@@ -319,8 +316,6 @@ github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhV
 github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5 h1:LnC5Kc/wtumK+WB441p7ynQJzVuNRJiqddSIE3IlSEQ=
 github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
 github.com/ugorji/go v1.1.4/go.mod h1:uQMGLiO92mf5W77hV/PUCpI3pbzQx3CRekS0kk+RGrc=
-github.com/vkumbhar94/lm-sdk-go v2.0.1+incompatible h1:t1UbZZ1ju6wv6NRVf6lx9wu4hHEe/mneZxqYGwIq/O8=
-github.com/vkumbhar94/lm-sdk-go v2.0.1+incompatible/go.mod h1:svWOa+F9+4aChOCrhd5m2pZt7V1zx2VUkmCkkdjw7Lg=
 github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2 h1:eY9dn8+vbi4tKz5Qo6v2eYzo7kUS51QINcR5jNpbZS8=
 github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
 github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
@@ -409,8 +404,10 @@ golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGm
 golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
 golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
 golang.org/x/tools v0.0.0-20190312170243-e65039ee4138/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
+golang.org/x/tools v0.0.0-20190425150028-36563e24a262/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
 golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
 golang.org/x/tools v0.0.0-20190614205625-5aca471b1d59/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
+golang.org/x/tools v0.0.0-20190617190820-da514acc4774 h1:CQVOmarCBFzTx0kbOU0ru54Cvot8SdSrNYjZPhQl+gk=
 golang.org/x/tools v0.0.0-20190617190820-da514acc4774/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

pkg/argus.go

@@ -3,7 +3,6 @@ package argus
 import (
 	"net/http"
 	"net/url"
-	"time"
 
 	httptransport "github.com/go-openapi/runtime/client"
 	"github.com/go-openapi/strfmt"
@@ -52,6 +51,10 @@ func newLMClient(argusConfig *config.Config) (*client.LMSdkGo, error) {
 	config.SetAccountDomain(&domain)
 	//config.UserAgent = constants.UserAgentBase + constants.Version
 	if argusConfig.ProxyURL == "" {
+		//return client.New(config), nil
+		if argusConfig.IgnoreSSL {
+			return newLMClientWithoutSSL(config)
+		}
 		return client.New(config), nil
 	}
 	return newLMClientWithProxy(config, argusConfig)
@@ -83,6 +86,22 @@ func newLMClientWithProxy(config *client.Config, argusConfig *config.Config) (*c
 	return client, nil
 }
 
+func newLMClientWithoutSSL(config *client.Config) (*client.LMSdkGo, error) {
+
+	var opts = httptransport.TLSClientOptions{InsecureSkipVerify: true}
+	var httpClient, err = httptransport.TLSClient(opts)
+
+	if err != nil {
+		return nil, err
+	}
+	transport := httptransport.NewWithClient(config.TransportCfg.Host, config.TransportCfg.BasePath, config.TransportCfg.Schemes, httpClient)
+	authInfo := client.LMv1Auth(*config.AccessID, *config.AccessKey)
+	cli := new(client.LMSdkGo)
+	cli.Transport = transport
+	cli.LM = lm.New(transport, strfmt.Default, authInfo)
+	return cli, nil
+}
+
 func newK8sClient() (*kubernetes.Clientset, error) {
 	config, err := rest.InClusterConfig()
 	if err != nil {
@@ -110,7 +129,7 @@ func NewArgus(base *types.Base) (*Argus, error) {
 		Base: base,
 	}
 
-	dcache := devicecache.NewDeviceCache(base, 5)
+	dcache := devicecache.NewDeviceCache(base, base.Config.GetCacheSyncInterval())
 	dcache.Run()
 
 	deviceManager := &device.Manager{
@@ -237,7 +256,9 @@ func NewArgus(base *types.Base) (*Argus, error) {
 
 	lctx := lmlog.NewLMContextWith(log.WithFields(log.Fields{"name": "init-sync"}))
 	initSyncer.InitSync(lctx, true)
-	initSyncer.RunPeriodicSync(10)
+
+	// periodically delete the non-exist resource devices through logicmonitor API based on specified time interval.
+	initSyncer.RunPeriodicSync(base.Config.GetPeriodicDeleteInterval())
 
 	if base.Config.EtcdDiscoveryToken != "" {
 		etcdController := etcd.Controller{
@@ -280,6 +301,7 @@ func NewBase(config *config.Config) (*types.Base, error) {
 
 // Watch watches the API for events.
 func (a *Argus) Watch() {
+	syncInterval := a.Base.Config.GetPeriodicSyncInterval()
 	log.Debugf("Starting watchers")
 	for _, w := range a.Watchers {
 		if !w.Enabled() {
@@ -290,7 +312,7 @@ func (a *Argus) Watch() {
 		_, controller := cache.NewInformer(
 			watchlist,
 			w.ObjType(),
-			time.Minute*10,
+			syncInterval,
 			cache.ResourceEventHandlerFuncs{
 				AddFunc:    w.AddFunc(),
 				DeleteFunc: w.DeleteFunc(),
@@ -300,18 +322,6 @@ func (a *Argus) Watch() {
 		log.Debugf("Starting watcher of %v", w.Resource())
 		stop := make(chan struct{})
 		go controller.Run(stop)
-		//		c := w.GetConfig()
-		//		if c == nil {
-		//			continue
-		//		}
-		//		wc := worker.NewWorker(c)
-		//		b, err := a.Facade.RegisterWorker(w.Resource(), wc)
-		//		if err != nil {
-		//			log.Errorf("Failed to register worker for resource for: %s", w.Resource())
-		//		}
-		//		if b {
-		//			wc.StartWorker()
-		//		}
 	}
 }
 

pkg/config/config.go

@@ -2,25 +2,31 @@ package config
 
 import (
 	"io/ioutil"
+	"time"
 
 	"github.com/kelseyhightower/envconfig"
 	"github.com/logicmonitor/k8s-argus/pkg/constants"
-	"gopkg.in/yaml.v2"
+	log "github.com/sirupsen/logrus"
+	yaml "gopkg.in/yaml.v2"
 )
 
 // Config represents the application's configuration file.
+// nolint: maligned
 type Config struct {
 	*Secrets
-	Address                           string `yaml:"address"`
-	ClusterCategory                   string `yaml:"cluster_category"`
-	ClusterName                       string `yaml:"cluster_name"`
-	Debug                             bool   `yaml:"debug"`
-	DeleteDevices                     bool   `yaml:"delete_devices"`
-	DisableAlerting                   bool   `yaml:"disable_alerting"`
-	FullDisplayNameIncludeNamespace   bool   `yaml:"displayName_include_namespace"`
-	FullDisplayNameIncludeClusterName bool   `yaml:"displayName_include_clustername"`
-	ClusterGroupID                    int32  `yaml:"cluster_group_id"`
-	ProxyURL                          string `yaml:"proxy_url"`
+	DeviceGroupProperties             DeviceGroupProperties `yaml:"device_group_props"`
+	Intervals                         Intervals             `yaml:"app_intervals"`
+	Address                           string                `yaml:"address"`
+	ClusterCategory                   string                `yaml:"cluster_category"`
+	ClusterName                       string                `yaml:"cluster_name"`
+	Debug                             bool                  `yaml:"debug"`
+	DeleteDevices                     bool                  `yaml:"delete_devices"`
+	DisableAlerting                   bool                  `yaml:"disable_alerting"`
+	FullDisplayNameIncludeNamespace   bool                  `yaml:"displayName_include_namespace"`
+	FullDisplayNameIncludeClusterName bool                  `yaml:"displayName_include_clustername"`
+	ClusterGroupID                    int32                 `yaml:"cluster_group_id"`
+	ProxyURL                          string                `yaml:"proxy_url"`
+	IgnoreSSL                         bool                  `yaml:"ignore_ssl"`
 }
 
 // Secrets represents the application's sensitive configuration file.
@@ -33,6 +39,27 @@ type Secrets struct {
 	ProxyPass          string `envconfig:"PROXY_PASS"`
 }
 
+// DeviceGroupProperties represents the properties applied on device groups
+type DeviceGroupProperties struct {
+	Cluster     []map[string]interface{} `yaml:"cluster"`
+	Pods        []map[string]interface{} `yaml:"pods"`
+	Services    []map[string]interface{} `yaml:"services"`
+	Deployments []map[string]interface{} `yaml:"deployments"`
+	Nodes       []map[string]interface{} `yaml:"nodes"`
+	ETCD        []map[string]interface{} `yaml:"etcd"`
+	HPA         []map[string]interface{} `yaml:"hpas"`
+}
+
+// Intervals represents default and min values for periodic sync, periodic delete and device cache sycn intervals
+type Intervals struct {
+	PeriodicSyncInterval      time.Duration `yaml:"periodic_sync_interval"`
+	PeriodicDeleteInterval    time.Duration `yaml:"periodic_delete_interval"`
+	CacheSyncInterval         time.Duration `yaml:"cache_sync_interval"`
+	PeriodicSyncMinInterval   time.Duration `yaml:"periodic_sync_min_interval"`
+	PeriodicDeleteMinInterval time.Duration `yaml:"periodic_delete_min_interval"`
+	CacheSyncMinInterval      time.Duration `yaml:"cache_sync_min_interval"`
+}
+
 // GetConfig returns the application configuration specified by the config file.
 func GetConfig() (*Config, error) {
 	configBytes, err := ioutil.ReadFile(constants.ConfigPath)
@@ -53,3 +80,39 @@ func GetConfig() (*Config, error) {
 
 	return c, nil
 }
+
+// GetCacheSyncInterval gets cache resync interval
+func (config Config) GetCacheSyncInterval() time.Duration {
+	cacheInterval := validateAndGetIntervalValue("cache_sync_interval", config.Intervals.CacheSyncInterval, config.Intervals.CacheSyncMinInterval, constants.DefaultCacheResyncInterval)
+	log.Debugf("cache_sync_interval - %v ", cacheInterval)
+	return cacheInterval
+}
+
+// GetPeriodicSyncInterval gets periodic sync interval
+func (config Config) GetPeriodicSyncInterval() time.Duration {
+	periodicSyncInterval := validateAndGetIntervalValue("periodic_sync_interval", config.Intervals.PeriodicSyncInterval, config.Intervals.PeriodicSyncMinInterval, constants.DefaultPeriodicSyncInterval)
+	log.Debugf("periodic_sync_interval - %v ", periodicSyncInterval)
+	return periodicSyncInterval
+}
+
+// GetPeriodicDeleteInterval gets periodic delete interval
+func (config Config) GetPeriodicDeleteInterval() time.Duration {
+	periodicDeleteInterval := validateAndGetIntervalValue("periodic_delete_interval", config.Intervals.PeriodicDeleteInterval, config.Intervals.PeriodicDeleteMinInterval, constants.DefaultPeriodicDeleteInterval)
+	log.Debugf("periodic_delete_interval - %v ", periodicDeleteInterval)
+	return periodicDeleteInterval
+}
+
+// ValidateAndGetIntervalValue parses given interval into duration format. Returns default value if any errors.
+func validateAndGetIntervalValue(intervalName string, syncInterval, minInterval, defaultValue time.Duration) time.Duration {
+	if syncInterval < minInterval {
+		log.Warnf("Please provide valid value for %s. Since invalid value is configured, forcefully setting it to default %v. ", intervalName, defaultValue)
+		syncInterval = defaultValue
+	}
+
+	if syncInterval == 0 || minInterval == 0 {
+		log.Warnf("Looks like helm chart is of previous version than the current Argus expects. Please upgrade helm chart. Setting %s to its default : %v", intervalName, defaultValue)
+		syncInterval = defaultValue
+	}
+
+	return syncInterval
+}

pkg/constants/constants.go

@@ -1,5 +1,7 @@
 package constants
 
+import "time"
+
 var (
 	// Version is the Argus version and is set at build time.
 	Version string
@@ -15,6 +17,12 @@ const (
 	RootDeviceGroupID = 1
 	// CustomPropertiesFieldName is the field name for a device's custom properties.
 	CustomPropertiesFieldName = "customProperties"
+	// NameFieldName is the field name for a device's name.
+	NameFieldName = "name"
+	// DisplayNameFieldName is the field name for a device's display name.
+	DisplayNameFieldName = "displayName"
+	// MaxResourceLength is the max length of the resource name
+	MaxResourceLength = 244
 )
 
 const (
@@ -108,6 +116,12 @@ const (
 	K8sResourceNamePropertyKey = "auto.resourcename"
 	// K8sResourceCreatedOnPropertyKey is the key of the custom property used to record resource create timestamp
 	K8sResourceCreatedOnPropertyKey = "kubernetes.resourceCreatedOn"
+	// K8sResourceDeletedOnPropertyKey is the key of the custom property used to record resource deleted timestamp
+	K8sResourceDeletedOnPropertyKey = "kubernetes.resourceDeletedOn"
+	// K8sResourceDeleteAfterDurationPropertyKey is the key of the custom property used to delete resources from the portal after specified time
+	K8sResourceDeleteAfterDurationPropertyKey = "kubernetes.resourcedeleteafterduration"
+	// K8sResourceDeleteAfterDurationPropertyValue is the default value of the custom property used to delete resources from the portal after specified time
+	K8sResourceDeleteAfterDurationPropertyValue = "P1DT0H0M0S"
 	// K8sDeviceType is the type value of the k8s device
 	K8sDeviceType = 8
 	// K8sSystemCategoriesPropertyKey is the key of the unique custom property kubernetes system categories
@@ -148,6 +162,8 @@ const (
 )
 
 const (
+	// ArgusAppVersion is the key for Argus app version
+	ArgusAppVersion = "argus.app-version"
 	// HelmChart is the key for Argus & Collectoeset-controller label
 	HelmChart = "helm-chart"
 	// HelmRevision is the key for Argus & Collectoeset-controller label
@@ -172,3 +188,14 @@ const (
 	// IsPingDevice is the key used in watcher context to pass metadata
 	IsPingDevice = "ispingdevice"
 )
+
+const (
+	// DefaultPeriodicSyncInterval Default interval for Periodic Discovery.
+	DefaultPeriodicSyncInterval = time.Minute * 30
+
+	// DefaultPeriodicDeleteInterval Default interval for Periodic delete.
+	DefaultPeriodicDeleteInterval = time.Minute * 30
+
+	// DefaultCacheResyncInterval Default interval for cache resync.
+	DefaultCacheResyncInterval = time.Minute * 5
+)

pkg/cronjob/cronjob.go

@@ -3,7 +3,7 @@ package cronjob
 import (
 	"github.com/logicmonitor/k8s-argus/pkg/lmctx"
 	lmlog "github.com/logicmonitor/k8s-argus/pkg/log"
-	"github.com/robfig/cron/v3"
+	cron "github.com/robfig/cron/v3"
 )
 
 var (