Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Log allows to set a logger to debug the library Log *logrus.Logger )
Functions ¶
This section is empty.
Types ¶
type PubSubPipeline ¶
type PubSubPipeline struct { CreateTopics bool CreateSubscription bool // contains filtered or unexported fields }
PubSubPipeline is the pipeline for use with Google Compute's PubSub
func NewPubSubPipeline ¶
func NewPubSubPipeline(projID *string, queue *string, resultQueue *string, subscriptionName *string, handler pipeline.Handler) *PubSubPipeline
NewPubSubPipeline creates a new Google PubSub based pipeline
func (*PubSubPipeline) AckMessage ¶
func (p *PubSubPipeline) AckMessage(message *pipeline.Message) error
AckMessage acknolwedges the messages recieved to makring it as processed.
func (*PubSubPipeline) PostMessage ¶
func (p *PubSubPipeline) PostMessage(outboundTopciName string, message *pipeline.Message) error
PostMessage allows posting a message to another queue, usually for further processing
func (*PubSubPipeline) Start ¶
func (p *PubSubPipeline) Start() error
Start starts the process of getting messages from pubsub
Click to show internal directories.
Click to hide internal directories.