balance

package
v1.10.2 Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Consume

func Consume(consumerGroup sarama.ConsumerGroup, topic string, callback SpanCallback) func()

Types

type Sender

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

func NewSender

func NewSender(client sarama.Client, topic string) (*Sender, error)

func (*Sender) Send

func (s *Sender) Send(spans <-chan proxy.Span)

type SpanCallback

type SpanCallback func(proxy.Span)

Jump to

Keyboard shortcuts

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