application SDK

package main



import (

    "fmt"

    "github.com/edgexfoundry/app-functions-sdk-go/appsdk"

    "github.com/edgexfoundry/app-functions-sdk-go/pkg/transforms"

    "os"

)



func main() {



    // 1) First thing to do is to create an instance of the EdgeX SDK, giving it a service key

    edgexSdk := &appsdk.AppFunctionsSDK{

        ServiceKey: "SimpleFilterXMLApp", // Key used by Registry (Aka Consul)

    }



    // 2) Next, we need to initialize the SDK

    if err := edgexSdk.Initialize(); err != nil {

        message := fmt.Sprintf("SDK initialization failed: %v\n", err)

        if edgexSdk.LoggingClient != nil {

            edgexSdk.LoggingClient.Error(message)

        } else {

            fmt.Println(message)

        }

        os.Exit(-1)

    }



    // 3) Shows how to access the application's specific configuration settings.

    deviceNames, err := edgexSdk.GetAppSettingStrings("DeviceNames")

    if err != nil {

        edgexSdk.LoggingClient.Error(err.Error())

        os.Exit(-1)

    }    



    // 4) This is our pipeline configuration, the collection of functions to

    // execute every time an event is triggered.

    if err = edgexSdk.SetFunctionsPipeline(

            transforms.NewFilter(deviceNames).FilterByDeviceName, 

            transforms.NewConversion().TransformToXML,

        ); err != nil {

        edgexSdk.LoggingClient.Error(fmt.Sprintf("SDK SetPipeline failed: %v\n", err))

        os.Exit(-1)

    }



    // 5) Lastly, we'll go ahead and tell the SDK to "start" and begin listening for events to trigger the pipeline.

    err = edgexSdk.MakeItRun()

    if err != nil {

        edgexSdk.LoggingClient.Error("MakeItRun returned error: ", err.Error())

        os.Exit(-1)

    }



    // Do any required cleanup here



    os.Exit(0)

}