create

Documentation

Index

• Constants
• func FetchInstanceTypes(f *factory.Factory, providerID string, regionId string) ([]kafkamgmtclient.SupportedKafkaInstanceType, error)
• func FetchSupportedBillingModels(userQuotas *accountmgmtutil.OrgQuotas, provider string) []string
• func FetchValidKafkaSizes(f *factory.Factory, providerID string, regionId string, ...) ([]kafkamgmtclient.SupportedKafkaSize, error)
• func FetchValidKafkaSizesLabels(f *factory.Factory, providerID string, regionId string, ...) ([]string, error)
• func FetchValidMarketplaceAccounts(amsTypes []accountmgmtutil.QuotaSpec, marketplace string) []string
• func FetchValidMarketplaces(amsTypes []accountmgmtutil.QuotaSpec, provider string) []string
• func GetBillingModelCompletionValues(f *factory.Factory) (availableBillingModels []string, directive cobra.ShellCompDirective)
• func GetCloudProviderCompletionValues(f *factory.Factory) (validProviders []string, directive cobra.ShellCompDirective)
• func GetCloudProviderRegionCompletionValues(f *factory.Factory, providerID string) (validRegions []string, directive cobra.ShellCompDirective)
• func GetEnabledCloudProviderNames(f *factory.Factory) ([]string, error)
• func GetEnabledCloudRegionIDs(f *factory.Factory, providerID string, ...) ([]string, error)
• func GetKafkaSizeCompletionValues(f *factory.Factory, providerID string, regionId string) (validSizes []string, directive cobra.ShellCompDirective)
• func GetMarketplaceAccountCompletionValues(f *factory.Factory, marketplace string) (validMarketplaceAcctIDs []string, directive cobra.ShellCompDirective)
• func GetMarketplaceCompletionValues(f *factory.Factory) (validSizes []string, directive cobra.ShellCompDirective)
• func GetValidKafkaSizesLabels(sizes []kafkamgmtclient.SupportedKafkaSize) []string
• func IsRegionAllowed(region *kafkamgmtclient.CloudRegion, ...) bool
• func NewCreateCommand(f *factory.Factory) *cobra.Command
• func ValidateBillingModel(billingModel string) error
• type CloudProviderId
• type ValidatorInput
  • func (input *ValidatorInput) ValidateProviderAndRegion() error
  • func (input *ValidatorInput) ValidateSize() error

Constants

const (
	// FlagProvider is a flag representing an provider ID
	FlagProvider = "provider"
	// FlagRegion is a flag representing an region ID
	FlagRegion = "region"
	// FlagSize is a flag representing an size ID
	FlagSize = "size"
	// FlagMarketPlaceAcctID is a flag representing a marketplace cloud account ID used to purchase the instance
	FlagMarketPlaceAcctID = "marketplace-account-id"
	// FlagMarketPlace is a flag representing marketplace where the instance is purchased on
	FlagMarketPlace = "marketplace"
	// FlagMarketPlace is a flag representing billing model of the instance
	FlagBillingModel = "billing-model"
)

Functions

func FetchInstanceTypes

func FetchInstanceTypes(f *factory.Factory, providerID string, regionId string) ([]kafkamgmtclient.SupportedKafkaInstanceType, error)

func FetchSupportedBillingModels

func FetchSupportedBillingModels(userQuotas *accountmgmtutil.OrgQuotas, provider string) []string

func FetchValidKafkaSizes

func FetchValidKafkaSizes(f *factory.Factory,
	providerID string, regionId string, amsType accountmgmtutil.QuotaSpec) ([]kafkamgmtclient.SupportedKafkaSize, error)

FetchValidKafkaSizes returns list of the valid instance sizes for the specified region and ams instance types

func FetchValidKafkaSizesLabels

func FetchValidKafkaSizesLabels(f *factory.Factory,
	providerID string, regionId string, amsType accountmgmtutil.QuotaSpec) ([]string, error)

func FetchValidMarketplaceAccounts

func FetchValidMarketplaceAccounts(amsTypes []accountmgmtutil.QuotaSpec, marketplace string) []string

func FetchValidMarketplaces

func FetchValidMarketplaces(amsTypes []accountmgmtutil.QuotaSpec, provider string) []string

func GetBillingModelCompletionValues

func GetBillingModelCompletionValues(f *factory.Factory) (availableBillingModels []string, directive cobra.ShellCompDirective)

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)

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

func GetEnabledCloudProviderNames

func GetEnabledCloudProviderNames(f *factory.Factory) ([]string, error)

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

func GetEnabledCloudRegionIDs

func GetEnabledCloudRegionIDs(f *factory.Factory, providerID string, userAllowedAMSInstanceType *accountmgmtutil.QuotaSpec) ([]string, error)

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

func GetKafkaSizeCompletionValues

func GetKafkaSizeCompletionValues(f *factory.Factory, providerID string, regionId string) (validSizes []string, directive cobra.ShellCompDirective)

GetKafkaSizeCompletionValues returns a list of valid kafka sizes for the specified region and ams instance types

func GetMarketplaceAccountCompletionValues

func GetMarketplaceAccountCompletionValues(f *factory.Factory, marketplace string) (validMarketplaceAcctIDs []string, directive cobra.ShellCompDirective)

func GetMarketplaceCompletionValues

func GetMarketplaceCompletionValues(f *factory.Factory) (validSizes []string, directive cobra.ShellCompDirective)

func GetValidKafkaSizesLabels

func GetValidKafkaSizesLabels(sizes []kafkamgmtclient.SupportedKafkaSize) []string

func IsRegionAllowed

func IsRegionAllowed(region *kafkamgmtclient.CloudRegion, userInstanceType *accountmgmtutil.QuotaSpec) bool

func NewCreateCommand

func NewCreateCommand(f *factory.Factory) *cobra.Command

NewCreateCommand creates a new command for creating kafkas. nolint: funlen

func ValidateBillingModel

func ValidateBillingModel(billingModel string) error

ValidateBillingModel validates if user provided a supported billing model

Types

type CloudProviderId

type CloudProviderId = string

Types we use on backend to map AMS Quotas

const (
	// Matches QuotaTrialType = trial
	DeveloperType CloudProviderId = "developer"

	// Matches QuotaStandardType = standard
	StandardType CloudProviderId = "standard"

	// Deprecated by DeveloperType
	TrialType CloudProviderId = "eval"
)

Additional types that are used in backend to match AMS Quota instance types

type ValidatorInput

type ValidatorInput struct {
	// contains filtered or unexported fields
}

func (*ValidatorInput) ValidateProviderAndRegion

func (input *ValidatorInput) ValidateProviderAndRegion() error

func (*ValidatorInput) ValidateSize

func (input *ValidatorInput) ValidateSize() error