general

Documentation

Index

• func AppFlags(options *options.DaemonOptions, version string) []cli.Flag
• func CleanActionFlag(options *options.DaemonOptions) []cli.Flag
• func CleanupWorkspace(cli kt.CliInterface, opts *options.DaemonOptions)
• func CombineKubeOpts(options *options.DaemonOptions) error
• func ConnectActionFlag(options *options.DaemonOptions) []cli.Flag
• func CreateShadowAndInbound(ctx context.Context, k cluster.KubernetesInterface, ...) error
• func ExchangeActionFlag(options *options.DaemonOptions) []cli.Flag
• func GetDeploymentByResourceName(ctx context.Context, k cluster.KubernetesInterface, ...) (*appV1.Deployment, error)
• func GetServiceByResourceName(ctx context.Context, k cluster.KubernetesInterface, ...) (*coreV1.Service, error)
• func LockService(ctx context.Context, k cluster.KubernetesInterface, ...) error
• func MeshActionFlag(options *options.DaemonOptions) []cli.Flag
• func NewCliAuthor() []cli.Author
• func ParseResourceName(resourceName string) (string, string, error)
• func PreviewActionFlag(options *options.DaemonOptions) []cli.Flag
• func RecoverOriginalService(ctx context.Context, k cluster.KubernetesInterface, svcName, namespace string)
• func SetupProcess(cli kt.CliInterface, options *options.DaemonOptions, componentName string) (chan os.Signal, error)
• func UnlockService(ctx context.Context, k cluster.KubernetesInterface, ...)
• func UpdateServiceSelector(ctx context.Context, k cluster.KubernetesInterface, svcName, namespace string, ...) error

Functions

func AppFlags

func AppFlags(options *options.DaemonOptions, version string) []cli.Flag

AppFlags return app flags

func CleanActionFlag

func CleanActionFlag(options *options.DaemonOptions) []cli.Flag

func CleanupWorkspace

func CleanupWorkspace(cli kt.CliInterface, opts *options.DaemonOptions)

CleanupWorkspace clean workspace

func CombineKubeOpts

func CombineKubeOpts(options *options.DaemonOptions) error

CombineKubeOpts set default options of kubectl if not assign

func ConnectActionFlag

func ConnectActionFlag(options *options.DaemonOptions) []cli.Flag

ConnectActionFlag ...

func CreateShadowAndInbound

func CreateShadowAndInbound(ctx context.Context, k cluster.KubernetesInterface, shadowPodName, portsToExpose string,
	labels, annotations map[string]string, options *options.DaemonOptions) error

func ExchangeActionFlag

func ExchangeActionFlag(options *options.DaemonOptions) []cli.Flag

func GetDeploymentByResourceName

func GetDeploymentByResourceName(ctx context.Context, k cluster.KubernetesInterface, resourceName, namespace string) (*appV1.Deployment, error)

func GetServiceByResourceName

func GetServiceByResourceName(ctx context.Context, k cluster.KubernetesInterface, resourceName, namespace string) (*coreV1.Service, error)

func LockService

func LockService(ctx context.Context, k cluster.KubernetesInterface, serviceName, namespace string, times int) error

func MeshActionFlag

func MeshActionFlag(options *options.DaemonOptions) []cli.Flag

func NewCliAuthor

func NewCliAuthor() []cli.Author

NewCliAuthor return cli author

func ParseResourceName

func ParseResourceName(resourceName string) (string, string, error)

func PreviewActionFlag

func PreviewActionFlag(options *options.DaemonOptions) []cli.Flag

func RecoverOriginalService

func RecoverOriginalService(ctx context.Context, k cluster.KubernetesInterface, svcName, namespace string)

func SetupProcess

func SetupProcess(cli kt.CliInterface, options *options.DaemonOptions, componentName string) (chan os.Signal, error)

SetupProcess write pid file and print setup message

func UnlockService

func UnlockService(ctx context.Context, k cluster.KubernetesInterface, serviceName, namespace string)

func UpdateServiceSelector

func UpdateServiceSelector(ctx context.Context, k cluster.KubernetesInterface, svcName, namespace string, selector map[string]string) error