Back to

Package zinger

Latest Go to latest

The latest major version is .

Published: May 8, 2020 | License: BSD-3-Clause | Module:


func Run

func Run(port string, outputs []zbuf.Writer, zctx *resolver.Context) error

type Producer

type Producer struct {
	// For now we use SyncProducer to provide simplicity and an easy-to-understand
	// example.  Before putting into production or any perf testing, we need to
	// change this to async and probably refactor the data path to have a
	// seprate Producer thread for each http connection (and a shared schema
	// manager).  For now, any parallel connections share a single producer.
	// XXX note: change this to sarama.AsyncProducer
	Producer sarama.SyncProducer
	// contains filtered or unexported fields

func NewProducer

func NewProducer(servers []string, reg *registry.Connection, topic, namespace string) (*Producer, error)

func (*Producer) Write

func (p *Producer) Write(rec *zng.Record) error

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier