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 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
Click to show internal directories.
Click to hide internal directories.