kafka

Documentation

Index

• func GetKafkaByID(ctx context.Context, api kasclient.DefaultApi, id string) (*kasclient.KafkaRequest, *http.Response, error)
• func GetKafkaByName(ctx context.Context, api kasclient.DefaultApi, name string) (*kasclient.KafkaRequest, *http.Response, error)
• func InteractiveSelect(connection connection.Connection, logger logging.Logger) (*kasclient.KafkaRequest, error)
• func TransformKafkaRequest(kafka *kasclient.KafkaRequest) *kasclient.KafkaRequest
• func TransformKafkaRequestListItems(items []kasclient.KafkaRequest) []kasclient.KafkaRequest
• func ValidateName(val interface{}) error
• func ValidateSearchInput(val interface{}) error

Functions

func GetKafkaByID

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

func GetKafkaByName

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

func InteractiveSelect

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

func TransformKafkaRequest

func TransformKafkaRequest(kafka *kasclient.KafkaRequest) *kasclient.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 []kasclient.KafkaRequest) []kasclient.KafkaRequest

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

func ValidateName

func ValidateName(val interface{}) error

ValidateName validates the proposed name of a Kafka instance

func ValidateSearchInput

func ValidateSearchInput(val interface{}) error

ValidateSearchInput validates the text provided to filter the Kafka instances