senders

package main

import (
	wavefront "github.com/wavefronthq/wavefront-sdk-go/senders"
)

func main() {
	// For Direct Ingestion endpoints, by default all data is sent to port 80
	// or port 443 for unencrypted or encrypted connections, respectively.

	// Direct Ingestion requires authentication.

	// Wavefront API tokens:
	// Set your API token using the APIToken Option
	// 11111111-2222-3333-4444-555555555555 is your API token with direct ingestion permission.
	sender, err := wavefront.NewSender("https://surf.wavefront.com",
		wavefront.APIToken("11111111-2222-3333-4444-555555555555"))

	// CSP API tokens:
	// Set your API token using the CSPAPIToken Option
	// <MY-CSP-TOKEN> is your CSP API token with the aoa:directDataIngestion scope.
	sender, err = wavefront.NewSender("https://surf.wavefront.com",
		wavefront.CSPAPIToken("<MY-CSP-TOKEN>"))

	// CSP Client Credentials:
	// Set your API token using the CSPClientCredentials Option
	sender, err = wavefront.NewSender("https://surf.wavefront.com",
		wavefront.CSPClientCredentials("<MY-CLIENT_ID>", "<MY-CLIENT_SECRET>"))

	// CSP Authentication strategies also support additional options
	sender, err = wavefront.NewSender("https://surf.wavefront.com",
		wavefront.CSPClientCredentials(
			"<MY-CLIENT_ID>",
			"<MY-CLIENT_SECRET>",
			wavefront.CSPBaseURL("<MY-NONSTANDARD-CSP-HOST>"),
			wavefront.CSPOrgID("<MY-ORG-ID>"),
		))

	sender, err = wavefront.NewSender("https://surf.wavefront.com",
		wavefront.CSPAPIToken(
			"<MY-CSP-TOKEN>",
			wavefront.CSPBaseURL("<MY-NONSTANDARD-CSP-HOST>"),
		))

	if err != nil {
		// handle error
	}
	err = sender.Flush()
	if err != nil {
		// handle error
	}
	sender.Close()
}

Output:

package main

import (
	"crypto/tls"
	"net/http"
	"time"

	wavefront "github.com/wavefronthq/wavefront-sdk-go/senders"
)

func main() {
	// NewSender accepts optional arguments. Use these if you need to set non-default ports for your Wavefront Proxy, tune batching parameters, or set tags for internal SDK metrics.
	sender, err := wavefront.NewSender(
		"http://localhost",
		wavefront.BatchSize(20000),                // Send batches of 20,000.
		wavefront.FlushInterval(5*time.Second),    // Flush every 5 seconds.
		wavefront.MetricsPort(4321),               // Use port 4321 for metrics.
		wavefront.TracesPort(40001),               // Use port 40001 for traces.
		wavefront.Timeout(15),                     // Set an HTTP timeout in seconds (default is 10s)
		wavefront.SendInternalMetrics(false),      // Don't send internal ~sdk.go.* metrics
		wavefront.TLSConfigOptions(&tls.Config{}), // Set TLS config options.
		wavefront.HTTPClient(&http.Client{
			Timeout: 15 * time.Second,
			Transport: &http.Transport{
				TLSClientConfig: &tls.Config{},
				IdleConnTimeout: 4 * time.Second,
			},
		}), // Provide a fully configured http.Client
	)

	if err != nil {
		// handle error
	}
	sender.Close()
}

Output:

package main

import (
	wavefront "github.com/wavefronthq/wavefront-sdk-go/senders"
)

func main() {
	// For Proxy endpoints, by default metrics and histograms are sent to
	// port 2878 and traces are sent to port 30001.
	sender, err := wavefront.NewSender("http://localhost")

	// To use non-default ports, specify the metric/histogram port in the url,
	// and set the port for traces using the TracesPort Option.
	sender, err = wavefront.NewSender("https://localhost:4443",
		wavefront.TracesPort(55555))

	if err != nil {
		// handle error
	}

	err = sender.Flush()
	if err != nil {
		// handle error
	}
	sender.Close()
}

Output: