kxupdatefilter

README

---

title: kxupdatefilter weight: 4615

Log

This activity allows you decode knox Update messagess based on specific tagnames.

Installation

Flogo Web

This activity is part of the knox system

Flogo CLI

flogo add activity github.com/mtorre-iot/flogo-contrib/activity/kxupdatefilter

Schema

Inputs and Outputs:

{
"input":[
    {
      "name": "message",
      "type": "string",
      "value": "",
      "required": true
    },
    {
      "name": "RTDBFile",
      "type": "string",
      "value": "",
      "required": true
    },
    {
      "name": "triggerTag",
      "type": "string",
      "value": "",
      "required": true
    },
    {
      "name": "inputTags",
      "type": "params",
      "required": true
    },
    {
      "name": "functionName",
      "type": "string",
      "value": "",
      "required": true
    }

  ],
  "output": [
    {
      "name": "outputStream",
      "type": "string"
    }
  ]
}

Settings

Examples

{
}

Documentation

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type KXUpdateFilterActivity
  • func (a *KXUpdateFilterActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *KXUpdateFilterActivity) Metadata() *activity.Metadata

Functions

func NewActivity

func NewActivity(metadata *activity.Metadata) activity.Activity

NewActivity creates a new AppActivity

Types

type KXUpdateFilterActivity

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

KXUpdateFilterActivity is an Activity that is used to deserialize messages from KXDataProc, to get changes to invoke other activities

func (*KXUpdateFilterActivity) Eval

func (a *KXUpdateFilterActivity) Eval(context activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Logs the Message

func (*KXUpdateFilterActivity) Metadata

func (a *KXUpdateFilterActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata