kafka

package
v0.27.0-alpha1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 29, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InteractiveSelect

func InteractiveSelect(connection connection.Connection, logger logging.Logger) (*kafkamgmtclient.KafkaRequest, error)

func TransformKafkaRequest

func TransformKafkaRequest(kafka *kafkamgmtclient.KafkaRequest) *kafkamgmtclient.KafkaRequest

TransformKafkaRequest modifies fields from the KafkaRequest payload object The main transformation is appending ":443" to the Bootstrap Server URL

func TransformKafkaRequestListItems

func TransformKafkaRequestListItems(items []kafkamgmtclient.KafkaRequest) []kafkamgmtclient.KafkaRequest

TransformKafkaRequestListItems modifies fields fields from a list of kafka instances The main transformation is appending ":443" to the Bootstrap Server URL

Types

type Validator added in v0.25.0

type Validator struct {
	Localizer  localize.Localizer
	Connection factory.ConnectionFunc
}

Validator is a type for validating Kafka configuration values

func (*Validator) ValidateName added in v0.25.0

func (v *Validator) ValidateName(val interface{}) error

ValidateName validates the proposed name of a Kafka instance

func (*Validator) ValidateNameIsAvailable added in v0.25.0

func (v *Validator) ValidateNameIsAvailable(val interface{}) error

ValidateNameIsAvailable checks if a kafka instance with the given name already exists

func (*Validator) ValidateSearchInput added in v0.25.0

func (v *Validator) ValidateSearchInput(val interface{}) error

ValidateSearchInput validates the text provided to filter the Kafka instances

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL