Documentation ¶
Overview ¶
Package kafka implements a kafka proxy for HTTP requests.
Index ¶
- Constants
- type Dynamic
- type Err
- type Kafka
- func (k *Kafka) Close()
- func (k *Kafka) Handle(ctx *context.Context) (result string)
- func (k *Kafka) Inherit(previousGeneration filters.Filter)
- func (k *Kafka) Init()
- func (k *Kafka) Kind() *filters.Kind
- func (k *Kafka) Name() string
- func (k *Kafka) Spec() filters.Spec
- func (k *Kafka) Status() interface{}
- type Key
- type Spec
- type Topic
Constants ¶
View Source
const (
// Kind is the kind of Kafka
Kind = "Kafka"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dynamic ¶
type Dynamic struct {
Header string `json:"header,omitempty"`
}
Dynamic defines dynamic ways to get Kafka topic from http request
type Kafka ¶
type Kafka struct {
// contains filtered or unexported fields
}
Kafka is a kafka proxy for HTTP requests.
Click to show internal directories.
Click to hide internal directories.