general

func AppFlags ¶

func AppFlags(options *opt.DaemonOptions) []cli.Flag

AppFlags return app flags

func CleanActionFlag ¶

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

func CleanupWorkspace ¶

func CleanupWorkspace()

CleanupWorkspace clean workspace

func CombineKubeOpts ¶

func CombineKubeOpts() error

CombineKubeOpts set default options of kubectl if not assign

func ConnectActionFlag ¶

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

ConnectActionFlag ...

func CreateShadowAndInbound ¶ added in v0.2.4

func CreateShadowAndInbound(shadowPodName, portsToExpose string, labels, annotations map[string]string) error

func ExchangeActionFlag ¶

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

func GetDeploymentByResourceName ¶ added in v0.3.0

func GetDeploymentByResourceName(resourceName, namespace string) (*appV1.Deployment, error)

func GetOccupiedUser ¶ added in v0.3.2

func GetOccupiedUser(labels map[string]string) string

func GetServiceByResourceName ¶ added in v0.2.4

func GetServiceByResourceName(resourceName, namespace string) (*coreV1.Service, error)

func LockService ¶ added in v0.3.0

func LockService(serviceName, namespace string, times int) (*coreV1.Service, error)

func MeshActionFlag ¶

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

func NewCliAuthor ¶

func NewCliAuthor() []cli.Author

NewCliAuthor return cli author

func ParseResourceName ¶ added in v0.3.0

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

func PreviewActionFlag ¶ added in v0.3.0

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

func RecoverActionFlag ¶ added in v0.3.2

func RecoverActionFlag(options *opt.DaemonOptions) []cli.Flag

func RecoverOriginalService ¶

func RecoverOriginalService(svcName, namespace string)

func SetupProcess ¶

func SetupProcess(componentName string, ch chan os.Signal) error

SetupProcess write pid file and print setup message

func UnlockService ¶ added in v0.2.4

func UnlockService(serviceName, namespace string)

func UpdateServiceSelector ¶ added in v0.2.4

func UpdateServiceSelector(svcName, namespace string, selector map[string]string) error