kafka

Documentation

Index

• func GetKafkaByID(ctx context.Context, api kafkamgmtclient.DefaultApi, id string) (*kafkamgmtclient.KafkaRequest, *http.Response, error)
• func GetKafkaByName(ctx context.Context, api kafkamgmtclient.DefaultApi, name string) (*kafkamgmtclient.KafkaRequest, *http.Response, error)
• func InteractiveSelect(connection connection.Connection, logger logging.Logger) (*kafkamgmtclient.KafkaRequest, error)
• 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 GetKafkaByID

func GetKafkaByID(ctx context.Context, api kafkamgmtclient.DefaultApi, id string) (*kafkamgmtclient.KafkaRequest, *http.Response, error)

func GetKafkaByName

func GetKafkaByName(ctx context.Context, api kafkamgmtclient.DefaultApi, name string) (*kafkamgmtclient.KafkaRequest, *http.Response, error)

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

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