kafkabox

type EmitterOptions struct {
	Outbox            OutboxStore
	ContextPropagator hexa.ContextPropagator
	Encoder           hevent.Encoder
}

type Header struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type MessageConverter interface {
	EventToOutboxMessage(context.Context, *hevent.Event) (*OutboxMessage, error)
}

type OutboxMessage struct {
	ID        string    `bson:"id" json:"id"`
	Topic     string    `bson:"topic" json:"topic"`
	Key       string    `bson:"key" json:"key"`
	Value     string    `bson:"value" json:"value"`
	Headers   []Header  `bson:"headers" json:"headers"`
	EmittedAt time.Time `bson:"emitted_at" json:"emitted_at"`
}

type OutboxStore interface {
	hexa.Shutdownable

	Migrate() error // do migration if needed.
	Create(c context.Context, msg *OutboxMessage) error
	Ping(c context.Context) error
}