projects

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 26, 2021 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetControllerMode 

func GetControllerMode(controllerMode string) (modeType, modeURL string, err error)

GetControllerMode parse url with controller

Types

type Callback 

type Callback func()

Callback provides callback to process

type EdgeNodeDescription 

type EdgeNodeDescription struct {
	Key    string
	Serial string
	Model  string
}

EdgeNodeDescription must be defined in config file

func (*EdgeNodeDescription) GetEdgeNode 

func (nodeDescription *EdgeNodeDescription) GetEdgeNode(tc *TestContext) *device.Ctx

GetEdgeNode returns EdgeNode for provided EdgeNodeDescription based on onboarding key (if exists) or name

type EdgeNodeOption 

type EdgeNodeOption func(description *device.Ctx)

EdgeNodeOption is type to use for creation of device.Ctx

type GetEdgeNodeOpts 

type GetEdgeNodeOpts func(*device.Ctx) bool

GetEdgeNodeOpts pattern to pass device modifications

type ProcAppLogFunc 

type ProcAppLogFunc func(log *logs.LogEntry) error

ProcAppLogFunc provides callback to process app log

type ProcInfoFunc 

type ProcInfoFunc func(info *info.ZInfoMsg) error

ProcInfoFunc provides callback to process info

type ProcLogFlowFunc 

type ProcLogFlowFunc func(log *flowlog.FlowMessage) error

ProcLogFlowFunc provides callback to process flowLog

type ProcLogFunc 

type ProcLogFunc func(log *elog.FullLogEntry) error

ProcLogFunc provides callback to process log

type ProcMetricFunc 

type ProcMetricFunc func(metric *metrics.ZMetricMsg) error

ProcMetricFunc provides callback to process metric

type ProcTimerFunc 

type ProcTimerFunc func() error

ProcTimerFunc provides callback to process on timer event

func SendCommandSSH 

func SendCommandSSH(ip *string, port *int, user, password, command string, foreground bool, callbacks ...Callback) ProcTimerFunc

SendCommandSSH try to access SSH with timer and sends command

func SendFileSCP 

func SendFileSCP(ip *string, port *int, user, password, filename, destpath string) ProcTimerFunc

SendFileSCP sends a file over SCP

type Project 

type Project struct {
	// contains filtered or unexported fields
}

Project structure for test set

type State 

type State struct {
	// contains filtered or unexported fields
}

State aggregates device state

func InitState 

func InitState(device *device.Ctx) *State

InitState init State object for device

func (*State) CheckReady 

func (state *State) CheckReady() bool

CheckReady returns true in all needed information obtained from controller

func (*State) GetAinfoSlice 

func (state *State) GetAinfoSlice() []*info.ZInfoApp

GetAinfoSlice get []*info.ZInfoApp from obtained info

func (*State) GetAppMetrics 

func (state *State) GetAppMetrics() []*metrics.AppMetric

GetAppMetrics get []*metrics.AppMetric from obtained metrics

func (*State) GetBinfoSlice 

func (state *State) GetBinfoSlice() []*info.ZInfoBlob

GetBinfoSlice get []*info.ZInfoBlob from obtained info

func (*State) GetCinfoSlice 

func (state *State) GetCinfoSlice() []*info.ZInfoContentTree

GetCinfoSlice get []*info.ZInfoContentTree from obtained info

func (*State) GetDeviceMetrics 

func (state *State) GetDeviceMetrics() *metrics.DeviceMetric

GetDeviceMetrics get *metrics.DeviceMetric from obtained metrics

func (*State) GetDinfo 

func (state *State) GetDinfo() *info.ZInfoDevice

GetDinfo get *info.ZInfoDevice from obtained info

func (*State) GetInfoProcessingFunction 

func (state *State) GetInfoProcessingFunction() ProcInfoFunc

GetInfoProcessingFunction returns processing function for ZInfoMsg

func (*State) GetLastInfoTime 

func (state *State) GetLastInfoTime() *timestamp.Timestamp

GetLastInfoTime get *timestamp.Timestamp for last received info

func (*State) GetMetricProcessingFunction 

func (state *State) GetMetricProcessingFunction() ProcMetricFunc

GetMetricProcessingFunction returns processing function for ZMetricMsg

func (*State) GetNetworkInstanceMetrics 

func (state *State) GetNetworkInstanceMetrics() []*metrics.ZMetricNetworkInstance

GetNetworkInstanceMetrics get []*metrics.ZMetricNetworkInstance from obtained metrics

func (*State) GetNiinfoSlice 

func (state *State) GetNiinfoSlice() []*info.ZInfoNetworkInstance

GetNiinfoSlice get []*info.ZInfoNetworkInstance from obtained info

func (*State) GetVinfoSlice 

func (state *State) GetVinfoSlice() []*info.ZInfoVolume

GetVinfoSlice get []*info.ZInfoVolume from obtained info

func (*State) GetVolumeMetrics 

func (state *State) GetVolumeMetrics() []*metrics.ZMetricVolume

GetVolumeMetrics get []*metrics.ZMetricVolume from obtained metrics

func (*State) LookUp 

func (state *State) LookUp(path string) (value reflect.Value, err error)

LookUp access fields of State objects by path path contains address to lookup for example: LookUp("Dinfo.Network[0].IPAddrs[0]") will return first IP of first network of EVE All top fields to lookup in: Dinfo *info.ZInfoDevice Ainfo []*info.ZInfoApp Niinfo []*info.ZInfoNetworkInstance Vinfo []*info.ZInfoVolume Cinfo []*info.ZInfoContentTree Binfo []*info.ZInfoBlob Cipherinfo []*info.ZInfoCipher AppMetrics []*metrics.AppMetric NetworkInstanceMetrics []*metrics.ZMetricNetworkInstance VolumeMetrics []*metrics.ZMetricVolume DeviceMetrics *metrics.DeviceMetric

type TestContext 

type TestContext struct {
	// contains filtered or unexported fields
}

TestContext is main structure for running tests

func NewTestContext 

func NewTestContext() *TestContext

NewTestContext creates new TestContext

func (*TestContext) AddEdgeNodesFromDescription 

func (tc *TestContext) AddEdgeNodesFromDescription()

AddEdgeNodesFromDescription adds EdgeNodes from description in test.eve param

func (*TestContext) AddNode 

func (tc *TestContext) AddNode(node *device.Ctx)

AddNode add node to test context

func (*TestContext) AddProcAppLog 

func (tc *TestContext) AddProcAppLog(edgeNode *device.Ctx, appUUID uuid.UUID, processFunction ProcAppLogFunc)

AddProcAppLog add processFunction, that will get all app logs for edgeNode

func (*TestContext) AddProcFlowLog 

func (tc *TestContext) AddProcFlowLog(edgeNode *device.Ctx, processFunction ProcLogFlowFunc)

AddProcFlowLog add processFunction, that will get all FlowLogs for edgeNode

func (*TestContext) AddProcInfo 

func (tc *TestContext) AddProcInfo(edgeNode *device.Ctx, processFunction ProcInfoFunc)

AddProcInfo add processFunction, that will get all info for edgeNode

func (*TestContext) AddProcLog 

func (tc *TestContext) AddProcLog(edgeNode *device.Ctx, processFunction ProcLogFunc)

AddProcLog add processFunction, that will get all logs for edgeNode

func (*TestContext) AddProcMetric 

func (tc *TestContext) AddProcMetric(edgeNode *device.Ctx, processFunction ProcMetricFunc)

AddProcMetric add processFunction, that will get all metrics for edgeNode

func (*TestContext) AddProcTimer 

func (tc *TestContext) AddProcTimer(edgeNode *device.Ctx, processFunction ProcTimerFunc)

AddProcTimer add processFunction, that will fire with time intervals for edgeNode

func (*TestContext) CheckMessageInAppLog 

func (tc *TestContext) CheckMessageInAppLog(edgeNode *device.Ctx, appID uuid.UUID, message string, callbacks ...Callback) ProcTimerFunc

CheckMessageInAppLog try to find message in logs of app

func (*TestContext) ConfigSync 

func (tc *TestContext) ConfigSync(edgeNode *device.Ctx)

ConfigSync send config to controller

func (*TestContext) ExpandOnSuccess 

func (tc *TestContext) ExpandOnSuccess(secs int)

ExpandOnSuccess adds additional time to global timeout on every success check

func (*TestContext) GetController 

func (tc *TestContext) GetController() controller.Cloud

GetController returns current controller

func (*TestContext) GetEdgeNode 

func (tc *TestContext) GetEdgeNode(opts ...GetEdgeNodeOpts) *device.Ctx

GetEdgeNode return node from context

func (*TestContext) GetNodeDescriptions 

func (tc *TestContext) GetNodeDescriptions() (nodes []*EdgeNodeDescription)

GetNodeDescriptions returns list of nodes from config

func (*TestContext) GetState 

func (tc *TestContext) GetState(edgeNode *device.Ctx) *State

GetState returns State object for edgeNode

func (*TestContext) InitProject 

func (tc *TestContext) InitProject(name string)

InitProject init project object with defined name

func (*TestContext) NewEdgeNode 

func (tc *TestContext) NewEdgeNode(opts ...EdgeNodeOption) *device.Ctx

NewEdgeNode creates edge node

func (*TestContext) StartTrackingState 

func (tc *TestContext) StartTrackingState(onlyNewElements bool)

StartTrackingState init function for State monitoring if onlyNewElements set no use old information from controller

func (*TestContext) UpdateEdgeNode 

func (tc *TestContext) UpdateEdgeNode(edgeNode *device.Ctx, opts ...EdgeNodeOption)

UpdateEdgeNode update edge node

func (*TestContext) WaitForProc 

func (tc *TestContext) WaitForProc(secs int)

WaitForProc blocking execution until the time elapses or all Procs gone returns error on timeout

func (*TestContext) WaitForProcWithErrorCallback 

func (tc *TestContext) WaitForProcWithErrorCallback(secs int, callback Callback)

WaitForProcWithErrorCallback blocking execution until the time elapses or all Procs gone and fires callback in case of timeout

func (*TestContext) WaitForState 

func (tc *TestContext) WaitForState(edgeNode *device.Ctx, secs int)

WaitForState wait for State initialization from controller

func (*TestContext) WithCurrentProject 

func (tc *TestContext) WithCurrentProject() EdgeNodeOption

WithCurrentProject sets project info

func (*TestContext) WithDeviceModel 

func (tc *TestContext) WithDeviceModel(devModel string) EdgeNodeOption

WithDeviceModel sets device model info

func (*TestContext) WithNodeDescription 

func (tc *TestContext) WithNodeDescription(nodeDescription *EdgeNodeDescription) EdgeNodeOption

WithNodeDescription sets device info

func (*TestContext) WithTest 

func (tc *TestContext) WithTest(t *testing.T) GetEdgeNodeOpts

WithTest assign *testing.T for device

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.