output

Documentation

Overview

Package output console.go writes Polymur output to console.

Package output http.go writes datapoints to an HTTP destination.

Package output tcp.go writes datapoints to a TCP destination.

Index

• func Console(q <-chan []*string)
• func DestinationWriter(p *pool.Pool, dest pool.Destination)
• func HTTPWriter(config *HTTPWriterConfig, ready chan bool)
• func TCPWriter(p *pool.Pool, config *TCPWriterConfig, ready chan bool)
• type GwResp
• type HTTPWriterConfig
• type TCPWriterConfig

Functions

func Console

func Console(q <-chan []*string)

Console reads from the destination queue and prints the datapoints to console.

func DestinationWriter

func DestinationWriter(p *pool.Pool, dest pool.Destination)

DestinationWriter requests a connection. It dequeues from the connection outbound buffer and writes to the respective destination.

func HTTPWriter

func HTTPWriter(config *HTTPWriterConfig, ready chan bool)

HTTPWriter writes compressesed message batches over HTTPS to a polymur-gateway instance. Initial connection is OK'd by hitting the /ping path with a valid client API key registered with the polymur-gateway.

func TCPWriter

func TCPWriter(p *pool.Pool, config *TCPWriterConfig, ready chan bool)

TCPWriter reads datapoints from the outbound destination queue and writes it to the TCP destination.

Types

type GwResp

type GwResp struct {
	String string
	Code   int
}

GwResp captures the response string and numeric code from a polymur-gateway.

type HTTPWriterConfig

type HTTPWriterConfig struct {
	Cert          string
	APIKey        string
	Gateway       string
	IncomingQueue chan []*string
	Workers       int

	Verbose bool
	// contains filtered or unexported fields
}

HTTPWriterConfig holds HTTP output configuration.

type TCPWriterConfig

type TCPWriterConfig struct {
	Destinations  string
	Distribution  string
	IncomingQueue chan []*string
	QueueCap      int
}

TCPWriterConfig holds TCP output configuraiton.