inmemclient

Documentation

Index

• func NewConsumer(options ...streamconfig.Option) (stream.Consumer, error)
• func NewProducer(options ...streamconfig.Option) (stream.Producer, error)
• func TestConsumer(tb testing.TB, s stream.Store, options ...streamconfig.Option) (stream.Consumer, func())
• func TestProducer(tb testing.TB, s stream.Store, options ...streamconfig.Option) (stream.Producer, func())

Functions

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.