delayedmessage

package

v0.5.0 Latest Latest Go to latest Published: May 3, 2022 License: MIT Imports: 7 Imported by: 0

Details

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

This section is empty.

This section is empty.

This section is empty.

type Repository struct{}

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

func (Repository) LoadNextMessage(
	ctx context.Context,
	ds persistence.DataStore,
) (endpoint.OutboundEnvelope, bool, error)

LoadNextMessage loads the next that is scheduled to be sent.

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

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

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

SaveMessage saves a message to be sent at a later time. If does NOT return an error if the message already exists in the repository.