nats

README

Kubemq nats source Connector

Kubemq nats source connector allows services using kubemq server to access nats messaging services.

Prerequisites

The following are required to run the nats source connector:

• kubemq cluster
• nats server
• kubemq-sources deployment

Configuration

nats source connector configuration properties:

Properties Key	Required	Description	Example
url	yes	nats connection host	"localhost:1883"
subject	yes	set subject name	any string
dynamic_mapping	yes	set if to map nats Destination to kubemq channel	"true"
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: messaging.nats
      properties:
        cert_file: |-
          -----BEGIN CERTIFICATE-----
          mycert
          -----END CERTIFICATE-----
        cert_key: |-
          -----BEGIN PRIVATE KEY-----
          mykey
          -----END PRIVATE KEY-----
        dynamic_mapping: "false"
        subject: foo
        url: nats://localhost:4222
    target:
      kind: kubemq.events
      properties:
        address: localhost:50000
        channel: event.messaging.nats
        dynamic_mapping: "false"
    properties: {}

Documentation

Index

• func Connector() *common.Connector
• type Client
  • func New() *Client
  • func (c *Client) Connector() *common.Connector
  • func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error
  • func (c *Client) Start(ctx context.Context, target middleware.Middleware) 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) Init

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

func (*Client) Start

func (c *Client) Start(ctx context.Context, target middleware.Middleware) error

func (*Client) Stop

func (c *Client) Stop() error