kafka

Documentation

Index

• Variables
• func NewSaramaReporter(address string, asyncFlag bool, logger *logrus.Entry) (r reporter.Reporter, err error)
• type KafkaGoReporter
  • func NewGoReporter(endpoint string) (*KafkaGoReporter, error)
  • func (r *KafkaGoReporter) Close() error
  • func (r *KafkaGoReporter) Send(s model.SpanModel, flag bool)
• type Producer

Variables

var (
	KafkazipkinTopicfail = errors.New("trace: Parse  kafkazipkin url fail Topic is nil")
	KafkazipkinHostfail  = errors.New("trace: Parse  kafkazipkin url fail Host is nil")
)

Functions

func NewSaramaReporter

func NewSaramaReporter(address string, asyncFlag bool, logger *logrus.Entry) (r reporter.Reporter, err error)

Types

type KafkaGoReporter

type KafkaGoReporter struct {
	Stoped bool
	// contains filtered or unexported fields
}

func NewGoReporter

func NewGoReporter(endpoint string) (*KafkaGoReporter, error)

func (*KafkaGoReporter) Close

func (r *KafkaGoReporter) Close() error

func (*KafkaGoReporter) Send

func (r *KafkaGoReporter) Send(s model.SpanModel, flag bool)

type Producer

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