README
¶
Kubemq HTTP Source
Kubemq HTTP source provides a REST Api endpoints for processing source REST Api request.
Prerequisites
The following are required to run events source connector:
- kubemq cluster
- kubemq-sources deployment
Configuration
HTTP source connector configuration properties:
| Properties Key | Required | Description | Example |
|---|---|---|---|
| methods | yes | List for REST API methods to process | "GET,POST,PUT,PATCH,DELETE" |
| path | yes | set http server endpoint path | "/path" |
Example:
bindings:
- name: http-post-kubemq-event
source:
kind: http
name: http-post
properties:
"methods": "post"
"path": "/post"
target:
kind: kubemq.events
name: target-kubemq-events
properties:
address: "kubemq-cluster:50000"
client_id: "kubemq-http-connector"
auth_token: ""
channel: "events.post"
properties:
log_level: "info"
Documentation
¶
Index ¶
- func Connector() *common.Connector
- type Client
- func (c *Client) Connector() *common.Connector
- func (c *Client) Init(ctx context.Context, cfg config.Spec, log *logger.Logger) error
- func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (c *Client) Start(ctx context.Context, target targetMiddleware.Middleware) error
- func (c *Client) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.