rabbitmq

Documentation

Index

• type Configuration
  • func NewConfiguration(id string, triggerConfiguration *functionconfig.Trigger, ...) (*Configuration, error)
• type Event
  • func (e *Event) GetBody() []byte
  • func (e *Event) GetContentType() string
  • func (e *Event) GetHeaderByteSlice(key string) []byte
  • func (e *Event) GetHeaderString(key string) string
  • func (e *Event) GetHeaders() map[string]interface{}
  • func (e *Event) GetID() nuclio.ID
  • func (e *Event) GetMethod() string
  • func (e *Event) GetPath() string
  • func (e *Event) GetTimestamp() time.Time
  • func (e *Event) GetURL() string

Types

type Configuration

type Configuration struct {
	trigger.Configuration
	ExchangeName      string
	QueueName         string
	Topics            []string
	ReconnectDuration string
	ReconnectInterval string
	PrefetchCount     int
	DurableExchange   bool
	DurableQueue      bool
	// contains filtered or unexported fields
}

func NewConfiguration

func NewConfiguration(id string,
	triggerConfiguration *functionconfig.Trigger,
	runtimeConfiguration *runtime.Configuration) (*Configuration, error)

type Event

type Event struct {
	nuclio.AbstractEvent
	// contains filtered or unexported fields
}

Event allows accessing an amqp.Delivery

func (*Event) GetBody

func (e *Event) GetBody() []byte

func (*Event) GetContentType

func (e *Event) GetContentType() string

func (*Event) GetHeaderByteSlice

func (e *Event) GetHeaderByteSlice(key string) []byte

func (*Event) GetHeaderString

func (e *Event) GetHeaderString(key string) string

func (*Event) GetHeaders

func (e *Event) GetHeaders() map[string]interface{}

func (*Event) GetID

func (e *Event) GetID() nuclio.ID

func (*Event) GetMethod

func (e *Event) GetMethod() string

func (*Event) GetPath

func (e *Event) GetPath() string

func (*Event) GetTimestamp

func (e *Event) GetTimestamp() time.Time

func (*Event) GetURL

func (e *Event) GetURL() string