Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

utils

package

Go to main page

Versions in this module

v1

v1.0.0

Jun 26, 2019

Changes in this version

+ const DeviceETPrefix

+ const TwinETGetResultSuffix

+ const TwinETGetSuffix

+ const TwinETUpdateSuffix

+ var Client MQTT.Client

+ var ClientOpts *MQTT.ClientOptions

+ var ProtocolQuic bool

+ var ProtocolWebsocket bool

+ func ChangeTwinValue(updateMessage DeviceTwinUpdate, deviceID string) error

+ func CleanUp(setupType string) error

+ func CompareConfigMaps(configMap, expectedConfigMap v1.ConfigMap) bool

+ func CompareTwin(deviceTwin map[string]*MsgTwin, expectedDeviceTwin map[string]*MsgTwin) bool

+ func DeleteConfigmap(apiConfigMap string) int

+ func DeploySetup(ctx *TestContext, nodeName, setupType string) error

+ func Err(format string, args ...interface{})

+ func GenerateCerts() error

+ func GetDevice(list *v1alpha1.DeviceList, getDeviceApi string, ...) ([]v1alpha1.Device, error)

+ func GetDeviceModel(list *v1alpha1.DeviceModelList, getDeviceModelApi string, ...) ([]v1alpha1.DeviceModel, error)

+ func GetTwin(updateMessage DeviceTwinUpdate, deviceID string) error

+ func HandleDeviceInstance(operation string, apiserver string, nodeSelector string, UID string, ...) (bool, int)

+ func HandleDeviceModel(operation string, apiserver string, UID string, protocolType string) (bool, int)

+ func IncorrectDeviceInstance() v1alpha1.Device

+ func IncorrectDeviceModel() v1alpha1.DeviceModel

+ func MqttClientInit(server, clientID, username, password string) *MQTT.ClientOptions

+ func MqttConnect() error

+ func NewBluetoothDeviceInstance(nodeSelector string) v1alpha1.Device

+ func NewBluetoothDeviceModel() v1alpha1.DeviceModel

+ func NewConfigMapBluetooth(nodeSelector string) v12.ConfigMap

+ func NewConfigMapLED(nodeSelector string) v12.ConfigMap

+ func NewConfigMapModbus(nodeSelector string) v12.ConfigMap

+ func NewLedDeviceInstance(nodeSelector string) v1alpha1.Device

+ func NewLedDeviceModel() v1alpha1.DeviceModel

+ func NewModbusDeviceInstance(nodeSelector string) v1alpha1.Device

+ func NewModbusDeviceModel() v1alpha1.DeviceModel

+ func OnTwinMessageReceived(client MQTT.Client, message MQTT.Message)

+ func StartEdgeController() error

+ func StartEdgeCore() error

+ func StartEdgeSite() error

+ func TwinSubscribe(deviceID string)

+ func UpdatedBluetoothDeviceInstance(nodeSelector string) v1alpha1.Device

+ func UpdatedBluetoothDeviceModel() v1alpha1.DeviceModel

+ func UpdatedLedDeviceInstance(nodeSelector string) v1alpha1.Device

+ func UpdatedLedDeviceModel() v1alpha1.DeviceModel

+ func UpdatedModbusDeviceInstance(nodeSelector string) v1alpha1.Device

+ func UpdatedModbusDeviceModel() v1alpha1.DeviceModel

+ type BaseMessage struct

+ EventID string

+ Timestamp int64

type Config

+ ControllerStubPort int

+ K8SMasterForKubeEdge string

+ K8SMasterForProvisionEdgeNodes string

+ Protocol string

+ type DeviceTwinResult struct

+ Twin map[string]*MsgTwin

+ var TwinResult DeviceTwinResult

+ type DeviceTwinUpdate struct

+ Twin map[string]*MsgTwin

+ type MsgTwin struct

+ Actual *TwinValue

+ ActualVersion *TwinVersion

+ Expected *TwinValue

+ ExpectedVersion *TwinVersion

+ Metadata *TypeMetadata

+ Optional *bool

+ type Token interface

+ Error func() error

+ Wait func() bool

+ WaitTimeout func(time.Duration) bool

+ var TokenClient Token

+ type TwinValue struct

+ Metadata *ValueMetadata

+ Value *string

+ type TwinVersion struct

+ CloudVersion int64

+ EdgeVersion int64

+ type TypeMetadata struct

+ Type string

+ type ValueMetadata struct

+ Timestamp int64

v1.0.0-beta.0

Jun 21, 2019

v0

v0.3.0

May 29, 2019

Changes in this version

+ const Namespace

+ func ApplyLabelToNode(apiserver, key, val string) error

+ func CheckDeploymentPodDeleteState(apiserver string, podlist v1.PodList)

+ func CreateServiceObject(name string) *v1.Service

+ func DeleteSvc(svcname string) int

+ func ExposeCloudService(name, serviceHandler string) error

+ func GetConfigmap(apiConfigMap string) int

+ func GetNodes(api string) v1.NodeList

+ func GetServicePort(cloudName, serviceHandler string) int32

+ func HandleConfigmap(configName chan error, operation, confighandler string, IsEdgeCore bool)

+ func NewKubeClient(apiserver string) *kubernetes.Clientset

+ func TaintEdgeDeployedNode(toTaint bool, taintHandler string) error

+ func VerifyDeleteDeployment(getDeploymentApi string) int

+ func WaitforPodsRunning(apiserver string, podlist v1.PodList, timout time.Duration)

type Config

+ ApiServer2 string

+ CloudImageUrl string

+ EdgeController string

+ EdgeImageUrl string

+ ImageRepo string

+ Namespace string

+ Nodes map[string]vmSpec

+ NumOfNodes int

+ type TestTimer struct

+ EndTime time.Time

+ Name string

+ StartTime time.Time

+ func (testTimer *TestTimer) Duration() time.Duration

+ func (testTimer *TestTimer) End()

+ func (testTimer *TestTimer) IsEnded() bool

+ func (testTimer *TestTimer) PrintResult()

+ type TestTimerGroup struct

+ func NewTestTimerGroup() *TestTimerGroup

+ func (group *TestTimerGroup) GetTestTimers() []*TestTimer

+ func (group *TestTimerGroup) NewTestTimer(name string) *TestTimer

+ func (group *TestTimerGroup) PrintResult()

v0.3.0-beta.0

May 3, 2019

v0.2.1

Apr 15, 2019

Changes in this version

+ func CheckNodeDeleteStatus(ctx *TestContext, nodehandler, nodename string) int

+ func CheckNodeReadyStatus(ctx *TestContext, nodehandler, nodename string) string

+ func CheckPodDeleteState(apiserver string, podlist v1.PodList)

+ func CheckPodRunningState(apiserver string, podlist v1.PodList)

+ func DeRegisterNodeFromMaster(ctx *TestContext, nodehandler, nodename string) error

+ func Debug(format string, data []byte, err error)

+ func DeleteDeployment(DeploymentApi, deploymentname string) int

+ func DeletePods(apiserver string) (string, int)

+ func Failf(format string, args ...interface{})

+ func GenerateNodeReqBody(nodeid, nodeselector string) (error, map[string]interface{})

+ func GetDeployments(list *apps.DeploymentList, getDeploymentApi string) error

+ func GetPodState(apiserver string) (string, int)

+ func GetPods(apiserver, label string) (v1.PodList, error)

+ func GetRandomString(length int) string

+ func HandleDeployment(operation, apiserver, UID, ImageUrl, nodeselector string, replica int) bool

+ func HandlePod(operation string, apiserver string, UID string, ImageUrl, nodeselector string) bool

+ func Info(format string, args ...interface{})

+ func InfoV2(format string, args ...interface{})

+ func InfoV6(format string, args ...interface{})

+ func Logf(format string, args ...interface{})

+ func MapLabels(ls map[string]string) string

+ func PrintCombinedOutput(cmd *exec.Cmd) error

+ func PrintTestcaseNameandStatus()

+ func RandomInt(min, max int) int

+ func RegisterNodeToMaster(ctx *TestContext, UID, nodehandler, nodeselector string) error

+ func SendHttpRequest(method, reqApi string) (error, *http.Response)

+ type Config struct

+ ApiServer string

+ AppImageUrl []string

+ EdgedEndpoint string

+ func LoadConfig() Config

+ type TestContext struct

+ Cfg Config

+ func NewTestContext(cfg Config) *TestContext