processors

Documentation

Index

• type EmailSender
  • func (e *EmailSender) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)
• type HTTPRequestor
  • func NewHTTPRequestor(method, url string) *HTTPRequestor
  • func (h *HTTPRequestor) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)
• type Logger
  • func (l *Logger) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)
• type Null
  • func (*Null) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)
• type SendgridEmailSender
  • func NewSendgridEmailSender(fromName, fromEmail, toName, toEmail, subject string) *SendgridEmailSender
  • func (s *SendgridEmailSender) ProcessData(d models.Data, outputChan chan models.Data, killChan chan error)

Types

type EmailSender

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

EmailSender is a DataProcessor that sends email

func (*EmailSender) ProcessData

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

ProcessData implementation

type HTTPRequestor

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

HTTPRequestor is a DataProcessor that makes a HTTP request

func NewHTTPRequestor

func NewHTTPRequestor(method, url string) *HTTPRequestor

NewHTTPRequestor is the HTTPRequestor constructor

func (*HTTPRequestor) ProcessData

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

ProcessData implementation

type Logger

type Logger struct{}

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

func (*Logger) ProcessData

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

ProcessData implementation

type Null

type Null struct{}

Null is a processor that just passes input to output

func (*Null) ProcessData

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

ProcessData implementation

type SendgridEmailSender

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

SendgridEmailSender is a DataProcessor that sends email via Sendgrid

func NewSendgridEmailSender

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

NewSendgridEmailSender returns a new *SendgridEmailSender

func (*SendgridEmailSender) ProcessData

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

ProcessData implementation