messaging

Documentation

Index

• type Message
• type MessageConsumer
• type MessageFailedCallback
• type MessageProcessedCallback
• type MessageProducer

Types

type Message

type Message struct {
	Topic       string
	Key         string
	Payload     []byte
	Headers     map[string]string
	PublishTime time.Time
	EventTime   time.Time
}

type MessageConsumer

type MessageConsumer interface {
	Connect(topic string) error
	Consume(ctx context.Context) (
		Message,
		MessageProcessedCallback,
		MessageFailedCallback,
		error)
	Close()
}

type MessageFailedCallback

type MessageFailedCallback func()

type MessageProcessedCallback

type MessageProcessedCallback func()

type MessageProducer

type MessageProducer interface {
	Connect(topic string) error
	Produce(
		ctx context.Context,
		key string,
		data []byte) error
	Close()
}