registrycmdutil

Documentation

Index

• Constants
• func GetInstanceAPIError(err error) (e registryinstanceclient.Error, ok bool)
• func TransformInstanceError(err error) error
• func ValidateName(val interface{}) error
• type CompatibilityEndpoints
  • func GetCompatibilityEndpoints(url string) *CompatibilityEndpoints
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Unwrap() error
• type FlagSet
  • func NewFlagSet(cmd *cobra.Command, f *factory.Factory) *FlagSet
  • func (fs *FlagSet) AddRegistryInstance(registryID *string)

Constants

const DefaultArtifactGroup = "default"

const REGISTRY_CNCF_PATH = "/apis/cncf/v0"

const REGISTRY_COMPAT_PATH = "/apis/ccompat/v6"

const REGISTRY_CORE_PATH = "/apis/registry/v2"

Functions

func GetInstanceAPIError

func GetInstanceAPIError(err error) (e registryinstanceclient.Error, ok bool)

GetInstanceAPIError gets a strongly typed error from an error

func TransformInstanceError

func TransformInstanceError(err error) error

TransformInstanceError code contains message that can be returned to the user

func ValidateName

func ValidateName(val interface{}) error

ValidateName validates the proposed name of a Kafka instance

Types

type CompatibilityEndpoints

type CompatibilityEndpoints struct {
	CoreRegistry       string `json:"coreRegistryAPI"`
	SchemaRegistry     string `json:"schemaRegistryCompatAPI"`
	CncfSchemaRegistry string `json:"cncfSchemaRegistryAPI"`
}

CompatibilityEndpoints - Service Registry API paths for various clients

func GetCompatibilityEndpoints

func GetCompatibilityEndpoints(url string) *CompatibilityEndpoints

GetCompatibilityEndpoints returns the compatible API endpoints

type Error

type Error struct {
	Err error
}

func (*Error) Error

func (e *Error) Error() string

func (*Error) Unwrap

func (e *Error) Unwrap() error

type FlagSet

type FlagSet struct {
	*flagutil.FlagSet
	// contains filtered or unexported fields
}

func NewFlagSet

func NewFlagSet(cmd *cobra.Command, f *factory.Factory) *FlagSet

NewFlagSet returns a new flag set with common Service Registry flags

func (*FlagSet) AddRegistryInstance

func (fs *FlagSet) AddRegistryInstance(registryID *string)

AddRegistryInstance adds a flag for setting the Service Registry instance ID