The highest tagged major version is v2.

kafka

package

v1.5.3 Latest Latest Go to latest Published: Jun 28, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	// Kind is the kind of Kafka
	Kind = "Kafka"
)

This section is empty.

This section is empty.

type Dynamic struct {
	Header string `yaml:"header" jsonschema:"omitempty"`
}

Dynamic defines dynamic ways to get Kafka topic from http request

type Kafka struct {
	// contains filtered or unexported fields
}

Kafka is kafka backend for MQTT proxy

func (k *Kafka) Close()

Close close Kafka

func (k *Kafka) DefaultSpec() interface{}

DefaultSpec return default spec of Kafka

func (k *Kafka) Description() string

Description return description of Kafka

func (k *Kafka) Handle(ctx context.HTTPContext) (result string)

Handle handles HTTPContext.

func (k *Kafka) Inherit(filterSpec *httppipeline.FilterSpec, previousGeneration httppipeline.Filter)

Inherit init Kafka based on previous generation

func (k *Kafka) Init(filterSpec *httppipeline.FilterSpec)

Init init Kafka

func (k *Kafka) Kind() string

Kind return kind of Kafka

func (k *Kafka) Results() []string

Results return possible results of Kafka

func (k *Kafka) Status() interface{}

Status return status of Kafka

type Spec struct {
	Backend []string `yaml:"backend" jsonschema:"required,uniqueItems=true"`
	Topic   *Topic   `yaml:"topic" jsonschema:"required"`
}

Spec is spec of Kafka

type Topic struct {
	Default string   `yaml:"default" jsonschema:"required"`
	Dynamic *Dynamic `yaml:"dynamic" jsonschema:"omitempty"`
}

Topic defined ways to get Kafka topic