diff --git a/service/CollectorService.go b/service/CollectorService.go index 3cdcfe8..af0d1e5 100644 --- a/service/CollectorService.go +++ b/service/CollectorService.go @@ -5,6 +5,9 @@ import ( cda "git.loafle.net/commons/di-go/annotation" cdr "git.loafle.net/commons/di-go/registry" + ocsp "git.loafle.net/overflow/commons-go/service/probe" + + // For annotation _ "git.loafle.net/overflow/commons-go/core/annotation" ) @@ -15,6 +18,7 @@ func init() { } type CollectorService struct { + ocsp.CollectorService cda.TypeAnnotation `annotation:"@overflow:RPCService()"` DataClientService *DataClientService `annotation:"@Inject()"` diff --git a/service/ContainerService.go b/service/ContainerService.go index 4528deb..a74feac 100644 --- a/service/ContainerService.go +++ b/service/ContainerService.go @@ -16,6 +16,7 @@ import ( crc "git.loafle.net/commons/rpc-go/client" csc "git.loafle.net/commons/server-go/client" occp "git.loafle.net/overflow/commons-go/config/probe" + ocsp "git.loafle.net/overflow/commons-go/service/probe" "git.loafle.net/overflow/probe/client/container" "git.loafle.net/overflow/probe/config" @@ -30,6 +31,7 @@ func init() { } type ContainerService struct { + ocsp.ContainerService cda.TypeAnnotation `annotation:"@overflow:RPCService()"` DiscoveryService *DiscoveryService `annotation:"@Inject()"` diff --git a/service/CrawlerService.go b/service/CrawlerService.go index 410b463..da5927e 100644 --- a/service/CrawlerService.go +++ b/service/CrawlerService.go @@ -5,6 +5,9 @@ import ( cda "git.loafle.net/commons/di-go/annotation" cdr "git.loafle.net/commons/di-go/registry" + ocsp "git.loafle.net/overflow/commons-go/service/probe" + + // For annotation _ "git.loafle.net/overflow/commons-go/core/annotation" ) @@ -15,6 +18,7 @@ func init() { } type CrawlerService struct { + ocsp.CrawlerService cda.TypeAnnotation `annotation:"@overflow:RPCService()"` } diff --git a/service/DataClientService.go b/service/DataClientService.go index 9140eec..f8df525 100644 --- a/service/DataClientService.go +++ b/service/DataClientService.go @@ -5,8 +5,11 @@ import ( cda "git.loafle.net/commons/di-go/annotation" cdr "git.loafle.net/commons/di-go/registry" - _ "git.loafle.net/overflow/commons-go/core/annotation" + ocsp "git.loafle.net/overflow/commons-go/service/probe" "git.loafle.net/overflow/probe/client/central" + + // For annotation + _ "git.loafle.net/overflow/commons-go/core/annotation" ) var DataClientServiceType = reflect.TypeOf((*DataClientService)(nil)) @@ -16,6 +19,7 @@ func init() { } type DataClientService struct { + ocsp.DataClientService RPCClientService cda.TypeAnnotation `annotation:"@overflow:RPCService()"` diff --git a/service/DiscoveryService.go b/service/DiscoveryService.go index 8a9b83c..4ddf0f4 100644 --- a/service/DiscoveryService.go +++ b/service/DiscoveryService.go @@ -8,6 +8,7 @@ import ( cdr "git.loafle.net/commons/di-go/registry" occp "git.loafle.net/overflow/commons-go/config/probe" ocmd "git.loafle.net/overflow/commons-go/model/discovery" + ocsp "git.loafle.net/overflow/commons-go/service/probe" // For annotation _ "git.loafle.net/overflow/commons-go/core/annotation" @@ -20,6 +21,7 @@ func init() { } type DiscoveryService struct { + ocsp.DiscoveryService cda.TypeAnnotation `annotation:"@overflow:RPCService()"` ContainerService *ContainerService `annotation:"@Inject()"` diff --git a/service/SensorConfigService.go b/service/SensorConfigService.go index db33ef2..341bf04 100644 --- a/service/SensorConfigService.go +++ b/service/SensorConfigService.go @@ -11,6 +11,7 @@ import ( cda "git.loafle.net/commons/di-go/annotation" cdr "git.loafle.net/commons/di-go/registry" ocmsc "git.loafle.net/overflow/commons-go/model/sensorconfig" + ocsp "git.loafle.net/overflow/commons-go/service/probe" "git.loafle.net/overflow/probe/config" // For annotation @@ -24,6 +25,7 @@ func init() { } type SensorConfigService struct { + ocsp.SensorConfigService cda.TypeAnnotation `annotation:"@overflow:RPCService()"` sensorConfigs map[string]*ocmsc.SensorConfig