Documentation
¶
Index ¶
- func FailOnError(err error, msg string)
- func GetLogLevel(level string) log.Level
- func GetLogLevelFromEnv() log.Level
- func GetQueue(ch *amqp.Channel, queueName string, durable bool) *amqp.Queue
- func ListenForCtrlC(service string)
- func PublishBytesToQueue(ch *amqp.Channel, q *amqp.Queue, bytes []byte)
- type AMQPConfig
- type ConvertTask
- type StickerizationMetric
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FailOnError ¶
func GetLogLevel ¶
func GetLogLevelFromEnv ¶
Returns a LogLevel type from Environment variable
Types ¶
type AMQPConfig ¶
type AMQPConfig struct {
Uri string // AMQP URI
Verbose bool // enable verbose output of message data
}
func GetAMQPConfig ¶
func GetAMQPConfig() *AMQPConfig
Click to show internal directories.
Click to hide internal directories.