zinger

Documentation

Index

• func Run(port string, outputs []zbuf.Writer, zctx *resolver.Context) error
• type Producer
  • func NewProducer(servers []string, reg *registry.Connection, topic, namespace string) (*Producer, error)
  • func (p *Producer) Write(rec *zng.Record) error

Functions

func Run

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

Types

type Producer

type Producer struct {
	sync.Mutex
	// 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