service

package

v0.0.0-...-28f90fc Latest Latest Go to latest Published: Sep 11, 2018 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/malike/go-kafka-alert

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CheckChannel(event db.Event, channel string) bool
func EventProcessorForChannel(events []db.Event)
func GetEventFromKafkaStream() ([]db.Event, error)
func NewKafkaConsumer() *kafka.Consumer
func ParseTemplateForMessage(event db.Event, channel string) (string, error)
func ProcessEvent(eventForMessage EventForMessage)
type EventForAPI
- func (event EventForAPI) ParseTemplate() ([]db.Message, error)
- func (event EventForAPI) SendMessage(message db.Message) db.MessageResponse
type EventForEmail
- func (event EventForEmail) ParseTemplate() ([]db.Message, error)
- func (event EventForEmail) SendMessage(message db.Message) db.MessageResponse
type EventForMessage
type EventForSMS
- func (event EventForSMS) ParseTemplate() ([]db.Message, error)
- func (event EventForSMS) SendMessage(message db.Message) db.MessageResponse

Constants ¶

This section is empty.

Variables ¶

View Source

var KafkaConsumer = NewKafkaConsumer()

KafkaConsumer instance

Functions ¶

func CheckChannel ¶

func CheckChannel(event db.Event, channel string) bool

CheckChannel : Validates Delivery Channel Support By Event

func EventProcessorForChannel ¶

func EventProcessorForChannel(events []db.Event)

EventProcessorForChannel : Event Processor For Channel

func GetEventFromKafkaStream ¶

func GetEventFromKafkaStream() ([]db.Event, error)

GetEventFromKafkaStream : Reads events from Kafka

func NewKafkaConsumer ¶

func NewKafkaConsumer() *kafka.Consumer

NewKafkaConsumer : New Kafka Consumer

func ParseTemplateForMessage ¶

func ParseTemplateForMessage(event db.Event, channel string) (string, error)

ParseTemplateForMessage : Parses Template

func ProcessEvent ¶

func ProcessEvent(eventForMessage EventForMessage)

ProcessEvent : Process Event

Types ¶

type EventForAPI ¶

type EventForAPI struct {
	TriggeredEvent db.Event
}

EventForAPI struct

func (EventForAPI) ParseTemplate ¶

func (event EventForAPI) ParseTemplate() ([]db.Message, error)

ParseTemplate for EventForAPI

func (EventForAPI) SendMessage ¶

func (event EventForAPI) SendMessage(message db.Message) db.MessageResponse

SendMessage for EventForAPI

type EventForEmail ¶

type EventForEmail struct {
	TriggeredEvent db.Event
}

EventForEmail : Email implementation for SMS

func (EventForEmail) ParseTemplate ¶

func (event EventForEmail) ParseTemplate() ([]db.Message, error)

ParseTemplate : Template Parser Implementation for Email

func (EventForEmail) SendMessage ¶

func (event EventForEmail) SendMessage(message db.Message) db.MessageResponse

SendMessage : Messaging Sending for Email

type EventForMessage ¶

type EventForMessage interface {
	ParseTemplate() ([]db.Message, error)

	SendMessage(message db.Message) db.MessageResponse
}

EventForMessage : Interface to be Implemented For Delivery Channels

type EventForSMS ¶

type EventForSMS struct {
	TriggeredEvent db.Event
}

EventForSMS : SMS implementation for SMS

func (EventForSMS) ParseTemplate ¶

func (event EventForSMS) ParseTemplate() ([]db.Message, error)

ParseTemplate : Parsing Template for SMS

func (EventForSMS) SendMessage ¶

func (event EventForSMS) SendMessage(message db.Message) db.MessageResponse

SendMessage : Message Sending for SMS

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL