kafkautil

package
v0.37.1-beta3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 11, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ErrorCode7 Resource not found
	ErrorCode7 = "KAFKAS-MGMT-7"
	// ErrorCode24 The maximum number of allowed kafka instances has been reached
	ErrorCode24 = "KAFKAS-MGMT-24"
	// ErrorCode21 Bad Request
	ErrorCode21 = "KAFKAS-MGMT-21"
	// ErrorCode36 Kafka cluster name is already used
	ErrorCode36 = "KAFKAS-MGMT-36"
)

Variables

View Source
var (
	NotFoundByIDErr         error
	NotFoundByNameErr       error
	IllegalSearchValueError error
	InvalidNameErr          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 GetAPIError

func GetAPIError(err error) *kafkamgmtclient.Error

GetAPIError gets a strongly typed error from an error

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 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) []string

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

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 IsErr

func IsErr(err error, code ServiceErrorCode) bool

IsErr returns true if the error contains the errCode

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

Types

type Error

type Error struct {
	Err error
}

func (*Error) Error

func (e *Error) Error() string

func (*Error) Unwrap

func (e *Error) Unwrap() error

type ServiceErrorCode

type ServiceErrorCode string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL