messaging

Documentation

Index

• type GcpPubSubProvider
  • func (provider GcpPubSubProvider) Init() error
  • func (provider GcpPubSubProvider) PublishMessage(messagingInfo *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 GcpPubSubProvider

type GcpPubSubProvider struct {
	// contains filtered or unexported fields
}

func (GcpPubSubProvider) Init

func (provider GcpPubSubProvider) Init() error

func (GcpPubSubProvider) PublishMessage

func (provider GcpPubSubProvider) PublishMessage(messagingInfo *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