pubsub

package

v0.0.0-...-f8e9dc7 Latest Latest Go to latest Published: Dec 25, 2024 License: BSD-3-Clause Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func AsKafkaMessage(msg Message) kafka.Message

type Handler func(ctx context.Context, msg Message) error

type KafkaMessage struct {
	kafka.Message
}

func NewMessage(msg kafka.Message) *KafkaMessage

func (k KafkaMessage) Key() []byte

func (k KafkaMessage) Value() []byte

type Message interface {
	Key() []byte
	Value() []byte
}

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

func NewPublisher(w *kafka.Writer) *Publisher

func (p *Publisher) Publish(ctx context.Context, msgs ...Message) error

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

func NewSubscriber(r *kafka.Reader) *Subscriber

func (s *Subscriber) Receive(ctx context.Context, h Handler) (func(), <-chan error)

Receive handles the message received from the message queue. Returning an error will not commit the offset.

Path	Synopsis
examples