nats

Documentation

Index

• type Configuration
  • func NewConfiguration(id string, triggerConfiguration *functionconfig.Trigger, ...) (*Configuration, error)
• type Event
  • func (e *Event) GetBody() []byte
  • func (e *Event) GetHeaders() map[string]interface{}
  • func (e *Event) GetPath() string
  • func (e *Event) GetSize() int
  • func (e *Event) NATSMessage() *natsio.Msg

Types

type Configuration

type Configuration struct {
	trigger.Configuration
	Topic     string
	QueueName string
}

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 access to the NATS message

func (*Event) GetBody

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

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

func (*Event) GetSize

func (e *Event) GetSize() int

func (*Event) NATSMessage

func (e *Event) NATSMessage() *natsio.Msg