kafkautil

Documentation

Index

• Constants
• Variables
• 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 GetAPIError(err error) *kafkamgmtclient.Error
• func GetCloudProviderCompletionValues(f *factory.Factory) (validProviders []string, directive cobra.ShellCompDirective)
• func GetEnabledCloudProviderNames(cloudProviders []kafkamgmtclient.CloudProvider) []string
• func GetEnabledCloudRegionIDs(regions []kafkamgmtclient.CloudRegion) []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 IsErr(err error, code ServiceErrorCode) bool
• func NotFoundByIDError(id string) error
• func NotFoundByNameError(name string) error
• func RegisterNameFlagCompletionFunc(cmd *cobra.Command, f *factory.Factory) error
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Unwrap() error
• type ServiceErrorCode

Constants

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

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