kafkautil

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 FindCloudProviderByName(cloudProviders []kafkamgmtclient.CloudProvider, name string) *kafkamgmtclient.CloudProvider
• func GetCloudProviderCompletionValues(f *factory.Factory) (validProviders []string, directive cobra.ShellCompDirective)
• func GetCloudProviderRegionCompletionValues(f *factory.Factory, providerID string) (validRegions []string, directive cobra.ShellCompDirective)
• func GetEnabledCloudProviderNames(cloudProviders []kafkamgmtclient.CloudProvider) []string
• func GetEnabledCloudRegionIDs(regions []kafkamgmtclient.CloudRegion, userAllowedInstanceTypes *[]string) []string
• 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(ctx context.Context, connection connection.Connection, logger logging.Logger, ...) (*kafkamgmtclient.KafkaRequest, error)
• func InvalidNameError(v string) error
• func InvalidSearchValueError(v string) error
• func IsRegionAllowed(region *kafkamgmtclient.CloudRegion, userAllowedInstanceTypes *[]string) bool
• func NotFoundByIDError(id string) error
• func NotFoundByNameError(name string) error
• func RegisterNameFlagCompletionFunc(cmd *cobra.Command, f *factory.Factory) 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 FindCloudProviderByName

func FindCloudProviderByName(cloudProviders []kafkamgmtclient.CloudProvider, name string) *kafkamgmtclient.CloudProvider

FindCloudProviderByName finds and returns a cloud provider item from the list by its name

func GetCloudProviderCompletionValues

func GetCloudProviderCompletionValues(f *factory.Factory) (validProviders []string, directive cobra.ShellCompDirective)

GetCloudProviderCompletionValues returns the list of supported cloud providers for creating a Kafka instance This is used in the cmd.RegisterFlagCompletionFunc for dynamic completion of --provider

func GetCloudProviderRegionCompletionValues

func GetCloudProviderRegionCompletionValues(f *factory.Factory, providerID string) (validRegions []string, directive cobra.ShellCompDirective)

GetCloudProviderCompletionValues returns the list of region IDs for a particular cloud provider

func GetEnabledCloudProviderNames

func GetEnabledCloudProviderNames(cloudProviders []kafkamgmtclient.CloudProvider) []string

GetEnabledCloudProviderNames returns a list of cloud provider names from the enabled cloud providers

func GetEnabledCloudRegionIDs

func GetEnabledCloudRegionIDs(regions []kafkamgmtclient.CloudRegion, userAllowedInstanceTypes *[]string) []string

GetEnabledCloudRegionIDs extracts and returns a slice of the unique IDs of all enabled regions

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(ctx context.Context, connection connection.Connection, logger logging.Logger, localizer localize.Localizer) (*kafkamgmtclient.KafkaRequest, error)

func InvalidNameError

func InvalidNameError(v string) error

func InvalidSearchValueError

func InvalidSearchValueError(v string) error

func IsRegionAllowed

func IsRegionAllowed(region *kafkamgmtclient.CloudRegion, userAllowedInstanceTypes *[]string) bool

func NotFoundByIDError

func NotFoundByIDError(id string) error

func NotFoundByNameError

func NotFoundByNameError(name string) error

func RegisterNameFlagCompletionFunc

func RegisterNameFlagCompletionFunc(cmd *cobra.Command, f *factory.Factory) error

RegisterNameFlagCompletionFunc adds dynamic completion for the --name flag