notificationlistener

Documentation

Overview

* Copyright © 2020. TIBCO Software Inc. * This file is subject to the license terms contained * in the license file that is distributed with this file.

Index

• type Factory
  • func (*Factory) Metadata() *trigger.Metadata
  • func (*Factory) New(config *trigger.Config) (trigger.Trigger, error)
• type HandlerSettings
• type NotificationListener
  • func (this *NotificationListener) Initialize(ctx trigger.InitContext) error
  • func (this *NotificationListener) ProcessEvent(brokerID string, event map[string]interface{}) error
  • func (this *NotificationListener) Start() error
  • func (this *NotificationListener) Stop() error
• type Output
  • func (this *Output) FromMap(values map[string]interface{}) error
  • func (this *Output) ToMap() map[string]interface{}
• type Settings

Types

type Factory

type Factory struct {
}

func (*Factory) Metadata

func (*Factory) Metadata() *trigger.Metadata

Metadata implements trigger.Factory.Metadata

func (*Factory) New

func (*Factory) New(config *trigger.Config) (trigger.Trigger, error)

New implements trigger.Factory.New

type HandlerSettings

type HandlerSettings struct {
	NotifierID string `md:"notifierID,required"`
}

type NotificationListener

type NotificationListener struct {
	// contains filtered or unexported fields
}

func (*NotificationListener) Initialize

func (this *NotificationListener) Initialize(ctx trigger.InitContext) error

implements trigger.Initializable.Initialize

func (*NotificationListener) ProcessEvent

func (this *NotificationListener) ProcessEvent(brokerID string, event map[string]interface{}) error

func (*NotificationListener) Start

func (this *NotificationListener) Start() error

implements ext.Trigger.Start

func (*NotificationListener) Stop

func (this *NotificationListener) Stop() error

implements ext.Trigger.Stop

type Output

type Output struct {
	Gateway  string                 `md:"gateway,required"`
	Reading  map[string]interface{} `md:"reading"`
	Enriched []interface{}          `md:"enriched"`
}

func (*Output) FromMap

func (this *Output) FromMap(values map[string]interface{}) error

func (*Output) ToMap

func (this *Output) ToMap() map[string]interface{}

type Settings

type Settings struct {
}