producer

Documentation

Overview

This program has been developed by students from the bachelor Computer Science at Utrecht University within the Software Project course. © Copyright Utrecht University (Department of Information and Computing Sciences)

Index

• type BrokerAliceProducer
  • func (ap *BrokerAliceProducer) PublishAnalyticsRequest(msg message.MessageFrontend, sessionID, userID, routingKey string)
  • func (ap *BrokerAliceProducer) PublishErrorMessage(err error, sessionID, routingKey string)
  • func (ap *BrokerAliceProducer) PublishFrontendMessage(msg message.MessageFrontend, sessionID, userID, routingKey string)
  • func (ap *BrokerAliceProducer) PublishFrontendSuccessMessage(typeVal string, value interface{}, sessionID, userID, routingKey string)
  • func (ap *BrokerAliceProducer) PublishMessageJsonHeaders(body *[]byte, routingKey string, headers *map[string]interface{}) BrokerProducerI
• type BrokerProducerI
  • func NewBrokerAliceProducer(producer alice.Producer, analyticsProducer alice.Producer, serviceName string) BrokerProducerI

Types

type BrokerAliceProducer

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

BrokerAliceProducer implements the producer interface

func (*BrokerAliceProducer) PublishAnalyticsRequest

func (ap *BrokerAliceProducer) PublishAnalyticsRequest(msg message.MessageFrontend, sessionID, userID, routingKey string)

PublishAnalyticsRequest will publish the message to the queue retrieved from the key value store, with the given sessionID, to the GSA

data: *[]byte, the data to publish
sessionID: *string, the ID of the session

func (*BrokerAliceProducer) PublishErrorMessage

func (ap *BrokerAliceProducer) PublishErrorMessage(err error, sessionID, routingKey string)

PublishErrorMessage publishes an error message

func (*BrokerAliceProducer) PublishFrontendMessage

func (ap *BrokerAliceProducer) PublishFrontendMessage(msg message.MessageFrontend, sessionID, userID, routingKey string)

PublishSchemaResult will publish the message to the queue retrieved from the key value store, with the given sessionID, to the UI

data: *[]byte, the data to publish
sessionID: *string, the ID of the session

func (*BrokerAliceProducer) PublishFrontendSuccessMessage

func (ap *BrokerAliceProducer) PublishFrontendSuccessMessage(typeVal string, value interface{}, sessionID, userID, routingKey string)

func (*BrokerAliceProducer) PublishMessageJsonHeaders

func (ap *BrokerAliceProducer) PublishMessageJsonHeaders(body *[]byte, routingKey string, headers *map[string]interface{}) BrokerProducerI

PublishMessage publishes a message with the specified routing key

body: *[]byte, the message to send, most likely a marshalled JSON object
routingKey: string, the key by which this message will be routed on the exchange
headers: *map[string]interface{}, the headers for this message, containing things like userID and sessionID

type BrokerProducerI

type BrokerProducerI interface {
	PublishMessageJsonHeaders(body *[]byte, routingKey string, headers *map[string]interface{}) BrokerProducerI
	PublishErrorMessage(err error, sessionID, routingKey string)
	PublishAnalyticsRequest(msg message.MessageFrontend, sessionID, userID, routingKey string)
	PublishFrontendMessage(msg message.MessageFrontend, sessionID, userID, routingKey string)
	PublishFrontendSuccessMessage(typeVal string, value interface{}, sessionID, userID, routingKey string)
}

A Producer belongs to a broker and publishes messages to a queue

func NewBrokerAliceProducer

func NewBrokerAliceProducer(producer alice.Producer, analyticsProducer alice.Producer, serviceName string) BrokerProducerI