elasticsearch

package

v1.8.1 Latest Latest Go to latest Published: Mar 18, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubemq-io/kubemq-targets

Links

Open Source Insights

README ¶

Kubemq ElasticSearch Target Connector

Kubemq aws-elasticsearch target connector allows services using kubemq server to access aws elasticsearch service.

Prerequisites

The following required to run the aws-elasticsearch target connector:

kubemq cluster
aws account with elasticsearch active service -elastic service with an active domain
kubemq-targets deployment

Configuration

aws-elasticsearch target connector configuration properties:

Properties Key	Required	Description	Example
aws_key	yes	aws key	aws key supplied by aws
aws_secret_key	yes	aws secret key	aws secret key supplied by aws
token	no	aws token ("default" empty string	aws token

Example:

bindings:
  - name: kubemq-query-aws-elasticsearch
    source:
      kind: kubemq.query
      name: kubemq-query
      properties:
        address: "kubemq-cluster:50000"
        client_id: "kubemq-query-aws-elasticsearch-connector"
        auth_token: ""
        channel: "query.aws.elasticsearch"
        group:   ""
        auto_reconnect: "true"
        reconnect_interval_seconds: "1"
        max_reconnects: "0"
    target:
      kind: aws.elasticsearch
      name: aws-elasticsearch
      properties:
        aws_key: "id"
        aws_secret_key: 'json'
        token: ""

Usage

Sign Message

Sign Message :

Metadata Key	Required	Description	Possible values
method	yes	type of HTTP method	"GET", "POST","PUT","DELETE","OPTIONS"
region	yes	aws region associated with domain	"region"
json	yes (unless "GET")	json body to send with the http request	"list"
domain	yes	elastic domain to assign the request	"list"
index	yes	name of the elastic index	"list"
endpoint	yes	aws domain end point	"list"
service	no(Default "es"	type of service	"list"
id	yes	Message ID	"list"

Example:

{
  "metadata": {
    "method": "GET",
    "region": "us-west-2",
    "domain": "https://my-domain-12345asdfg.us-west-2.es.amazonaws.com",
    "index": "myindex",
    "endpoint": "https://my-domain-12345asdfg.us-west-2.es.amazonaws.com/my/end_point",
    "service": "es",
    "id": "123124"
  },
  "data": null
}

Documentation ¶

Constants ¶

View Source

const (
	DefaultJson    = ""
	DefaultService = "es"
)

View Source

const (
	DefaultToken = ""
)

Variables ¶

This section is empty.

Functions ¶

func Connector ¶

func Connector() *common.Connector

Types ¶

type Client ¶

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

func New ¶

func New() *Client

func (*Client) Connector ¶

func (c *Client) Connector() *common.Connector

func (*Client) Do ¶

func (c *Client) Do(ctx context.Context, req *types.Request) (*types.Response, error)

func (*Client) Init ¶

func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error

func (*Client) Stop ¶

func (c *Client) Stop() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL