cmdutil

Documentation

Index

• Constants
• func CheckSurveyError(err error) error
• func ConvertPageValueToInt32(s string) int32
• func ConvertSizeValueToInt32(s string) int32
• func FetchCloudProviders(f *factory.Factory) (validProviders []string, directive cobra.ShellCompDirective)
• func FilterValidConsumerGroupIDs(f *factory.Factory, toComplete string) (validIDs []string, directive cobra.ShellCompDirective)
• func FilterValidKafkas(f *factory.Factory, toComplete string) (validNames []string, directive cobra.ShellCompDirective)
• func FilterValidTopicNameArgs(f *factory.Factory, toComplete string) (validNames []string, directive cobra.ShellCompDirective)

Constants

const (
	// The default indentation to use when printing data to stdout
	DefaultJSONIndent = "    "
	// DefaultPollTime is the default interval to wait when polling a network request
	DefaultPollTime = time.Millisecond * 5000
)

Functions

func CheckSurveyError

func CheckSurveyError(err error) error

CheckSurveyError checks the error from AlecAivazis/survey if the error is from SIGINT, force exit the program quietly

func ConvertPageValueToInt32

func ConvertPageValueToInt32(s string) int32

func ConvertSizeValueToInt32

func ConvertSizeValueToInt32(s string) int32

func FetchCloudProviders

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

FetchCloudProviders 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 FilterValidConsumerGroupIDs

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

FilterValidConsumerGroups returns the list of consumer group IDs from the API

func FilterValidKafkas

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

FilterValidKafkaNames filters Kafkas by name from the API and returns the names This is used in the cobra.ValidArgsFunction for dynamic completion of Kafka instance names

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 the cobra.ValidArgsFunction for dynamic completion of topic names