amqp09

Documentation

Index

• func DeclareExchange(amqpUri string, exchange string, exchangeType string, queueName string)
• type Sink
  • 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
  • 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)

Functions

func DeclareExchange

func DeclareExchange(amqpUri string, exchange string, exchangeType string, queueName string)

Types

type Sink

type Sink struct {
	Uri        string
	Exchange   string
	BindingKey string
}

func (*Sink) Close

func (s *Sink) Close(ctx *goconnect.Context) error

func (*Sink) Flush

func (s *Sink) Flush(ctx *goconnect.Context) error

func (*Sink) InType

func (s *Sink) InType() reflect.Type

func (*Sink) Process

func (s *Sink) Process(element *goconnect.Element, ctx *goconnect.Context)

type Source

type Source struct {
	Uri           string
	Exchange      string
	QueueName     string
	ConsumerTag   string
	BindingKey    string
	PrefetchCount int
	PrefetchSize  int
}

func (*Source) Close

func (source *Source) Close(ctx *goconnect.Context) error

func (*Source) Commit

func (source *Source) Commit(checkpoint goconnect.Watermark, ctx *goconnect.Context) error

func (*Source) OutType

func (source *Source) OutType() reflect.Type

func (*Source) Run

func (source *Source) Run(context *goconnect.Context)