Versions in this module Expand all Collapse all v0 v0.0.1 Aug 19, 2019 Changes in this version + func DeclareExchange(amqpUri string, exchange string, exchangeType string, queueName string) + type Sink struct + BindingKey string + Exchange string + Uri string + func (s *Sink) Close(ctx *goconnect.Context) error + func (s *Sink) Flush(ctx *goconnect.Context) error + func (s *Sink) InType() reflect.Type + func (s *Sink) Process(element *goconnect.Element, ctx *goconnect.Context) + type Source struct + BindingKey string + ConsumerTag string + Exchange string + PrefetchCount int + PrefetchSize int + QueueName string + Uri string + func (source *Source) Close(ctx *goconnect.Context) error + func (source *Source) Commit(checkpoint goconnect.Watermark, ctx *goconnect.Context) error + func (source *Source) OutType() reflect.Type + func (source *Source) Run(context *goconnect.Context)