pubsub

package
v0.0.0-...-f7ae98d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 10, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

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
}

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) GetBody

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

GetBody returns a message data

func (*Event) GetHeader

func (e *Event) GetHeader(key string) interface{}

GetHeader returns the header by name as an interface{}

func (*Event) GetHeaderByteSlice

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

GetHeaderByteSlice returns the header by name as a byte slice

func (*Event) GetHeaderString

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

GetHeaderString returns the header by name as a string

func (*Event) GetHeaders

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

GetHeaders loads all headers into a map of string / interface{}

func (*Event) GetPath

func (e *Event) GetPath() string

GetPath returns the path of the event

func (*Event) GetSize

func (e *Event) GetSize() int

GetSize returns data length

func (*Event) GetURL

func (e *Event) GetURL() string

GetURL returns the URL of the event

type Subscription

type Subscription struct {
	Topic         string
	MaxNumWorkers int
	Shared        bool
	AckDeadline   string
}