elasticloud

README

Elastic Cloud

Index data into Elastic Cloud

Log in to your exising cloud account at https://cloud.elastic.co or sign-up for a trial account on https://www.elastic.co/cloud/elasticsearch-service/signup .

Installation

flogo install github.com/tuurleyck/flogo-components/activity/elasticloud

Link for flogo web:

https://github.com/tuurleyck/flogo-components/activity/elasticloud

Schema

Inputs and Outputs:

{
"inputs": [
        {
        "name": "cloud_id",
        "type": "string",
        "required": "true"
        },
        {
        "name": "cloud_auth",
        "type": "string",
        "required": "true"
        },
        {
        "name": "index",
        "type": "string",
        "required": "true"
        },
        {
        "name": "document_id",
        "type": "string"
        },
        {
        "name": "params",
        "type": "params"
        },
        {
        "name": "value",
        "type": "params",
        "required": "true"
        }
    ],
    "outputs": [
        {
            "name": "result",
            "type": "string"
        }
    ]
}

Inputs

Input	Description
cloud_id	Your Elastic Cloud id
cloud_auth	Your Elastic Cloud authentication (username:password)
index	The index in which you want to store your data
document_id	The id for the document you want to store
params	Additional parameters you might want to set for your request
value	The data you want to store

Ouputs

Output	Description
result	The result (either OK or the error that was generated by Elasticsearch)

Documentation

Index

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

Functions

func NewActivity

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

NewActivity creates a new activity

Types

type ElasticloudActivity

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

Integration with Elasticsearch inputs: {cloud_id, cloud_auth, index, params, id, document} outputs: {response}

func (*ElasticloudActivity) Eval

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

Eval implements activity.Activity.Eval - Elasticsearch integration

func (*ElasticloudActivity) Metadata

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

Metadata implements activity.Activity.Metadata