bundle

Documentation

Index

• Constants
• func InitializePublisher() (*publisher, error)
• func InitializeSubscriber() (*subscriber, error)
• func PublisherName(topic string) string
• func SubscriberFileName(topic string) string
• func SubscriberHandlerName(topic string) string
• type MySQLDatastore
• type SubscriberConfiguration

Constants

const PublisherKey = "transport.amqp.publisher"

const SubscriberKey = "transport.amqp.subscriber"

Functions

func InitializePublisher

func InitializePublisher() (*publisher, error)

func InitializeSubscriber

func InitializeSubscriber() (*subscriber, error)

func PublisherName

func PublisherName(topic string) string

func SubscriberFileName

func SubscriberFileName(topic string) string

SubscriberFileName assembles the target .go file into which the handler is going to be generated.

func SubscriberHandlerName

func SubscriberHandlerName(topic string) string

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"`
	}
}