general

Documentation

Index

• Constants
• func CleanupWorkspace()
• func CreateShadowAndInbound(shadowPodName, portsToExpose string, labels, annotations map[string]string, ...) error
• func GetDeploymentByResourceName(resourceName, namespace string) (*appV1.Deployment, error)
• func GetOccupiedUser(labels map[string]string) string
• func GetServiceByResourceName(resourceName, namespace string) (*coreV1.Service, error)
• func GetTargetPorts(svc *coreV1.Service) map[int]string
• func LockService(serviceName, namespace string, times int) (*coreV1.Service, error)
• func ParseResourceName(resourceName string) (string, string, error)
• func Prepare() error
• func RecoverOriginalService(svcName, namespace string)
• func SetupLogger()
• func SetupProcess(componentName string) (chan os.Signal, error)
• func SimpleSubCommand(name, usage string, action func(args []string) error, ...) *cobra.Command
• func UnlockService(serviceName, namespace string)
• func UpdateServiceSelector(svcName, namespace string, selector map[string]string) error
• func UsageTemplate(showInheritedFlags bool) string

Constants

const LockTimeout = 3 * 60

LockTimeout 3 minutes

Functions

func CleanupWorkspace

func CleanupWorkspace()

CleanupWorkspace clean workspace

func CreateShadowAndInbound

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

func GetDeploymentByResourceName

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

func GetOccupiedUser

func GetOccupiedUser(labels map[string]string) string

func GetServiceByResourceName

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

func GetTargetPorts

func GetTargetPorts(svc *coreV1.Service) map[int]string

func LockService

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

func ParseResourceName

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

func Prepare

func Prepare() error

Prepare setup log level, time difference and kube config

func RecoverOriginalService

func RecoverOriginalService(svcName, namespace string)

func SetupLogger

func SetupLogger()

func SetupProcess

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

SetupProcess write pid file and set component type

func SimpleSubCommand

func SimpleSubCommand(name, usage string, action func(args []string) error, postHandler func(cmd *cobra.Command)) *cobra.Command

func UnlockService

func UnlockService(serviceName, namespace string)

func UpdateServiceSelector

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

func UsageTemplate

func UsageTemplate(showInheritedFlags bool) string