common

Documentation

Index

• Constants
• Variables
• func AddFakePod(ControllerHubURL string, pod types.FakePod)
• func ApplyLabel(nodeHandler string) error
• func CreateConfigMapforEdgeCore(cloudhub, cmHandler, nodeHandler string, numOfNodes int)
• func DeleteCloudDeployment(apiserver string)
• func DeleteEdgeDeployments(apiServerForRegisterNode, apiServerForDeployments string, nodes int)
• func DeleteFakePod(ControllerHubURL string, pod types.FakePod)
• func GetLatency(pods []types.FakePod) types.Latency
• func HandleCloudDeployment(...) error
• func HandleEdgeCorePodDeployment(depHandler, imgURL, podHandler, nodeHandler string, numOfNodes int) v1.PodList
• func HandleEdgeDeployment(cloudhub, depHandler, nodeHandler, cmHandler, imgURL, podHandler string, ...) v1.PodList
• func ListFakePods(ControllerHubURL string) []types.FakePod
• func SendHTTPRequest(method, reqAPI string, body io.Reader) (*http.Response, error)

Constants

const (
	AppHandler        = "/api/v1/namespaces/default/pods"
	NodeHandler       = "/api/v1/nodes"
	DeploymentHandler = "/apis/apps/v1/namespaces/default/deployments"
	ConfigmapHandler  = "/api/v1/namespaces/default/configmaps"
	ServiceHandler    = "/api/v1/namespaces/default/services"
	NodelabelKey      = "k8snode"
	NodelabelVal      = "kb-perf-node"
)

K8s resource handlers

Variables

var (
	Deployments         []string
	NodeInfo            = make(map[string][]string)
	CloudConfigMap      string
	CloudCoreDeployment string
	ToTaint             bool
	IsQuicProtocol      bool
)

Functions

func AddFakePod

func AddFakePod(ControllerHubURL string, pod types.FakePod)

AddFakePod adds a fake pod

func ApplyLabel

func ApplyLabel(nodeHandler string) error

func CreateConfigMapforEdgeCore

func CreateConfigMapforEdgeCore(cloudhub, cmHandler, nodeHandler string, numOfNodes int)

func DeleteCloudDeployment

func DeleteCloudDeployment(apiserver string)

func DeleteEdgeDeployments

func DeleteEdgeDeployments(apiServerForRegisterNode, apiServerForDeployments string, nodes int)

func DeleteFakePod

func DeleteFakePod(ControllerHubURL string, pod types.FakePod)

DeleteFakePod deletes a fake pod

func GetLatency

func GetLatency(pods []types.FakePod) types.Latency

GetLatency calculates latency based on different percent

func HandleCloudDeployment

func HandleCloudDeployment(cloudConfigMap, cloudCoreDeployment, apiserver2, confighdl, deploymenthdl, imgURL string, nodelimit int) error

func HandleEdgeCorePodDeployment

func HandleEdgeCorePodDeployment(depHandler, imgURL, podHandler, nodeHandler string, numOfNodes int) v1.PodList

func HandleEdgeDeployment

func HandleEdgeDeployment(cloudhub, depHandler, nodeHandler, cmHandler, imgURL, podHandler string, numOfNodes int) v1.PodList

func ListFakePods

func ListFakePods(ControllerHubURL string) []types.FakePod

ListFakePods lists all fake pods

func SendHTTPRequest

func SendHTTPRequest(method, reqAPI string, body io.Reader) (*http.Response, error)

SendHTTPRequest launches a http request