README
¶
Go2sky with kafka reporter
Installation
go get -u github.com/SkyAPM/go2sky-plugins/kafkareporter
Usage
r, err := kafkareporter.New([]string{"localhost:9092"})
if err != nil {
log.Fatalf("new kafka reporter error %v \n", err)
}
defer r.Close()
tracer, err := go2sky.NewTracer("example", go2sky.WithReporter(r))
Documentation
¶
Overview ¶
Package kafkareporter is a plugin that can be one kafka reporter as go2sky.Reporter.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Option ¶
type Option func(r *kafkaReporter)
Option allows for functional options to adjust behaviour of a kafka reporter to be created by New
func WithCheckInterval ¶
WithCheckInterval setup service and endpoint registry check interval
func WithConfig ¶
WithConfig setup sarama.Config for kafka reporter
func WithInstanceProps ¶
WithInstanceProps setup service instance properties eg: org=SkyAPM
func WithLogger ¶
WithLogger setup logger for kafka reporter
func WithTopicManagement ¶
WithTopicManagement setup service management topic
func WithTopicSegment ¶
WithTopicSegment setup service segment topic
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.