Documentation ¶
Index ¶
- Constants
- type Configuration
- type Event
- func (e *Event) GetBody() []byte
- func (e *Event) GetHeader(key string) interface{}
- func (e *Event) GetHeaderByteSlice(key string) []byte
- func (e *Event) GetHeaderString(key string) string
- func (e *Event) GetHeaders() map[string]interface{}
- func (e *Event) GetPath() string
- func (e *Event) GetSize() int
- func (e *Event) GetURL() string
- type Subscription
Constants ¶
View Source
const DefaultSubscriptionIDPrefix string = "nuclio-pub"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
type Configuration struct { trigger.Configuration Subscriptions []Subscription ProjectID string AckDeadline string Credentials trigger.Secret NoCredentials bool }
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 stores a whole pubsub message
func (*Event) GetHeaderByteSlice ¶
GetHeaderByteSlice returns the header by name as a byte slice
func (*Event) GetHeaderString ¶
GetHeaderString returns the header by name as a string
func (*Event) GetHeaders ¶
GetHeaders loads all headers into a map of string / interface{}
type Subscription ¶
Click to show internal directories.
Click to hide internal directories.