producer

package

v0.0.0-...-485a10e Latest Latest Go to latest Published: May 26, 2022 License: Apache-2.0 Imports: 2 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/pingcap/ticdc

Links

Open Source Insights

Documentation ¶

Index ¶

type Producer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Producer ¶

type Producer interface {
	SendMessage(ctx context.Context, message *codec.MQMessage, partition int32) error
	SyncBroadcastMessage(ctx context.Context, message *codec.MQMessage) error
	Flush(ctx context.Context) error
	GetPartitionNum() int32
	Close() error
}

Producer is a interface of mq producer

Source Files ¶

View all Source files

mq_producer.go

Directories ¶

Path	Synopsis
kafka
pulsar Package pulsar provider a pulsar based mq Producer implementation.	Package pulsar provider a pulsar based mq Producer implementation.

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