Documentation
¶
Index ¶
- Constants
- func MapToKafkaMessage(toMap interface{}, topicName string) *sarama.ProducerMessage
- func MapToSignalEvent(toMap *models.SignalMessage) *models.SignalEvent
- func MapToSnsPublishMessage(snsInstance *sns.SNS, toMap interface{}, topicName string) (*sns.PublishInput, error)
- func MapToSqsSendMessage(sqsInstance *sqs.SQS, toMap interface{}, queueName string) (*sqs.SendMessageInput, error)
- type EventHub
- type KafkaEventHub
- type MessageHub
- type SnsEventHub
- type SqsMessageHub
Constants ¶
View Source
const ( Queue_engineeringsignal_input = "engineering_signal_collector_prd_signal_ingestion" Topic_engineeringsignal_raw = "engineering_signal_collector_prd_signal_received" Topic_engineeringsignal_standardized = "engineering_signal_collector_prd_signal_standardized" Topic_engineeringsignal_policymeasured = "engineering_signal_collector_prd_policy_measured" )
Variables ¶
This section is empty.
Functions ¶
func MapToKafkaMessage ¶
func MapToKafkaMessage(toMap interface{}, topicName string) *sarama.ProducerMessage
func MapToSignalEvent ¶
func MapToSignalEvent(toMap *models.SignalMessage) *models.SignalEvent
func MapToSnsPublishMessage ¶
func MapToSqsSendMessage ¶
Types ¶
type EventHub ¶
type EventHub interface {
Send(toSend *models.SignalEvent, target string) error
}
func NewEventHub ¶
func NewKafkaEventHub ¶
func NewSnsEventHub ¶
type KafkaEventHub ¶
type KafkaEventHub struct {
// contains filtered or unexported fields
}
func (*KafkaEventHub) Send ¶
func (hub *KafkaEventHub) Send(toSend *models.SignalEvent, target string) error
type MessageHub ¶
type MessageHub interface {
Send(toSend *models.SignalMessage, target string) error
Receive(receiver func(message *models.SignalMessage), target string) error
}
func NewMessageHub ¶
func NewMessageHub(appConfig *config.AppConfig) MessageHub
func NewSqsMessageHub ¶
func NewSqsMessageHub(appConfig *config.AppConfig) MessageHub
type SnsEventHub ¶
type SnsEventHub struct {
// contains filtered or unexported fields
}
func (*SnsEventHub) Send ¶
func (hub *SnsEventHub) Send(toSend *models.SignalEvent, target string) error
type SqsMessageHub ¶
type SqsMessageHub struct {
// contains filtered or unexported fields
}
func (*SqsMessageHub) Receive ¶
func (hub *SqsMessageHub) Receive(receiver func(message *models.SignalMessage), target string) error
func (*SqsMessageHub) Send ¶
func (hub *SqsMessageHub) Send(toSend *models.SignalMessage, target string) error
Source Files
Click to show internal directories.
Click to hide internal directories.