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 GetServiceByResourceName(ctx context.Context, k cluster.KubernetesInterface, resourceName string, ...) (string, error)
• func LockAndFetchService(ctx context.Context, k cluster.KubernetesInterface, ...) (*coreV1.Service, error)
• func MeshActionFlag(options *options.DaemonOptions) []cli.Flag
• func NewCliAuthor() []cli.Author
• func ProvideActionFlag(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, svc *coreV1.Service, ...) 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 GetServiceByResourceName

func GetServiceByResourceName(ctx context.Context, k cluster.KubernetesInterface, resourceName string, opts *options.DaemonOptions) (string, error)

func LockAndFetchService

func LockAndFetchService(ctx context.Context, k cluster.KubernetesInterface, serviceName, namespace string, times int) (*coreV1.Service, error)

func MeshActionFlag

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

func NewCliAuthor

func NewCliAuthor() []cli.Author

NewCliAuthor return cli author

func ProvideActionFlag

func ProvideActionFlag(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, svc *coreV1.Service, selector map[string]string) error