Documentation
¶
Index ¶
- func GetTemplateFuncMaps() template.FuncMap
- func NewAzBusListener() (core.QueueListener, error)
- func NewPubSubListener() (core.QueueListener, error)
- type AzBusListener
- type EmailProvider
- type ListenerFactory
- type MSTeamsMessage
- type MSTeamsProvider
- type ProviderFactory
- type PubSubListener
- type SNSListener
- type SQSListener
- type SlackProvider
- type TelegramMessage
- type TelegramProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetTemplateFuncMaps ¶
func NewAzBusListener ¶
func NewAzBusListener() (core.QueueListener, error)
func NewPubSubListener ¶
func NewPubSubListener() (core.QueueListener, error)
Types ¶
type AzBusListener ¶
type AzBusListener struct{}
func (*AzBusListener) StartListening ¶
func (l *AzBusListener) StartListening(handler func(content map[string]interface{}) error) error
type EmailProvider ¶
type EmailProvider struct {
// contains filtered or unexported fields
}
func NewEmailProvider ¶
func NewEmailProvider(cfg config.EmailConfig) *EmailProvider
type ListenerFactory ¶
type ListenerFactory struct {
// contains filtered or unexported fields
}
Listener
func NewListenerFactory ¶
func NewListenerFactory(cfg *config.Config) *ListenerFactory
func (*ListenerFactory) CreateListeners ¶
func (f *ListenerFactory) CreateListeners() ([]core.QueueListener, error)
type MSTeamsMessage ¶
type MSTeamsMessage struct {
Text string `json:"text"`
}
type MSTeamsProvider ¶
type MSTeamsProvider struct {
// contains filtered or unexported fields
}
func NewMSTeamsProvider ¶
func NewMSTeamsProvider(cfg config.MSTeamsConfig) *MSTeamsProvider
type ProviderFactory ¶
type ProviderFactory struct {
// contains filtered or unexported fields
}
Alert Provider
func NewProviderFactory ¶
func NewProviderFactory(cfg *config.Config) *ProviderFactory
func (*ProviderFactory) CreateProviders ¶
func (f *ProviderFactory) CreateProviders() ([]core.AlertProvider, error)
type PubSubListener ¶
type PubSubListener struct{}
func (*PubSubListener) StartListening ¶
func (l *PubSubListener) StartListening(handler func(content map[string]interface{}) error) error
type SNSListener ¶
type SNSListener struct {
// contains filtered or unexported fields
}
func NewSNSListener ¶
func NewSNSListener(cfg c.SNSConfig, endpointURL string, autoCreateSubscription bool) *SNSListener
func (*SNSListener) StartListening ¶
func (l *SNSListener) StartListening(handler func(content *map[string]interface{}) error) error
type SQSListener ¶
type SQSListener struct {
QueueURL string
}
func NewSQSListener ¶
func NewSQSListener(cfg config.SQSConfig) *SQSListener
func (*SQSListener) StartListening ¶
func (s *SQSListener) StartListening(handler func(content *map[string]interface{}) error) error
type SlackProvider ¶
type SlackProvider struct {
// contains filtered or unexported fields
}
func NewSlackProvider ¶
func NewSlackProvider(cfg config.SlackConfig) *SlackProvider
type TelegramMessage ¶
type TelegramProvider ¶
type TelegramProvider struct {
// contains filtered or unexported fields
}
func NewTelegramProvider ¶
func NewTelegramProvider(cfg config.TelegramConfig) *TelegramProvider
Click to show internal directories.
Click to hide internal directories.