fix dump remote bucket (#280)

* Fix local dev env with datadog

* fix empty bucket name on dump command

* reverting

pkg/config/collector.go

@@ -41,15 +41,9 @@ type K8SAPICollectorConfig struct {
 type FileCollectorConfig struct {
 	Directory string             `mapstructure:"directory"` // Base directory holding the K8s data JSON files
 	Archive   *FileArchiveConfig `mapstructure:"archive"`   // Archive configuration
-	Blob      *BlobConfig        `mapstructure:"blob"`      // Blob storage configuration
 }
 
 type FileArchiveConfig struct {
 	ArchiveName string `mapstructure:"archive_name"` // Name of the output archive
 	NoCompress  bool   `mapstructure:"no_compress"`  // Disable compression for the dumped data (generates a tar.gz file)
 }
-
-type BlobConfig struct {
-	BucketUrl string `mapstructure:"bucket_url"` // Bucket to use to push k8s resources (e.g.: s3://<your_bucket>)
-	Region    string `mapstructure:"region"`     // Region to use for the bucket (only for s3)
-}

pkg/config/ingestor.go

@@ -30,3 +30,8 @@ type IngestorAPIConfig struct {
 	Endpoint string `mapstructure:"endpoint"`
 	Insecure bool   `mapstructure:"insecure" validate:"omitempty,boolean"`
 }
+
+type BlobConfig struct {
+	BucketUrl string `mapstructure:"bucket_url"` // Bucket to use to push k8s resources (e.g.: s3://<your_bucket>)
+	Region    string `mapstructure:"region"`     // Region to use for the bucket (only for s3)
+}

pkg/kubehound/core/core_dump.go

@@ -60,7 +60,7 @@ func DumpCore(ctx context.Context, khCfg *config.KubehoundConfig, upload bool) (
 				log.I.Errorf("Failed to remove temporary directory: %v", err)
 			}
 		}()
-		puller, err := blob.NewBlobStorage(khCfg, khCfg.Collector.File.Blob)
+		puller, err := blob.NewBlobStorage(khCfg, khCfg.Ingestor.Blob)
 		if err != nil {
 			return "", err
 		}