Back to godoc.org

Package inmemclient

v3.0.1
Latest Go to latest

The highest tagged major version is v3.

Published: Sep 5, 2019 | License: ISC | Module: github.com/blendle/go-streamprocessor/v3

Index

func NewConsumer

func NewConsumer(options ...streamconfig.Option) (stream.Consumer, error)

NewConsumer returns a new inmem consumer.

func NewProducer

func NewProducer(options ...streamconfig.Option) (stream.Producer, error)

NewProducer returns a new inmem producer.

func TestConsumer

func TestConsumer(tb testing.TB, s stream.Store, options ...streamconfig.Option) (stream.Consumer, func())

TestConsumer returns a new inmem consumer to be used in test cases. It also returns a function that should be deferred to clean up resources.

You can either pass a pre-configured inmemstore to this function as its second argument, or pass in `nil`, to have one be instantiated for you.

You can optionally provide extra options to be used when instantiating the consumer.

func TestProducer

func TestProducer(tb testing.TB, s stream.Store, options ...streamconfig.Option) (stream.Producer, func())

TestProducer returns a new inmem producer to be used in test cases. It also returns a function that should be deferred to clean up resources.

You can either pass a pre-configured inmemstore to this function as its second argument, or pass in `nil`, to have one be instantiated for you.

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

Jump to identifier

Keyboard shortcuts

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