producer

package

v0.0.0-...-4a59535 Latest Latest Go to latest Published: Sep 19, 2024 License: MIT Imports: 3 Imported by: 0

Documentation ¶

Index ¶

type Producer
type ProducerBuilderFuc

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Producer ¶

type Producer interface {
	PublishMessage(ctx context.Context, message types.IMessage, meta metadata.Metadata) error
	PublishMessageWithTopicName(
		ctx context.Context,
		message types.IMessage,
		meta metadata.Metadata,
		topicOrExchangeName string,
	) error
	IsProduced(func(message types.IMessage))
}

type ProducerBuilderFuc ¶

type ProducerBuilderFuc[T interface{}] func(builder T)

Source Files ¶

View all Source files

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