msg

Documentation

Index

• Constants
• func InitMessaging(cfg *core.Messaging)
• func PublishToExchange(exchange string, message any) error
• func ReceiveMessages(queue string, handler func(m *Message) bool)
• func SendMessage(exchange string, source string, msgType int, entity any) error
• type Message

Constants

const (
	TypeCreate     = 1
	TypeUpdate     = 2
	TypeDelete     = 3
	TypeActivate   = 4
	TypeDeactivate = 5
	TypeNewJob     = 6

	SourceTradingSystem  = "trading-system"
	SourceDataProduct    = "data-product"
	SourceBrokerProduct  = "broker-product"
	SourceConnection     = "connection"
	SourcePortfolio      = "portfolio"
	SourceTradingSession = "trading-session"

	SourceUploadJob = "upload-job"

	SourceTrade = "trade"
)

const ExCollector = "bf.collector"

const ExInventory = "bf.inventory"

const ExRuntime = "bf.runtime"

const QuCollectorToIngester = "bf.collector:ingester"

const QuInventoryToCollector = "bf.inventory:collector"

const QuInventoryToPortfolio = "bf.inventory:portfolio"

const QuRuntimeToPortfolio = "bf.runtime:portfolio"

Functions

func InitMessaging

func InitMessaging(cfg *core.Messaging)

func PublishToExchange

func PublishToExchange(exchange string, message any) error

func ReceiveMessages

func ReceiveMessages(queue string, handler func(m *Message) bool)

func SendMessage

func SendMessage(exchange string, source string, msgType int, entity any) error

Types

type Message

type Message struct {
	Source string
	Type   int
	Entity []byte
}