cmd

Documentation

Index

• Constants
• Variables
• func ApplyConfigOption(config *RunConfigOption, integrationSpec *v1.IntegrationSpec, c client.Client, ...) error
• func ApplyResourceOption(config *RunConfigOption, integrationSpec *v1.IntegrationSpec, c client.Client, ...) error
• func DeleteIntegration(ctx context.Context, c client.Client, name string, namespace string) error
• func GetContainerIntegrationRunCommand(ctx context.Context, properties []string, dependencies []string, ...) (*exec.Cmd, error)
• func NewKamelCommand(ctx context.Context) (*cobra.Command, error)
• func NewKamelWithModelineCommand(ctx context.Context, osArgs []string) (*cobra.Command, []string, error)
• func RunLocalIntegrationRunCommand(ctx context.Context, properties []string, dependencies []string, ...) error
• type Config
  • func LoadConfiguration() (*Config, error)
  • func (cfg *Config) Delete(path string)
  • func (cfg *Config) Save() error
  • func (cfg *Config) SetNode(nodeID string, nodeValues map[string]interface{})
  • func (cfg *Config) Update(cmd *cobra.Command, nodeID string, data interface{}, changedOnly bool)
• type RootCmdOptions
  • func (command *RootCmdOptions) GetCamelCmdClient() (*camelv1.CamelV1Client, error)
  • func (command *RootCmdOptions) GetCmdClient() (client.Client, error)
  • func (command *RootCmdOptions) NewCmdClient() (client.Client, error)
• type RunConfigOption
  • func ParseConfigOption(item string) (*RunConfigOption, error)
  • func ParseResourceOption(item string) (*RunConfigOption, error)
  • func (runConfigOption *RunConfigOption) DestinationPath() string
  • func (runConfigOption *RunConfigOption) Key() string
  • func (runConfigOption *RunConfigOption) Name() string
  • func (runConfigOption *RunConfigOption) Type() string
  • func (runConfigOption *RunConfigOption) Validate() error
• type Source
  • func ResolveLocalSource(location string, compress bool) (Source, error)
  • func ResolveSources(ctx context.Context, locations []string, compress bool) ([]Source, error)

Constants

const (
	// ConfigOptionTypeConfigmap --
	ConfigOptionTypeConfigmap configOptionType = "configmap"
	// ConfigOptionTypeSecret --
	ConfigOptionTypeSecret configOptionType = "secret"
	// ConfigOptionTypeFile --
	ConfigOptionTypeFile configOptionType = "file"
)

const (
	// DefaultConfigName is the default config name
	DefaultConfigName = "kamel-config"

	// DefaultConfigLocation is the main place where the kamel content is stored
	DefaultConfigLocation = DefaultConfigName + ".yaml"

	// KamelTagName ---
	KamelTagName = "kamel"

	// MapstructureTagName ---
	MapstructureTagName = "mapstructure"
)

const (
	Megabyte = 1 << 20
	Kilobyte = 1 << 10
)

Variables

var VersionVariant = ""

VersionVariant may be overridden at build time

Functions

func ApplyConfigOption

func ApplyConfigOption(config *RunConfigOption, integrationSpec *v1.IntegrationSpec, c client.Client, namespace string, enableCompression bool) error

ApplyConfigOption will set the proper --config option behavior to the IntegrationSpec

func ApplyResourceOption

func ApplyResourceOption(config *RunConfigOption, integrationSpec *v1.IntegrationSpec, c client.Client, namespace string, enableCompression bool) error

ApplyResourceOption will set the proper --resource option behavior to the IntegrationSpec

func DeleteIntegration

func DeleteIntegration(ctx context.Context, c client.Client, name string, namespace string) error

DeleteIntegration --

func GetContainerIntegrationRunCommand

func GetContainerIntegrationRunCommand(ctx context.Context, properties []string, dependencies []string, routes []string, stdout, stderr io.Writer) (*exec.Cmd, error)

GetContainerIntegrationRunCommand --

func NewKamelCommand

func NewKamelCommand(ctx context.Context) (*cobra.Command, error)

NewKamelCommand --

func NewKamelWithModelineCommand

func NewKamelWithModelineCommand(ctx context.Context, osArgs []string) (*cobra.Command, []string, error)

NewKamelWithModelineCommand ---

func RunLocalIntegrationRunCommand

func RunLocalIntegrationRunCommand(ctx context.Context, properties []string, dependencies []string, routes []string, propertiesDir string, stdout, stderr io.Writer) error

RunLocalIntegrationRunCommand --

Types

type Config

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

Config is a helper class to manipulate kamel configuration files

func LoadConfiguration

func LoadConfiguration() (*Config, error)

LoadConfiguration loads a kamel configuration file

func (*Config) Delete

func (cfg *Config) Delete(path string)

Delete allows to remove a sub tree from the kamel content

func (*Config) Save

func (cfg *Config) Save() error

Save ---

func (*Config) SetNode

func (cfg *Config) SetNode(nodeID string, nodeValues map[string]interface{})

SetNode allows to replace a subtree with a given content

func (*Config) Update

func (cfg *Config) Update(cmd *cobra.Command, nodeID string, data interface{}, changedOnly bool)

Update ---

type RootCmdOptions

type RootCmdOptions struct {
	RootContext   context.Context    `mapstructure:"-"`
	Context       context.Context    `mapstructure:"-"`
	ContextCancel context.CancelFunc `mapstructure:"-"`

	KubeConfig string `mapstructure:"kube-config"`
	Namespace  string `mapstructure:"namespace"`
	// contains filtered or unexported fields
}

RootCmdOptions --

func (*RootCmdOptions) GetCamelCmdClient

func (command *RootCmdOptions) GetCamelCmdClient() (*camelv1.CamelV1Client, error)

GetCamelCmdClient returns a client to access the Camel resources

func (*RootCmdOptions) GetCmdClient

func (command *RootCmdOptions) GetCmdClient() (client.Client, error)

GetCmdClient returns the client that can be used from command line tools

func (*RootCmdOptions) NewCmdClient

func (command *RootCmdOptions) NewCmdClient() (client.Client, error)

NewCmdClient returns a new client that can be used from command line tools

type RunConfigOption

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

RunConfigOption represents a config option

func ParseConfigOption

func ParseConfigOption(item string) (*RunConfigOption, error)

ParseConfigOption will parse and return a runConfigOption

func ParseResourceOption

func ParseResourceOption(item string) (*RunConfigOption, error)

ParseResourceOption will parse and return a runConfigOption

func (*RunConfigOption) DestinationPath

func (runConfigOption *RunConfigOption) DestinationPath() string

DestinationPath is the location where the resource will be stored on destination

func (*RunConfigOption) Key

func (runConfigOption *RunConfigOption) Key() string

Key is the key specified for the resource

func (*RunConfigOption) Name

func (runConfigOption *RunConfigOption) Name() string

Name is the name of the resource

func (*RunConfigOption) Type

func (runConfigOption *RunConfigOption) Type() string

Type is the type, converted as string

func (*RunConfigOption) Validate

func (runConfigOption *RunConfigOption) Validate() error

Validate checks if the DestinationPath is correctly configured

type Source

type Source struct {
	Origin   string
	Location string
	Name     string
	Content  string
	Compress bool
	Local    bool
}

Source ---

func ResolveLocalSource

func ResolveLocalSource(location string, compress bool) (Source, error)

ResolveLocalSource --

func ResolveSources

func ResolveSources(ctx context.Context, locations []string, compress bool) ([]Source, error)

ResolveSources ---