Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoadConfiguration ¶
func LoadConfiguration(config *util.ViperProxy, prefix string)
Types ¶
type MessageQueue ¶
type MessageQueue interface { // GetName gets the name to locate the configuration in filer.toml file GetName() string // Initialize initializes the file store Initialize(configuration util.Configuration, prefix string) error SendMessage(key string, message proto.Message) error }
var ( MessageQueues []MessageQueue Queue MessageQueue )
Directories ¶
Path | Synopsis |
---|---|
Package gocdk_pub_sub is for Azure Service Bus and RabbitMQ.
|
Package gocdk_pub_sub is for Azure Service Bus and RabbitMQ. |
Click to show internal directories.
Click to hide internal directories.