outbox

Documentation

Overview

Package outbox provides MySQL-specific implementations of the interfaces in Ax's top-level "outbox" package.

Index

• type Repository
  • func (Repository) LoadOutbox(ctx context.Context, ds persistence.DataStore, id ax.MessageID) ([]endpoint.OutboundEnvelope, bool, error)
  • func (Repository) MarkAsSent(ctx context.Context, ptx persistence.Tx, env endpoint.OutboundEnvelope) error
  • func (Repository) SaveOutbox(ctx context.Context, ptx persistence.Tx, id ax.MessageID, ...) error

Types

type Repository

type Repository struct{}

Repository is a MySQL-backed implementation of Ax's outbox.Repository interface.

func (Repository) LoadOutbox

func (Repository) LoadOutbox(
	ctx context.Context,
	ds persistence.DataStore,
	id ax.MessageID,
) ([]endpoint.OutboundEnvelope, bool, error)

LoadOutbox loads the unsent outbound messages that were produced when the message identified by id was first processed.

func (Repository) MarkAsSent

func (Repository) MarkAsSent(
	ctx context.Context,
	ptx persistence.Tx,
	env endpoint.OutboundEnvelope,
) error

MarkAsSent marks a message as sent, removing it from the outbox.

func (Repository) SaveOutbox

func (Repository) SaveOutbox(
	ctx context.Context,
	ptx persistence.Tx,
	id ax.MessageID,
	envs []endpoint.OutboundEnvelope,
) error

SaveOutbox saves a set of unsent outbound messages that were produced when the message identified by id was processed.