Delete old e2e tests (#438)

We'll be replacing our e2e tests so these are no longer necessary.

Makefile

@@ -43,10 +43,6 @@ test:
 	go test ./...
 .PHONY: test
 
-e2e:
-	KUSTO_INTEGRATION_TEST=true go test -timeout 5m -count=1 -v github.com/Azure/adx-mon/tools/test/logs
-.PHONY: e2e
-
 default:
 	@$(MAKE) test
 	@$(MAKE) build

cmd/ingestor/main.go

@@ -29,7 +29,6 @@ import (
 	"github.com/Azure/adx-mon/pkg/logger"
 	"github.com/Azure/adx-mon/pkg/tls"
 	"github.com/Azure/adx-mon/schema"
-	"github.com/Azure/adx-mon/tools/otlp/logs/kustainer"
 	"github.com/Azure/azure-kusto-go/kusto"
 	"github.com/Azure/azure-kusto-go/kusto/ingest"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
@@ -528,25 +527,19 @@ func newUploaders(endpoints []string, storageDir string, concurrentUploads int,
 		if err != nil {
 			return nil, nil, err
 		}
-		if strings.HasPrefix(addr, "http://") {
-
-			logger.Warnf("Using Kustainer for endpoint %s", endpoint)
-			uploaders = append(uploaders, kustainer.New(database, addr))
-		} else {
-
-			client, err := newKustoClient(addr)
-			if err != nil {
-				return nil, nil, err
-			}
-			uploaders = append(uploaders, adx.NewUploader(client, adx.UploaderOpts{
-				StorageDir:        storageDir,
-				Database:          database,
-				ConcurrentUploads: concurrentUploads,
-				DefaultMapping:    defaultMapping,
-				SampleType:        sampleType,
-				FnStore:           fnStore,
-			}))
+
+		client, err := newKustoClient(addr)
+		if err != nil {
+			return nil, nil, err
 		}
+		uploaders = append(uploaders, adx.NewUploader(client, adx.UploaderOpts{
+			StorageDir:        storageDir,
+			Database:          database,
+			ConcurrentUploads: concurrentUploads,
+			DefaultMapping:    defaultMapping,
+			SampleType:        sampleType,
+			FnStore:           fnStore,
+		}))
 
 		uploadDatabaseNames = append(uploadDatabaseNames, database)
 	}