producer

package

v1.1.1 Latest Latest Go to latest Published: Jan 17, 2022 License: MIT Imports: 6 Imported by: 0

Documentation ¶

Package producer defines functions for producing messages.

This section is empty.

This section is empty.

This section is empty.

type MessageProducer struct {
	// contains filtered or unexported fields
}

func NewMessageProducer(writer storage.MessageWriter, sentinelClient sentinelpb.SentinelClient) *MessageProducer

func (m *MessageProducer) Produce(ctx context.Context, message proto.Message) error

type Producer interface {
	Produce(ctx context.Context, message proto.Message) error
}

Producer defines an interface for a blocking operation of adding message to the configured pdcl topic