Versions in this module Expand all Collapse all v1 v1.0.1 Dec 9, 2024 v1.0.0 Dec 2, 2024 Changes in this version + func InitBus(tc *TestContext) *processingBus + type Callback func() + type EdgeNodeDescription struct + Key string + Model string + Serial string + func (nodeDescription *EdgeNodeDescription) GetEdgeNode(tc *TestContext) *device.Ctx + type EdgeNodeOption func(description *device.Ctx) + type GetEdgeNodeOpts func(*device.Ctx) bool + type ProcAppLogFunc func(log *logs.LogEntry) error + type ProcInfoFunc func(info *info.ZInfoMsg) error + type ProcLogFlowFunc func(log *flowlog.FlowMessage) error + type ProcLogFunc func(log *elog.FullLogEntry) error + type ProcMetricFunc func(metric *metrics.ZMetricMsg) error + type ProcTimerFunc func() error + func SendCommandSSH(ip *string, port *int, user, password, command string, foreground bool, ...) ProcTimerFunc + func SendFileSCP(ip *string, port *int, user, password, filename, destpath string) ProcTimerFunc + type Project struct + type State struct + func InitState(device *device.Ctx) *State + func (state *State) CheckReady() bool + func (state *State) GetAinfoSlice() []*info.ZInfoApp + func (state *State) GetAppMetrics() []*metrics.AppMetric + func (state *State) GetBinfoSlice() []*info.ZInfoBlob + func (state *State) GetCinfoSlice() []*info.ZInfoContentTree + func (state *State) GetDeviceMetrics() *metrics.DeviceMetric + func (state *State) GetDinfo() *info.ZInfoDevice + func (state *State) GetInfoProcessingFunction() ProcInfoFunc + func (state *State) GetLastInfoTime() *timestamppb.Timestamp + func (state *State) GetMetricProcessingFunction() ProcMetricFunc + func (state *State) GetNetworkInstanceMetrics() []*metrics.ZMetricNetworkInstance + func (state *State) GetNiinfoSlice() []*info.ZInfoNetworkInstance + func (state *State) GetVinfoSlice() []*info.ZInfoVolume + func (state *State) GetVolumeMetrics() []*metrics.ZMetricVolume + func (state *State) LookUp(path string) (value reflect.Value, err error) + type TestContext struct + Cloud controller.Cloud + ProcBus *processingBus + SdnClient *edensdn.SdnClient + Tests map[*device.Ctx]*testing.T + WithSdn bool + func NewTestContext() *TestContext + func (tc *TestContext) AddEdgeNodesFromDescription() + func (tc *TestContext) AddNode(node *device.Ctx) + func (tc *TestContext) AddProcAppLog(edgeNode *device.Ctx, appUUID uuid.UUID, processFunction ProcAppLogFunc) + func (tc *TestContext) AddProcFlowLog(edgeNode *device.Ctx, processFunction ProcLogFlowFunc) + func (tc *TestContext) AddProcInfo(edgeNode *device.Ctx, processFunction ProcInfoFunc) + func (tc *TestContext) AddProcLog(edgeNode *device.Ctx, processFunction ProcLogFunc) + func (tc *TestContext) AddProcMetric(edgeNode *device.Ctx, processFunction ProcMetricFunc) + func (tc *TestContext) AddProcTimer(edgeNode *device.Ctx, processFunction ProcTimerFunc) + func (tc *TestContext) CheckMessageInAppLog(edgeNode *device.Ctx, appID uuid.UUID, message string, callbacks ...Callback) ProcTimerFunc + func (tc *TestContext) ConfigSync(edgeNode *device.Ctx) + func (tc *TestContext) ExpandOnSuccess(secs int) + func (tc *TestContext) GetController() controller.Cloud + func (tc *TestContext) GetEdgeNode(opts ...GetEdgeNodeOpts) *device.Ctx + func (tc *TestContext) GetNodeDescriptions() (nodes []*EdgeNodeDescription) + func (tc *TestContext) GetState(edgeNode *device.Ctx) *State + func (tc *TestContext) InitProject(name string) + func (tc *TestContext) NewEdgeNode(opts ...EdgeNodeOption) *device.Ctx + func (tc *TestContext) PortForwardCommand(cmd func(fwdPort uint16) error, eveIfName string, targetPort uint16) error + func (tc *TestContext) StartTrackingState(onlyNewElements bool) + func (tc *TestContext) UpdateEdgeNode(edgeNode *device.Ctx, opts ...EdgeNodeOption) + func (tc *TestContext) WaitForProc(secs int) + func (tc *TestContext) WaitForProcWithErrorCallback(secs int, callback Callback) + func (tc *TestContext) WaitForState(edgeNode *device.Ctx, secs int) + func (tc *TestContext) WithCurrentProject() EdgeNodeOption + func (tc *TestContext) WithDeviceModel(devModel string) EdgeNodeOption + func (tc *TestContext) WithNodeDescription(nodeDescription *EdgeNodeDescription) EdgeNodeOption + func (tc *TestContext) WithTest(t *testing.T) GetEdgeNodeOpts