event

Documentation

Overview

Package event contains details related to event defined as Outbox Row in Datastore.

Index

• type Metadata
  • func (m *Metadata) Scan(value interface{}) error
  • func (m *Metadata) Value() (driver.Value, error)
• type OutboxRow
• type RabbitCfg
• type SQSCfg

Types

type Metadata

type Metadata struct {
	RabbitCfg *RabbitCfg `json:"rabbitCfg,omitempty"`
	SQSCfg    *SQSCfg    `json:"sqsCfg,omitempty"`
}

Metadata defines the various configuration for Messaging system.

func (*Metadata) Scan

func (m *Metadata) Scan(value interface{}) error

Scan overrides the behaviour to parse Metadata.

func (*Metadata) Value

func (m *Metadata) Value() (driver.Value, error)

Value overrides the behaviour to covert Metadata to driver.Value.

type OutboxRow

type OutboxRow struct {
	OutboxID int
	Metadata Metadata
	Payload  []byte
	Status   sql.NullInt64
}

OutboxRow represents the outbox rows in DB

type RabbitCfg

type RabbitCfg struct {
	Exchange   string          `json:"exchange"`
	RoutingKey string          `json:"routingKey"`
	Mandatory  bool            `json:"mandatory"`
	Immediate  bool            `json:"immediate"`
	Publishing amqp.Publishing `json:"publishing"`
}

RabbitCfg defines all configuration required to publish to given Exchange.

type SQSCfg

type SQSCfg struct {
	*sqs.SendMessageInput
}

SQSCfg defines all configuration required to publish to SQS queue.