The highest tagged major version is v3.

streamclient

package

v2.4.0+incompatible Latest Latest Go to latest Published: Jul 9, 2019 License: ISC Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/blendle/go-streamprocessor

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewConsumer(options ...streamconfig.Option) (stream.Consumer, error)
func NewProducer(options ...streamconfig.Option) (stream.Producer, error)
func TestMessageFromConsumer(tb testing.TB, consumer stream.Consumer) stream.Message
type Type
- func (t Type) String() string

Constants ¶

View Source

const (
	// Unknown represents an unknown streamclient implementation.
	Unknown Type = "unknown"

	// Inmem represents the in-memory streamclient implementation.
	Inmem = "inmem"

	// Kafka represents the Kafka streamclient implementation.
	Kafka = "kafka"

	// Standardstream represents the Standardstream streamclient implementation.
	Standardstream = "standardstream"
)

Variables ¶

View Source

var ErrUnknownConsumerClient = errors.New("unable to determine required consumer streamclient")

ErrUnknownConsumerClient is returned when the desired stream client cannot be inferred from the environment context.

View Source

var ErrUnknownProducerClient = errors.New("unable to determine required producer streamclient")

ErrUnknownProducerClient is returned when the desired stream client cannot be inferred from the environment context.

Functions ¶

func NewConsumer ¶

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

NewConsumer returns a new streamclient consumer, based on the context from which this function is called.

func NewProducer ¶

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

NewProducer returns a new streamclient producer, based on the context from which this function is called.

func TestMessageFromConsumer ¶

func TestMessageFromConsumer(tb testing.TB, consumer stream.Consumer) stream.Message

TestMessageFromConsumer returns a single message, consumed from the provided consumer. It has a built-in timeout mechanism to prevent the test from getting stuck.

Types ¶

type Type ¶

type Type string

Type represents the streamclient implementation type.

func (Type) String ¶

func (t Type) String() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
inmemclient
kafkaclient
standardstreamclient

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