pipeline

package module

v0.0.0-...-0d796e7 Latest Latest Go to latest Published: Oct 5, 2016 License: MIT Imports: 1 Imported by: 0

Details

Go based Pipeline wrappers that saves a lot of boilerplate code

This section is empty.

View Source

var (
	// Log allows attaching a logger to the library
	Log *logrus.Logger
)

This section is empty.

type Handler interface {
	Init(p Pipeline)
	Handle(message *Message) error
}

Handler provides a handle for various pipeling mechanism and settings

type Message struct {
	ID              string
	Data            []byte
	Attributes      map[string]string
	InternalMessage interface{}
}

Message abstract a pipeline message structure

type Pipeline interface {
	Start() error
	Stop()
	AckMessage(message *Message) error
	PostMessage(outboundTopciName string, message *Message) error
}

Pipeline interface to communicate with various implementations

Path	Synopsis
gcloud