package riemann

import "k8s.io/heapster/common/riemann"

Index ¶

• func GetRiemannClient(config RiemannConfig) (riemanngo.Client, error)
• func SendData(client riemanngo.Client, events []riemanngo.Event) error
• type RiemannConfig
• type RiemannSink
• func CreateRiemannSink(uri *url.URL) (*RiemannSink, error)

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

Source Files ¶

riemann.go