transport

package
v3.0.0-...-0a92e08 Latest Latest
Warning

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

Go to latest
Published: Oct 24, 2022 License: BSD-3-Clause Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	KafkaTLS   *bool
	KafkaSASL  *bool
	KafkaTopic *string
	KafkaSrv   *string
	KafkaBrk   *string

	KafkaLogErrors *bool

	KafkaHashing *bool
	KafkaKeying  *string
	KafkaVersion *string
)

Functions

func HashProto

func HashProto(fields []string, flowMessage *flowmessage.FlowMessage) string

func ParseKafkaVersion

func ParseKafkaVersion(versionString string) (sarama.KafkaVersion, error)

ParseKafkaVersion is a pass through to sarama.ParseKafkaVersion to get a KafkaVersion struct by a string version that can be passed into SetKafkaVersion This function is here so that calling code need not import sarama to set KafkaVersion

func RegisterFlags

func RegisterFlags()

func SetKafkaVersion

func SetKafkaVersion(version sarama.KafkaVersion)

SetKafkaVersion sets the KafkaVersion that is used to set the log message format version

Types

type KafkaState

type KafkaState struct {
	FixedLengthProto bool
	// contains filtered or unexported fields
}

func StartKafkaProducer

func StartKafkaProducer(addrs []string, topic string, hashing bool, keying string, useTls bool, useSasl bool, logErrors bool, log utils.Logger) (*KafkaState, error)

func StartKafkaProducerFromArgs

func StartKafkaProducerFromArgs(log utils.Logger) (*KafkaState, error)

func (KafkaState) Publish

func (s KafkaState) Publish(msgs []*flowmessage.FlowMessage)

func (KafkaState) SendKafkaFlowMessage

func (s KafkaState) SendKafkaFlowMessage(flowMessage *flowmessage.FlowMessage)

Jump to

Keyboard shortcuts

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