riemann

package
v1.5.0-beta.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetRiemannClient

func GetRiemannClient(config RiemannConfig) (riemanngo.Client, error)

Receives a sink, connect the riemann client.

func SendData

func SendData(client riemanngo.Client, events []riemanngo.Event) error

Send Events to Riemann using the client from the sink.

Types

type RiemannConfig

type RiemannConfig struct {
	Host      string
	Ttl       float32
	State     string
	Tags      []string
	BatchSize int
}

Used to store the Riemann configuration specified in the Heapster cli

type RiemannSink

type RiemannSink struct {
	Client riemanngo.Client
	Config RiemannConfig
	sync.RWMutex
}

contains the riemann client, the riemann configuration, and a RWMutex

func CreateRiemannSink

func CreateRiemannSink(uri *url.URL) (*RiemannSink, error)

creates a Riemann sink. Returns a riemannSink

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL