testhelpers

package

v0.12.0 Latest Latest Go to latest Published: Feb 22, 2017 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/maxthomas/kafka-pixy

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func InitLogging(c *C)
func NewTestProxyCfg(clientID string) *config.Proxy
func NewUDSHTTPClient(unixSockAddr string) *http.Client

Constants ¶

View Source

const (
	// Use Shopify/sarama Vagrant box (copied over from https://github.com/Shopify/sarama/blob/master/functional_test.go#L18)
	VagrantKafkaPeers     = "192.168.100.67:9091,192.168.100.67:9092,192.168.100.67:9093,192.168.100.67:9094,192.168.100.67:9095"
	VagrantZookeeperPeers = "192.168.100.67:2181,192.168.100.67:2182,192.168.100.67:2183,192.168.100.67:2184,192.168.100.67:2185"
)

Variables ¶

View Source

var (
	KafkaPeers     []string
	ZookeeperPeers []string
)

Functions ¶

func InitLogging ¶

func InitLogging(c *C)

InitLogging initializes both internal and 3rd party loggers to output logs using the test context object's `Log` function.

func NewTestProxyCfg ¶ added in v0.12.0

func NewTestProxyCfg(clientID string) *config.Proxy

func NewUDSHTTPClient ¶

func NewUDSHTTPClient(unixSockAddr string) *http.Client

NewUDSHTTPClient creates an HTTP client that always connects to the specified unix domain socket ignoring the host part of requested HTTP URLs.

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
kafkahelper

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