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 SetupProcess(componentName string) (chan os.Signal, error)
• func UnlockService(serviceName, namespace string)
• func UpdateServiceSelector(svcName, namespace string, selector map[string]string) error

Constants

const LockTimeout = 3 * 60

LockTimeout 3 minutes

const UsageTemplate = `` /* 842-byte string literal not displayed */

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 SetupProcess

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

SetupProcess write pid file and set component type

func UnlockService

func UnlockService(serviceName, namespace string)

func UpdateServiceSelector

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