rtm

Documentation

Index

• type DirectProvider
  • func (provider DirectProvider) Init() error
  • func (provider DirectProvider) PublishMessage(mi *MessagingInfo) error
• type MessagingInfo
• type NotUseProvider
  • func (provider NotUseProvider) Init() error
  • func (provider NotUseProvider) PublishMessage(mi *MessagingInfo) error
• type NsqProvider
  • func (provider NsqProvider) Init() error
  • func (provider NsqProvider) PublishMessage(mi *MessagingInfo) error
• type Provider
  • func GetMessagingProvider() Provider

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