Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageHub ¶
type MessageHub interface {
Send(toSend interface{}, target string) error
SendBulk(toSend []interface{}, target string) error
}
func NewMessageHub ¶
func NewMessageHub(config configuration.ConfigurationService) MessageHub
type SqsMessageHub ¶
type SqsMessageHub struct {
// contains filtered or unexported fields
}
func (*SqsMessageHub) Send ¶
func (hub *SqsMessageHub) Send(toSend interface{}, target string) error
func (*SqsMessageHub) SendBulk ¶
func (hub *SqsMessageHub) SendBulk(toSend []interface{}, target string) error
Source Files
Click to show internal directories.
Click to hide internal directories.