source

type Base ¶

type Base struct {
	config.Source

	Listener *listener.Listener

	Log logger.Logger
	// contains filtered or unexported fields
}

Helper struct that performs common functions that most if not all Sources will use

type Beanstalkd ¶

type Beanstalkd struct {
	Base
}

Listens to an AWS SQS. When a message is placed onto this queue it is converted into a Event and assessed by the listeners. The message must be a JSON string representing an Event

func (this *Beanstalkd) Listen(wg sync.WaitGroup)

type Http ¶

type Http struct {
	Base
}

Http source listens to a specified http port. To create an event send a "POST" request to "/event/" with the json event object as the body of the request.

curl -X POST -d '{"event":"test","message":{"test": 1}' http://localhost:8080/event/

func (s *Http) Listen(wg sync.WaitGroup)

type Source ¶

type Source interface {
	Listen(wg sync.WaitGroup)
	// contains filtered or unexported methods
}

Interface that all sources should satisfy

func BuildFromConfig(conf config.Source, rootList *listener.Listener, log logger.Logger) Source

type Sqs ¶

type Sqs struct {
	Base
	// contains filtered or unexported fields
}

Listens to an AWS SQS. When a message is placed onto this queue it is converted into a Event and assessed by the listeners. The message must be a JSON string representing an Event

func (s *Sqs) Listen(wg sync.WaitGroup)