snapheka

package
v0.0.0-...-0724adc Latest Latest
Warning

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

Go to latest
Published: Nov 23, 2016 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SnapDfltHekaSeverity  = 6
	SnapDfltHekaMsgType   = "snap.heka"
	SnapDfltHekaMsgLogger = "snap.heka.logger"
)

Variables

View Source
var (
	SnapHekaSeverity  int32             = SnapDfltHekaSeverity
	SnapHekaMsgType                     = SnapDfltHekaMsgType
	SnapHekaMsgLogger                   = SnapDfltHekaMsgLogger
	MetricMappings    map[string]string = make(map[string]string)
)

Functions

func HandleMappingsFile

func HandleMappingsFile(mfile string)

HandleMappingsFile TODO protect initialization using mutex for potential race conditions

func Meta

func Meta() *plugin.PluginMeta

Meta returns a plugin meta data

func NewHekaPublisher

func NewHekaPublisher() *hekaPublisher

NewHekaPublisher returns an instance of the Heka publisher

Types

type SnapHekaClient

type SnapHekaClient struct {
	// contains filtered or unexported fields
}

SnapHekaClient defines the Heka connection scheme (e.g. tcp) and the connection address.

func NewSnapHekaClient

func NewSnapHekaClient(addr string, mfile string) (shc *SnapHekaClient, err error)

NewSnapHekaClient creates a new instance of Heka client

Jump to

Keyboard shortcuts

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