contrib/exporters: Rename "sa" to "secadvisor"

Author: dubek

contrib/exporters/allinone/allinone.yml.default

@@ -14,8 +14,8 @@ pipeline:
       # - internal
       # - other
   transform:
-    type: sa
-    sa:
+    type: secadvisor
+    secadvisor:
       # exclude_started_flows: true
   store:
     type: s3

contrib/exporters/allinone/main.go

@@ -20,15 +20,15 @@ package main
 import (
 	aws "github.com/skydive-project/skydive/contrib/exporters/awsflowlogs/mod"
 	"github.com/skydive-project/skydive/contrib/exporters/core"
-	sa "github.com/skydive-project/skydive/contrib/exporters/secadvisor/mod"
+	secadvisor "github.com/skydive-project/skydive/contrib/exporters/secadvisor/mod"
 )
 
 func main() {
 	core.Main("/etc/skydive/allinone.yml")
 }
 
 func init() {
-	core.EncoderHandlers.Register("sa", sa.NewEncode, false)
+	core.EncoderHandlers.Register("secadvisor", secadvisor.NewEncode, false)
 	core.TransformerHandlers.Register("awsflowlogs", aws.NewTransform, false)
-	core.TransformerHandlers.Register("vpclogs", sa.NewTransform, false)
+	core.TransformerHandlers.Register("vpclogs", secadvisor.NewTransform, false)
 }

contrib/exporters/secadvisor/main.go

@@ -27,6 +27,6 @@ func main() {
 }
 
 func init() {
-	core.EncoderHandlers.Register("sa", mod.NewEncode, true)
-	core.TransformerHandlers.Register("sa", mod.NewTransform, true)
+	core.EncoderHandlers.Register("secadvisor", mod.NewEncode, true)
+	core.TransformerHandlers.Register("secadvisor", mod.NewTransform, true)
 }

contrib/exporters/secadvisor/mod/transform.go

@@ -31,7 +31,7 @@ import (
 
 // NewTransform creates a new flow transformer based on a name string
 func NewTransform(cfg *viper.Viper) (interface{}, error) {
-	excludeStartedFlows := cfg.GetBool(core.CfgRoot + "transform.sa.exclude_started_flows")
+	excludeStartedFlows := cfg.GetBool(core.CfgRoot + "transform.secadvisor.exclude_started_flows")
 
 	resolver := NewResolveRunc(cfg)
 	resolver = NewResolveMulti(resolver)

contrib/exporters/secadvisor/secadvisor.yml.default

@@ -25,13 +25,13 @@ pipeline:
     # exclude the following classified tags 
     excluded_tags:
       - other
-  # transform to sa record structure
+  # transform to secadvisor record structure
   transform:
-    type: sa
-    sa:
+    type: secadvisor
+    secadvisor:
       exclude_started_flows: true
   encode:
-    type: sa
+    type: secadvisor
     json:
       pretty: true
   compress:

contrib/exporters/vpclogs/main.go

@@ -19,13 +19,13 @@ package main
 
 import (
 	"github.com/skydive-project/skydive/contrib/exporters/core"
-	sa "github.com/skydive-project/skydive/contrib/exporters/secadvisor/mod"
+	secadvisor "github.com/skydive-project/skydive/contrib/exporters/secadvisor/mod"
 )
 
 func main() {
 	core.Main("/etc/skydive/vpclogs.yml")
 }
 
 func init() {
-	core.TransformerHandlers.Register("vpclogs", sa.NewTransform, false)
+	core.TransformerHandlers.Register("vpclogs", secadvisor.NewTransform, false)
 }