producer

Documentation

Overview

Package producer contains the Producer protocol handler. It sets up a producerServer at the given address to accept producers that want to connect.

Index

• func Make(listener AcceptCloser, channels channels.Producer, done <-chan struct{}, ...) (util.Runner, error)
• type AcceptCloser

Functions

func Make

func Make(listener AcceptCloser, channels channels.Producer, done <-chan struct{}, logger *zap.Logger) (util.Runner, error)

Make creates a new producer protocol handler

Types

type AcceptCloser

type AcceptCloser interface {
	Accept() (io.ReadWriteCloser, error)
	io.Closer
}

AcceptCloser wraps the generic Accept and Close methods. This interface allows plugging a custom transport