riemann

Documentation

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