kafkacmdutil

Documentation

Index

• func FilterValidConsumerGroupIDs(f *factory.Factory, toComplete string) (validIDs []string, directive cobra.ShellCompDirective)
• func FilterValidTopicNameArgs(f *factory.Factory, toComplete string) (validNames []string, directive cobra.ShellCompDirective)
• 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 FilterValidConsumerGroupIDs

func FilterValidConsumerGroupIDs(f *factory.Factory, toComplete string) (validIDs []string, directive cobra.ShellCompDirective)

FilterValidConsumerGroupIDs returns the list of consumer group IDs from the API

func FilterValidTopicNameArgs

func FilterValidTopicNameArgs(f *factory.Factory, toComplete string) (validNames []string, directive cobra.ShellCompDirective)

FilterValidTopicNameArgs filters topics from the API and returns the names This is used in for dynamic completion of topic names

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