outbox

package

v0.0.0-...-0de0edb Latest Latest Go to latest Published: Nov 24, 2024 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Event interface {
	Kind() string
}

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

func New(
	cfg *config.Config,
	db *sqlx.DB,
	publisher Publisher,
	getter *trmsqlx.CtxGetter,
	logger logger.Logger,
) Manager

func (m *Manager) Consume(ctx context.Context) error

TOFIX: refactor function.

func (m *Manager) Publish(ctx context.Context, topic string, event Event) error

func (m *Manager) Start(ctx context.Context, lock *latch.CountDownLatch, options Options)

type Message struct {
	Kind    string
	Topic   string
	Payload []byte
}

type Options struct {
	Heartbeat time.Duration
}

type Publisher interface {
	Publish(ctx context.Context, event Message) error
}