producer

type MessageProducer ¶

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

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

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

type Producer ¶

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