Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DirectProvider ¶
type DirectProvider struct{}
func (DirectProvider) Init ¶
func (provider DirectProvider) Init() error
func (DirectProvider) PublishMessage ¶
func (provider DirectProvider) PublishMessage(mi *MessagingInfo) error
type MessagingInfo ¶
type MessagingInfo struct {
Message string
}
type NotUseProvider ¶
type NotUseProvider struct{}
func (NotUseProvider) Init ¶
func (provider NotUseProvider) Init() error
func (NotUseProvider) PublishMessage ¶
func (provider NotUseProvider) PublishMessage(mi *MessagingInfo) error
type NsqProvider ¶
type NsqProvider struct{}
func (NsqProvider) Init ¶
func (provider NsqProvider) Init() error
func (NsqProvider) PublishMessage ¶
func (provider NsqProvider) PublishMessage(mi *MessagingInfo) error
type Provider ¶
type Provider interface {
Init() error
PublishMessage(*MessagingInfo) error
}
func GetMessagingProvider ¶
func GetMessagingProvider() Provider
Source Files
Click to show internal directories.
Click to hide internal directories.