event

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 2, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL