testing

package

v0.0.2 Latest Latest Go to latest Published: Sep 5, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func MockKafkaConsumerFunc(brokers []string) (sarama.Consumer, error)

type GinkgoTestReporter struct{}

func (g GinkgoTestReporter) Errorf(format string, args ...interface{})

func (g GinkgoTestReporter) Fatalf(format string, args ...interface{})

type TestReadWriteCloser struct {
	bytes.Buffer
}

TestReadWriteCloser implements a in-memory io.ReadWriteCloser and utils.ReaderSeekerCloser for testing files.

func (t *TestReadWriteCloser) Close() error

Close implements io.ReadWriteCloser.Close.

func (t *TestReadWriteCloser) Seek(offset int64, whence int) (int64, error)

Seek implements utils.ReaderSeekerCloser.Seek.

func (t *TestReadWriteCloser) Write(bytes []byte) (n int, err error)