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"`
}
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.