amqp

Documentation

Index

• type Source
  • func (src *Source) Close()
  • func (src *Source) Connect() (sink <-chan deps.Dep, err error)
  • func (src *Source) Init(conf *config.Config)

Types

type Source

type Source struct {
	Config    *config.Config
	Exchanges []exchange
	// contains filtered or unexported fields
}

Source implements amqp for the source.Source interface

func (*Source) Close

func (src *Source) Close()

Close stops the source

func (*Source) Connect

func (src *Source) Connect() (sink <-chan deps.Dep, err error)

Connect connects the source and writes new tasks to the sink

func (*Source) Init

func (src *Source) Init(conf *config.Config)

Init initializes the source