kafkacmdutil

Documentation

Index

• func TransformKafkaRequest(kafka *kafkamgmtclient.KafkaRequest) *kafkamgmtclient.KafkaRequest
• func TransformKafkaRequestListItems(items []kafkamgmtclient.KafkaRequest) []kafkamgmtclient.KafkaRequest
• type Validator
  • func (v *Validator) ValidateName(val interface{}) error
  • func (v *Validator) ValidateNameIsAvailable(val interface{}) error
  • func (v *Validator) ValidateSearchInput(val interface{}) error

Functions

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

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

Validator is a type for validating Kafka configuration values

func (*Validator) ValidateName

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

ValidateName validates the proposed name of a Kafka instance

func (*Validator) ValidateNameIsAvailable

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

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

func (*Validator) ValidateSearchInput

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

ValidateSearchInput validates the text provided to filter the Kafka instances