nats

README

Kubemq Nats Target Connector

Kubemq Nats target connector allows services using kubemq server to access Nats messaging services.

Prerequisites

The following are required to run the Nats target connector:

• kubemq cluster
• Nats server
• kubemq-targets deployment

Configuration

Nats target connector configuration properties:

Properties Key	Required	Description	Example
url	yes	nats connection host	"localhost:1883"
subject	yes	set subject name	any string
username	no	set nats username	"username"
password	no	set nats password	"password"
token	no	set nats token	"my_token"
tls	no	set if tls is needed	"false","true"
cert_file	no	tls certificate file in string format	"my_file"
cert_key	no	tls certificate key in string format	"my_key"
timeout	no	connection timeout in seconds	"130"

Example:

bindings:
  - name: nats
    source:
      kind: kubemq.events
      properties:
        address: localhost:50000
        channel: event.messaging.nats
    target:
      kind: messaging.nats
      properties:
        cert_file: |-
          -----BEGIN CERTIFICATE-----
          -----END CERTIFICATE-----
        cert_key: |-
          -----BEGIN PRIVATE KEY-----
          -----END PRIVATE KEY-----
        dynamic_mapping: "false"
        url: nats://localhost:4222
    properties: {}

Usage

Request

Query request data setting:

Data Key	Required	Description	Possible values
data	yes	data to publish	base64 bytes array

Example:

{
  "data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
}

Documentation

Index

• func Connector() *common.Connector
• type Client
  • func New() *Client
  • func (c *Client) Connector() *common.Connector
  • func (c *Client) Do(ctx context.Context, req *types.Request) (*types.Response, error)
  • func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error
  • func (c *Client) Stop() error

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