Fix senders.NewSender() for direct ingestion.

This commit fixes Issue #84.

senders/client_factory.go

@@ -67,15 +67,26 @@ func CreateConfig(wfURL string, setters ...Option) (*configuration, error) {
 		return nil, err
 	}
 
-	if !strings.HasPrefix(strings.ToLower(u.Scheme), "http") {
-		return nil, fmt.Errorf("invalid scheme '%s' in '%s', only 'http' is supported", u.Scheme, u)
-	}
-
 	if len(u.User.String()) > 0 {
 		cfg.Token = u.User.String()
 		u.User = nil
 	}
 
+	switch strings.ToLower(u.Scheme) {
+	case "http":
+		if cfg.Token != "" {
+			cfg.MetricsPort = 80
+			cfg.TracesPort = 80
+		}
+	case "https":
+		if cfg.Token != "" {
+			cfg.MetricsPort = 443
+			cfg.TracesPort = 443
+		}
+	default:
+		return nil, fmt.Errorf("invalid scheme '%s' in '%s', only 'http' is supported", u.Scheme, u)
+	}
+
 	if u.Port() != "" {
 		port, err := strconv.Atoi(u.Port())
 		if err != nil {

senders/client_factory_test.go

@@ -24,6 +24,27 @@ func TestScheme(t *testing.T) {
 	require.Error(t, err)
 }
 
+func TestDefaultPortsProxy(t *testing.T) {
+	cfg, err := senders.CreateConfig("http://localhost")
+	require.NoError(t, err)
+	assert.Equal(t, 2878, cfg.MetricsPort)
+	assert.Equal(t, 30001, cfg.TracesPort)
+}
+
+func TestDefaultPortsDIHttp(t *testing.T) {
+	cfg, err := senders.CreateConfig("http://11111111-2222-3333-4444-555555555555@localhost")
+	require.NoError(t, err)
+	assert.Equal(t, 80, cfg.MetricsPort)
+	assert.Equal(t, 80, cfg.TracesPort)
+}
+
+func TestDefaultPortsDIHttps(t *testing.T) {
+	cfg, err := senders.CreateConfig("https://11111111-2222-3333-4444-555555555555@localhost")
+	require.NoError(t, err)
+	assert.Equal(t, 443, cfg.MetricsPort)
+	assert.Equal(t, 443, cfg.TracesPort)
+}
+
 func TestPortExtractedFromURL(t *testing.T) {
 	cfg, err := senders.CreateConfig("http://localhost:1234")
 	require.NoError(t, err)