pubsub

README

Kubemq pubsub source Connector

Kubemq gcp-pubsub source connector allows services using kubemq server to access google pubsub server.

Prerequisites

The following required to run the gcp-pubsub source connector:

• kubemq cluster
• gcp-pubsub set up
• kubemq-source deployment

Configuration

pubsub source connector configuration properties:

Properties Key	Required	Description	Example
project_id	yes	gcp project_id	"googleurl/myproject"
credentials	yes	gcp credentials files	"google json credentials"
subscriber_id	yes	gcp pubsub queue subscriber id	"string"

Example:

bindings:
  - name: pubsub
    source:
      kind: gcp.pubsub
      properties:
        credentials: |-
          {
          }
        project_id: kubemq-tests-294511
        subscriber_id: test
    target:
      kind: kubemq.events
      properties:
        address: localhost:50000
        auth_token: ""
        channel: event.gcp.pubsub
        client_id: pubsub
    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