Close closes the Rabbit connection. All resources associated with the connection, including channels, will also be closed.

DeclareTopicExchange declares an exchange of type 'topic'.

GetConn established a Rabbit connection.

New returns configuration variables from the environment. These are passed by Docker from the .env file.

StartConsumer consumes messages from a Rabbit queue with a specified routing key and passes them to a supplied handler for processing. The queue is cr

FormatDuration formats duration from timestamp to now. Based in part on the javascript library date-fns: https://github.com/date-fns/date-fns/blob/mas

GetCache gets cached data from Redis.

Publish publishes a message to a Rabbit exchange using the main channel. For use in the main go routine.

PublishInChannel publishes a message to a Rabbit exchange using a provided channel. For use in go routines.

handleAPICache handles API calls for cached messages.

insertToDB inserts a Rabbit message into a Postgres database.

updateRedis updates Redis with a new Rabbit message.

GetCacheJSON marshals cached data into JSON, calls GetCache to get the Cache struct.

StartConsumerTemp consumes messages with a specified routing key and passes them to a supplied handler for processing. Creates a separate channel and

handleMessages handles the messages page.

handleNotFound handles 404

handlePublishRabbit publishes a Websocket message to a Rabbit exchange with the the back-end and database routing keys. A Websocket reader only passes

handleWebsocket starts two message readers (consumers), one consuming a Rabbit queue and another reading from a Websocket connection. Each consumer re

handleWebsocketConn passes a Rabbit connection to the Websocket handler.

handleWriteWebsocket writes a Rabbit message to Websocket. A Rabbit consumer only passes a message. So, a Websocket connection is additionally passed

publishInput reads user input, marshals to json, and publishes to a Rabbit exchange with the front-end and database routing keys.

testArguments produces arguments for the function being tested

testArguments produces arguments for the function being tested

testUpdateRedis inserts a marshalled message into mock redis

StartReader reads messages from a Websocket connection and passes them to a supplied handler for processing.

TestAPICache tests the cache API

TestFormatDuration tests duration formatting

TestInsertToDB tests a message insertion into a database

TestUpdateRedis tests a message insertion into cache

handleHome handles the home page.

printMessages prints messages to stdout.