Documentation ¶
Index ¶
Constants ¶
View Source
const PublisherKey = "transport.amqp.publisher"
View Source
const SubscriberKey = "transport.amqp.subscriber"
Variables ¶
This section is empty.
Functions ¶
func InitializePublisher ¶
func InitializePublisher() (*publisher, error)
func InitializeSubscriber ¶
func InitializeSubscriber() (*subscriber, error)
func PublisherName ¶
func SubscriberFileName ¶
SubscriberFileName assembles the target .go file into which the handler is going to be generated.
func SubscriberHandlerName ¶
SubscriberHandlerName returns the handler name of the subscriber based on the subscription topic The topic 'user.created' will be handled by the 'UserCreatedSubscriber'
Types ¶
type MySQLDatastore ¶
type MySQLDatastore struct {
// contains filtered or unexported fields
}
type SubscriberConfiguration ¶
type SubscriberConfiguration struct { RabbitMQ rabbitmq.Subscription HandlerName string `json:"handler_name" mapstructure:"handler_name"` Protobuf struct { GoModule string `json:"go_module" mapstructure:"go_module"` MessageName string `json:"message_name" mapstructure:"message_name"` } }
Click to show internal directories.
Click to hide internal directories.