framer

package

v2.0.0+incompatible Latest Latest Go to latest Published: Nov 19, 2018 License: Apache-2.0 Imports: 9 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/terrextech/go-agg-framer

Links

Open Source Insights

Documentation ¶

Index ¶

type Framer
- func New(ctx context.Context, prodConfig *kafka.ProducerConfig, ...) (*Framer, error)
type TopicConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Framer ¶

type Framer struct {
	Command  chan<- *model.Command
	Document chan<- *model.Document
	Event    chan<- *model.Event
}

Framer provides convenience channels for producing messages.

func New ¶

func New(
	ctx context.Context,
	prodConfig *kafka.ProducerConfig,
	topicConfig *TopicConfig,
) (*Framer, error)

New creates a new Framer instance.

type TopicConfig ¶

type TopicConfig struct {
	CommandTopic  string
	DocumentTopic string
	EventTopic    string
}

TopicConfig is the configuration for topics on which respective entities should be produced. In case of Command and Document, this is the default topic if one is not set in Command or Document.

Source Files ¶

View all Source files

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