outbox

Documentation

Index

• Constants
• Variables
• type EventEntity
  • func (ee *EventEntity) ToSerializedEvent() (*events.SerializedEvent, error)
• type Options
• type Outbox
  • func New(options *Options) (*Outbox, error)
  • func (o *Outbox) EmitEvent(ctx context.Context, tx *sqlx.Tx, event *events.EventSpec) (*events.EventID, error)

Constants

const DefaultOutboxTableName = "event_outbox"

Variables

var (
	ErrEventIdInvalid = errors.New("event id invalid")
)

Types

type EventEntity

type EventEntity struct {
	Id        sql.NullString `db:"id"`
	Topic     sql.NullString `db:"topic"`
	Payload   []byte         `db:"payload"`
	CreatedAt sql.NullTime   `db:"created_at"`
}

func (*EventEntity) ToSerializedEvent

func (ee *EventEntity) ToSerializedEvent() (*events.SerializedEvent, error)

type Options

type Options struct {
	TableName  string
	Serializer serialization.Serializer
}

type Outbox

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

func New

func New(options *Options) (*Outbox, error)

func (*Outbox) EmitEvent

func (o *Outbox) EmitEvent(ctx context.Context, tx *sqlx.Tx, event *events.EventSpec) (*events.EventID, error)