Documentation
¶
Index ¶
- type Configuration
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GetContentType ¶
func (*Event) GetHeaderByteSlice ¶
func (*Event) GetHeaderString ¶
func (*Event) GetHeaders ¶
func (*Event) GetTimestamp ¶
Source Files
Click to show internal directories.
Click to hide internal directories.