processors

package

v0.1.8 Latest Latest Go to latest Published: Sep 2, 2018 License: Apache-2.0 Imports: 11 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

This section is empty.

This section is empty.

This section is empty.

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

EmailSender is a DataProcessor that sends email

func (e *EmailSender) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)

ProcessData implementation

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

HTTPRequestor is a DataProcessor that makes a HTTP request

func NewHTTPRequestor(method, url string) *HTTPRequestor

NewHTTPRequestor is the HTTPRequestor constructor

func (h *HTTPRequestor) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)

ProcessData implementation

type Logger struct{}

Logger is a processor that just logs and passes input to output

func (l *Logger) ProcessData(
	d models.Data,
	outputChan chan models.Data,
	killChan chan error,
)

ProcessData implementation

type Null struct{}

Null is a processor that just passes input to output

func (*Null) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)

ProcessData implementation

type SendgridEmailSender struct {
	FromName  string
	FromEmail string
	ToName    string
	ToEmail   string
	Subject   string
}

SendgridEmailSender is a DataProcessor that sends email via Sendgrid

func NewSendgridEmailSender(
	fromName, fromEmail, toName, toEmail, subject string,
) *SendgridEmailSender

NewSendgridEmailSender returns a new *SendgridEmailSender

func (s *SendgridEmailSender) ProcessData(
	d models.Data, outputChan chan models.Data,
	killChan chan error,
)

ProcessData implementation