testutil

package
v1.2.5 Latest Latest
Warning

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

Go to latest
Published: Sep 23, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

README

Test utilities

This package is used for unit-test support code. It should only be included in unit test code, and never in main or shipping code. It is part of its own package so that it can be referenced from other package's unit test files (_test.go files from other packages cannot be referenced in a unit test file).

Some of these files may be auto-generated from protoc-gen-test.

Documentation

Index

Constants

View Source
const TagExpectErr = "expecterr"

Variables

View Source
var AlertPolicyShowExtraCount = 0
View Source
var AlertShowExtraCount = 0
View Source
var AppInstInfoShowExtraCount = 0
View Source
var AppInstRefsShowExtraCount = 0
View Source
var AppInstShowExtraCount = 0
View Source
var AppShowExtraCount = 0
View Source
var AutoProvPolicyShowExtraCount = 0
View Source
var AutoScalePolicyShowExtraCount = 0
View Source
var CloudletInfoShowExtraCount = 0
View Source
var CloudletNodeShowExtraCount = 0
View Source
var CloudletPoolShowExtraCount = 0
View Source
var CloudletRefsShowExtraCount = 0
View Source
var CloudletShowExtraCount = 0
View Source
var ClusterInstInfoShowExtraCount = 0
View Source
var ClusterInstShowExtraCount = 0
View Source
var ClusterRefsShowExtraCount = 0
View Source
var DeviceShowExtraCount = 0
View Source
var FlavorShowExtraCount = 0
View Source
var GPUDriverShowExtraCount = 0
View Source
var NetworkShowExtraCount = 0
View Source
var NoApiCallback = func(string) {}
View Source
var NodeShowExtraCount = 0
View Source
var OperatorCodeShowExtraCount = 0
View Source
var ResTagTableShowExtraCount = 0
View Source
var ShowCloudletsForAppDeploymentExtraCount = 0
View Source
var ShowFlavorsForCloudletExtraCount = 0
View Source
var TrustPolicyExceptionShowExtraCount = 0
View Source
var TrustPolicyShowExtraCount = 0
View Source
var VMPoolShowExtraCount = 0

Functions

func AlertData

func AlertData() []edgeproto.Alert

func AlertPolicyData

func AlertPolicyData() []edgeproto.AlertPolicy

func AlertPolicyReadStream

func AlertPolicyReadStream(stream AlertPolicyStream) ([]edgeproto.AlertPolicy, error)

func AlertReadStream

func AlertReadStream(stream AlertStream) ([]edgeproto.Alert, error)

func AppData

func AppData() []edgeproto.App

func AppInstClientData

func AppInstClientData() []edgeproto.AppInstClient

func AppInstClientKeyData

func AppInstClientKeyData() []edgeproto.AppInstClientKey

func AppInstClientReadStream

func AppInstClientReadStream(stream AppInstClientStream) ([]edgeproto.AppInstClient, error)

func AppInstData

func AppInstData() []edgeproto.AppInst

func AppInstInfoData

func AppInstInfoData() []edgeproto.AppInstInfo

func AppInstInfoReadStream

func AppInstInfoReadStream(stream AppInstInfoStream) ([]edgeproto.AppInstInfo, error)

func AppInstMetricsReadStream

func AppInstMetricsReadStream(stream AppInstMetricsStream) ([]edgeproto.AppInstMetrics, error)

func AppInstReadResultStream

func AppInstReadResultStream(stream ResultStream, err error) error

func AppInstReadStream

func AppInstReadStream(stream AppInstStream) ([]edgeproto.AppInst, error)

func AppInstRefsReadStream

func AppInstRefsReadStream(stream AppInstRefsStream) ([]edgeproto.AppInstRefs, error)

func AppReadStream

func AppReadStream(stream AppStream) ([]edgeproto.App, error)

func AutoProvPolicyData

func AutoProvPolicyData() []edgeproto.AutoProvPolicy

func AutoProvPolicyReadStream

func AutoProvPolicyReadStream(stream AutoProvPolicyStream) ([]edgeproto.AutoProvPolicy, error)

func AutoScalePolicyData

func AutoScalePolicyData() []edgeproto.AutoScalePolicy

func AutoScalePolicyReadStream

func AutoScalePolicyReadStream(stream AutoScalePolicyStream) ([]edgeproto.AutoScalePolicy, error)

func ClientAlertPolicyCreate

func ClientAlertPolicyCreate(t *testing.T, api edgeproto.AlertPolicyApiClient, testData []edgeproto.AlertPolicy)

func ClientAlertPolicyDelete

func ClientAlertPolicyDelete(t *testing.T, api edgeproto.AlertPolicyApiClient, testData []edgeproto.AlertPolicy)

func ClientAlertPolicyTest

func ClientAlertPolicyTest(t *testing.T, test string, api edgeproto.AlertPolicyApiClient, testData []edgeproto.AlertPolicy, ops ...AlertPolicyTestOp)

func ClientAlertTest

func ClientAlertTest(t *testing.T, test string, api edgeproto.AlertApiClient, testData []edgeproto.Alert, ops ...AlertTestOp)

func ClientAppCreate

func ClientAppCreate(t *testing.T, api edgeproto.AppApiClient, testData []edgeproto.App)

func ClientAppDelete

func ClientAppDelete(t *testing.T, api edgeproto.AppApiClient, testData []edgeproto.App)

func ClientAppInstCreate

func ClientAppInstCreate(t *testing.T, api edgeproto.AppInstApiClient, testData []edgeproto.AppInst)

func ClientAppInstDelete

func ClientAppInstDelete(t *testing.T, api edgeproto.AppInstApiClient, testData []edgeproto.AppInst)

func ClientAppInstInfoTest

func ClientAppInstInfoTest(t *testing.T, test string, api edgeproto.AppInstInfoApiClient, testData []edgeproto.AppInstInfo, ops ...AppInstInfoTestOp)

func ClientAppInstRefsTest

func ClientAppInstRefsTest(t *testing.T, test string, api edgeproto.AppInstRefsApiClient, testData []edgeproto.AppInstRefs, ops ...AppInstRefsTestOp)

func ClientAppInstTest

func ClientAppInstTest(t *testing.T, test string, api edgeproto.AppInstApiClient, testData []edgeproto.AppInst, ops ...AppInstTestOp)

func ClientAppTest

func ClientAppTest(t *testing.T, test string, api edgeproto.AppApiClient, testData []edgeproto.App, ops ...AppTestOp)

func ClientAutoProvPolicyCreate

func ClientAutoProvPolicyCreate(t *testing.T, api edgeproto.AutoProvPolicyApiClient, testData []edgeproto.AutoProvPolicy)

func ClientAutoProvPolicyDelete

func ClientAutoProvPolicyDelete(t *testing.T, api edgeproto.AutoProvPolicyApiClient, testData []edgeproto.AutoProvPolicy)

func ClientAutoProvPolicyTest

func ClientAutoProvPolicyTest(t *testing.T, test string, api edgeproto.AutoProvPolicyApiClient, testData []edgeproto.AutoProvPolicy, ops ...AutoProvPolicyTestOp)

func ClientAutoScalePolicyCreate

func ClientAutoScalePolicyCreate(t *testing.T, api edgeproto.AutoScalePolicyApiClient, testData []edgeproto.AutoScalePolicy)

func ClientAutoScalePolicyDelete

func ClientAutoScalePolicyDelete(t *testing.T, api edgeproto.AutoScalePolicyApiClient, testData []edgeproto.AutoScalePolicy)

func ClientAutoScalePolicyTest

func ClientAutoScalePolicyTest(t *testing.T, test string, api edgeproto.AutoScalePolicyApiClient, testData []edgeproto.AutoScalePolicy, ops ...AutoScalePolicyTestOp)

func ClientCloudletCreate

func ClientCloudletCreate(t *testing.T, api edgeproto.CloudletApiClient, testData []edgeproto.Cloudlet)

func ClientCloudletDelete

func ClientCloudletDelete(t *testing.T, api edgeproto.CloudletApiClient, testData []edgeproto.Cloudlet)

func ClientCloudletInfoTest

func ClientCloudletInfoTest(t *testing.T, test string, api edgeproto.CloudletInfoApiClient, testData []edgeproto.CloudletInfo, ops ...CloudletInfoTestOp)

func ClientCloudletNodeCreate

func ClientCloudletNodeCreate(t *testing.T, api edgeproto.CloudletNodeApiClient, testData []edgeproto.CloudletNode)

func ClientCloudletNodeDelete

func ClientCloudletNodeDelete(t *testing.T, api edgeproto.CloudletNodeApiClient, testData []edgeproto.CloudletNode)

func ClientCloudletNodeTest

func ClientCloudletNodeTest(t *testing.T, test string, api edgeproto.CloudletNodeApiClient, testData []edgeproto.CloudletNode, ops ...CloudletNodeTestOp)

func ClientCloudletPoolCreate

func ClientCloudletPoolCreate(t *testing.T, api edgeproto.CloudletPoolApiClient, testData []edgeproto.CloudletPool)

func ClientCloudletPoolDelete

func ClientCloudletPoolDelete(t *testing.T, api edgeproto.CloudletPoolApiClient, testData []edgeproto.CloudletPool)

func ClientCloudletPoolTest

func ClientCloudletPoolTest(t *testing.T, test string, api edgeproto.CloudletPoolApiClient, testData []edgeproto.CloudletPool, ops ...CloudletPoolTestOp)

func ClientCloudletRefsTest

func ClientCloudletRefsTest(t *testing.T, test string, api edgeproto.CloudletRefsApiClient, testData []edgeproto.CloudletRefs, ops ...CloudletRefsTestOp)

func ClientCloudletTest

func ClientCloudletTest(t *testing.T, test string, api edgeproto.CloudletApiClient, testData []edgeproto.Cloudlet, ops ...CloudletTestOp)

func ClientClusterInstCreate

func ClientClusterInstCreate(t *testing.T, api edgeproto.ClusterInstApiClient, testData []edgeproto.ClusterInst)

func ClientClusterInstDelete

func ClientClusterInstDelete(t *testing.T, api edgeproto.ClusterInstApiClient, testData []edgeproto.ClusterInst)

func ClientClusterInstInfoTest

func ClientClusterInstInfoTest(t *testing.T, test string, api edgeproto.ClusterInstInfoApiClient, testData []edgeproto.ClusterInstInfo, ops ...ClusterInstInfoTestOp)

func ClientClusterInstTest

func ClientClusterInstTest(t *testing.T, test string, api edgeproto.ClusterInstApiClient, testData []edgeproto.ClusterInst, ops ...ClusterInstTestOp)

func ClientClusterRefsTest

func ClientClusterRefsTest(t *testing.T, test string, api edgeproto.ClusterRefsApiClient, testData []edgeproto.ClusterRefs, ops ...ClusterRefsTestOp)

func ClientDeviceTest

func ClientDeviceTest(t *testing.T, test string, api edgeproto.DeviceApiClient, testData []edgeproto.Device, ops ...DeviceTestOp)

func ClientFlavorCreate

func ClientFlavorCreate(t *testing.T, api edgeproto.FlavorApiClient, testData []edgeproto.Flavor)

func ClientFlavorDelete

func ClientFlavorDelete(t *testing.T, api edgeproto.FlavorApiClient, testData []edgeproto.Flavor)

func ClientFlavorTest

func ClientFlavorTest(t *testing.T, test string, api edgeproto.FlavorApiClient, testData []edgeproto.Flavor, ops ...FlavorTestOp)

func ClientGPUDriverCreate

func ClientGPUDriverCreate(t *testing.T, api edgeproto.GPUDriverApiClient, testData []edgeproto.GPUDriver)

func ClientGPUDriverDelete

func ClientGPUDriverDelete(t *testing.T, api edgeproto.GPUDriverApiClient, testData []edgeproto.GPUDriver)

func ClientGPUDriverTest

func ClientGPUDriverTest(t *testing.T, test string, api edgeproto.GPUDriverApiClient, testData []edgeproto.GPUDriver, ops ...GPUDriverTestOp)

func ClientNetworkCreate

func ClientNetworkCreate(t *testing.T, api edgeproto.NetworkApiClient, testData []edgeproto.Network)

func ClientNetworkDelete

func ClientNetworkDelete(t *testing.T, api edgeproto.NetworkApiClient, testData []edgeproto.Network)

func ClientNetworkTest

func ClientNetworkTest(t *testing.T, test string, api edgeproto.NetworkApiClient, testData []edgeproto.Network, ops ...NetworkTestOp)

func ClientNodeTest

func ClientNodeTest(t *testing.T, test string, api edgeproto.NodeApiClient, testData []edgeproto.Node, ops ...NodeTestOp)

func ClientOperatorCodeCreate

func ClientOperatorCodeCreate(t *testing.T, api edgeproto.OperatorCodeApiClient, testData []edgeproto.OperatorCode)

func ClientOperatorCodeDelete

func ClientOperatorCodeDelete(t *testing.T, api edgeproto.OperatorCodeApiClient, testData []edgeproto.OperatorCode)

func ClientOperatorCodeTest

func ClientOperatorCodeTest(t *testing.T, test string, api edgeproto.OperatorCodeApiClient, testData []edgeproto.OperatorCode, ops ...OperatorCodeTestOp)

func ClientResTagTableCreate

func ClientResTagTableCreate(t *testing.T, api edgeproto.ResTagTableApiClient, testData []edgeproto.ResTagTable)

func ClientResTagTableDelete

func ClientResTagTableDelete(t *testing.T, api edgeproto.ResTagTableApiClient, testData []edgeproto.ResTagTable)

func ClientResTagTableTest

func ClientResTagTableTest(t *testing.T, test string, api edgeproto.ResTagTableApiClient, testData []edgeproto.ResTagTable, ops ...ResTagTableTestOp)

func ClientTrustPolicyCreate

func ClientTrustPolicyCreate(t *testing.T, api edgeproto.TrustPolicyApiClient, testData []edgeproto.TrustPolicy)

func ClientTrustPolicyDelete

func ClientTrustPolicyDelete(t *testing.T, api edgeproto.TrustPolicyApiClient, testData []edgeproto.TrustPolicy)

func ClientTrustPolicyExceptionCreate

func ClientTrustPolicyExceptionCreate(t *testing.T, api edgeproto.TrustPolicyExceptionApiClient, testData []edgeproto.TrustPolicyException)

func ClientTrustPolicyExceptionDelete

func ClientTrustPolicyExceptionDelete(t *testing.T, api edgeproto.TrustPolicyExceptionApiClient, testData []edgeproto.TrustPolicyException)

func ClientTrustPolicyTest

func ClientTrustPolicyTest(t *testing.T, test string, api edgeproto.TrustPolicyApiClient, testData []edgeproto.TrustPolicy, ops ...TrustPolicyTestOp)

func ClientVMPoolCreate

func ClientVMPoolCreate(t *testing.T, api edgeproto.VMPoolApiClient, testData []edgeproto.VMPool)

func ClientVMPoolDelete

func ClientVMPoolDelete(t *testing.T, api edgeproto.VMPoolApiClient, testData []edgeproto.VMPool)

func ClientVMPoolTest

func ClientVMPoolTest(t *testing.T, test string, api edgeproto.VMPoolApiClient, testData []edgeproto.VMPool, ops ...VMPoolTestOp)

func CloudletData

func CloudletData() []edgeproto.Cloudlet

func CloudletInfoData

func CloudletInfoData() []edgeproto.CloudletInfo

func CloudletInfoReadStream

func CloudletInfoReadStream(stream CloudletInfoStream) ([]edgeproto.CloudletInfo, error)

func CloudletKeyReadStream

func CloudletKeyReadStream(stream CloudletKeyStream) ([]edgeproto.CloudletKey, error)

func CloudletMetricsReadStream

func CloudletMetricsReadStream(stream CloudletMetricsStream) ([]edgeproto.CloudletMetrics, error)

func CloudletNodeData

func CloudletNodeData() []edgeproto.CloudletNode

func CloudletNodeReadStream

func CloudletNodeReadStream(stream CloudletNodeStream) ([]edgeproto.CloudletNode, error)

func CloudletPoolData

func CloudletPoolData() []edgeproto.CloudletPool

func CloudletPoolReadStream

func CloudletPoolReadStream(stream CloudletPoolStream) ([]edgeproto.CloudletPool, error)

func CloudletReadResultStream

func CloudletReadResultStream(stream ResultStream, err error) error

func CloudletReadStream

func CloudletReadStream(stream CloudletStream) ([]edgeproto.Cloudlet, error)

func CloudletRefsData

func CloudletRefsData() []edgeproto.CloudletRefs

To figure out what resources are used on each Cloudlet, see ClusterInstData to see what clusters are instantiated on what Cloudlet.

func CloudletRefsReadStream

func CloudletRefsReadStream(stream CloudletRefsStream) ([]edgeproto.CloudletRefs, error)

func CloudletRefsWithAppInstsData

func CloudletRefsWithAppInstsData() []edgeproto.CloudletRefs

These Refs are after creating both cluster insts and app insts. Some of the app insts trigger creating auto-clusterinsts, and ports are reserved with the creation of app insts.

func ClusterInstAutoData

func ClusterInstAutoData() []edgeproto.ClusterInst

These are the cluster insts that will be created automatically from appinsts that have not specified a cluster.

func ClusterInstData

func ClusterInstData() []edgeproto.ClusterInst

func ClusterInstInfoReadStream

func ClusterInstInfoReadStream(stream ClusterInstInfoStream) ([]edgeproto.ClusterInstInfo, error)

func ClusterInstReadResultStream

func ClusterInstReadResultStream(stream ResultStream, err error) error

func ClusterInstReadStream

func ClusterInstReadStream(stream ClusterInstStream) ([]edgeproto.ClusterInst, error)

func ClusterRefsReadStream

func ClusterRefsReadStream(stream ClusterRefsStream) ([]edgeproto.ClusterRefs, error)

func CompareExpectedFileData

func CompareExpectedFileData(t *testing.T, fileNameRoot, fileType, generatedData string)

CompareExpectedData is used for tests that generate data and want to compare it to expected data in a file. Typically this for testing configuration file generation. GeneratedData should be blank if the generated data is already in the generated file named "fileNameRoot.fileType".

func ControllerReadStream

func ControllerReadStream(stream ControllerStream) ([]edgeproto.Controller, error)

func CreateAlertPolicyData

func CreateAlertPolicyData(t *testing.T, ctx context.Context, api *AlertPolicyCommonApi, testData []edgeproto.AlertPolicy)

func CreateAppData

func CreateAppData(t *testing.T, ctx context.Context, api *AppCommonApi, testData []edgeproto.App)

func CreateAppInstData

func CreateAppInstData(t *testing.T, ctx context.Context, api *AppInstCommonApi, testData []edgeproto.AppInst)

func CreateAutoProvPolicyData

func CreateAutoProvPolicyData(t *testing.T, ctx context.Context, api *AutoProvPolicyCommonApi, testData []edgeproto.AutoProvPolicy)

func CreateAutoScalePolicyData

func CreateAutoScalePolicyData(t *testing.T, ctx context.Context, api *AutoScalePolicyCommonApi, testData []edgeproto.AutoScalePolicy)

func CreateCloudletData

func CreateCloudletData(t *testing.T, ctx context.Context, api *CloudletCommonApi, testData []edgeproto.Cloudlet)

func CreateCloudletNodeData

func CreateCloudletNodeData(t *testing.T, ctx context.Context, api *CloudletNodeCommonApi, testData []edgeproto.CloudletNode)

func CreateCloudletPoolData

func CreateCloudletPoolData(t *testing.T, ctx context.Context, api *CloudletPoolCommonApi, testData []edgeproto.CloudletPool)

func CreateClusterInstData

func CreateClusterInstData(t *testing.T, ctx context.Context, api *ClusterInstCommonApi, testData []edgeproto.ClusterInst)

func CreateFlavorData

func CreateFlavorData(t *testing.T, ctx context.Context, api *FlavorCommonApi, testData []edgeproto.Flavor)

func CreateGPUDriverData

func CreateGPUDriverData(t *testing.T, ctx context.Context, api *GPUDriverCommonApi, testData []edgeproto.GPUDriver)

func CreateNetworkData

func CreateNetworkData(t *testing.T, ctx context.Context, api *NetworkCommonApi, testData []edgeproto.Network)

func CreateOperatorCodeData

func CreateOperatorCodeData(t *testing.T, ctx context.Context, api *OperatorCodeCommonApi, testData []edgeproto.OperatorCode)

func CreateResTagTableData

func CreateResTagTableData(t *testing.T, ctx context.Context, api *ResTagTableCommonApi, testData []edgeproto.ResTagTable)

func CreateTrustPolicyData

func CreateTrustPolicyData(t *testing.T, ctx context.Context, api *TrustPolicyCommonApi, testData []edgeproto.TrustPolicy)

func CreateTrustPolicyExceptionData

func CreateTrustPolicyExceptionData(t *testing.T, ctx context.Context, api *TrustPolicyExceptionCommonApi, testData []edgeproto.TrustPolicyException)

func CreateVMPoolData

func CreateVMPoolData(t *testing.T, ctx context.Context, api *VMPoolCommonApi, testData []edgeproto.VMPool)

func CreatedAppInstData

func CreatedAppInstData() []edgeproto.AppInst

Get the AppInst data after it has been created by the Controller. This is for tests that are using data as if it has already been created and processed by the Controller, given that the controller may modify certain fields during create.

func DebugReplyReadStream

func DebugReplyReadStream(stream DebugReplyStream) ([]edgeproto.DebugReply, error)

func DeleteAlertPolicyData

func DeleteAlertPolicyData(t *testing.T, ctx context.Context, api *AlertPolicyCommonApi, testData []edgeproto.AlertPolicy)

func DeleteAllAllDataInternal

func DeleteAllAllDataInternal(t *testing.T, ctx context.Context, apis InternalCUDAPIs, in *edgeproto.AllData)

func DeleteAllDebugDataInternal

func DeleteAllDebugDataInternal(t *testing.T, ctx context.Context, apis InternalCUDAPIs, in *edgeproto.DebugData)

func DeleteAllDeviceDataInternal

func DeleteAllDeviceDataInternal(t *testing.T, ctx context.Context, apis InternalCUDAPIs, in *edgeproto.DeviceData)

func DeleteAllNodeDataInternal

func DeleteAllNodeDataInternal(t *testing.T, ctx context.Context, apis InternalCUDAPIs, in *edgeproto.NodeData)

func DeleteAllOrganizationDataInternal

func DeleteAllOrganizationDataInternal(t *testing.T, ctx context.Context, apis InternalCUDAPIs, in *edgeproto.OrganizationData)

func DeleteAllRateLimitSettingsDataInternal

func DeleteAllRateLimitSettingsDataInternal(t *testing.T, ctx context.Context, apis InternalCUDAPIs, in *edgeproto.RateLimitSettingsData)

func DeleteAppData

func DeleteAppData(t *testing.T, ctx context.Context, api *AppCommonApi, testData []edgeproto.App)

func DeleteAppInstData

func DeleteAppInstData(t *testing.T, ctx context.Context, api *AppInstCommonApi, testData []edgeproto.AppInst)

func DeleteAutoProvPolicyData

func DeleteAutoProvPolicyData(t *testing.T, ctx context.Context, api *AutoProvPolicyCommonApi, testData []edgeproto.AutoProvPolicy)

func DeleteAutoScalePolicyData

func DeleteAutoScalePolicyData(t *testing.T, ctx context.Context, api *AutoScalePolicyCommonApi, testData []edgeproto.AutoScalePolicy)

func DeleteCloudletData

func DeleteCloudletData(t *testing.T, ctx context.Context, api *CloudletCommonApi, testData []edgeproto.Cloudlet)

func DeleteCloudletNodeData

func DeleteCloudletNodeData(t *testing.T, ctx context.Context, api *CloudletNodeCommonApi, testData []edgeproto.CloudletNode)

func DeleteCloudletPoolData

func DeleteCloudletPoolData(t *testing.T, ctx context.Context, api *CloudletPoolCommonApi, testData []edgeproto.CloudletPool)

func DeleteClusterInstData

func DeleteClusterInstData(t *testing.T, ctx context.Context, api *ClusterInstCommonApi, testData []edgeproto.ClusterInst)

func DeleteFlavorData

func DeleteFlavorData(t *testing.T, ctx context.Context, api *FlavorCommonApi, testData []edgeproto.Flavor)

func DeleteGPUDriverData

func DeleteGPUDriverData(t *testing.T, ctx context.Context, api *GPUDriverCommonApi, testData []edgeproto.GPUDriver)

func DeleteNetworkData

func DeleteNetworkData(t *testing.T, ctx context.Context, api *NetworkCommonApi, testData []edgeproto.Network)

func DeleteOperatorCodeData

func DeleteOperatorCodeData(t *testing.T, ctx context.Context, api *OperatorCodeCommonApi, testData []edgeproto.OperatorCode)

func DeleteResTagTableData

func DeleteResTagTableData(t *testing.T, ctx context.Context, api *ResTagTableCommonApi, testData []edgeproto.ResTagTable)

func DeleteTrustPolicyData

func DeleteTrustPolicyData(t *testing.T, ctx context.Context, api *TrustPolicyCommonApi, testData []edgeproto.TrustPolicy)

func DeleteTrustPolicyExceptionData

func DeleteTrustPolicyExceptionData(t *testing.T, ctx context.Context, api *TrustPolicyExceptionCommonApi, testData []edgeproto.TrustPolicyException)

func DeleteVMPoolData

func DeleteVMPoolData(t *testing.T, ctx context.Context, api *VMPoolCommonApi, testData []edgeproto.VMPool)

func DevData

func DevData() []string

func DeviceReadStream

func DeviceReadStream(stream DeviceStream) ([]edgeproto.Device, error)

func FilterResults

func FilterResults(in []edgeproto.Result) []edgeproto.Result

Remove results with code 0. This lets us remove status update results from create AppInst/ClusterInst/Cloudlet which are non-deterministic.

func FilterStreamResults

func FilterStreamResults(in [][]edgeproto.Result) [][]edgeproto.Result

func FindAlertData

func FindAlertData(key *edgeproto.AlertKey, testData []edgeproto.Alert) (*edgeproto.Alert, bool)

func FindAlertPolicyData

func FindAlertPolicyData(key *edgeproto.AlertPolicyKey, testData []edgeproto.AlertPolicy) (*edgeproto.AlertPolicy, bool)

func FindAppData

func FindAppData(key *edgeproto.AppKey, testData []edgeproto.App) (*edgeproto.App, bool)

func FindAppInstData

func FindAppInstData(key *edgeproto.AppInstKey, testData []edgeproto.AppInst) (*edgeproto.AppInst, bool)

func FindAppInstInfoData

func FindAppInstInfoData(key *edgeproto.AppInstKey, testData []edgeproto.AppInstInfo) (*edgeproto.AppInstInfo, bool)

func FindAppInstRefsData

func FindAppInstRefsData(key *edgeproto.AppKey, testData []edgeproto.AppInstRefs) (*edgeproto.AppInstRefs, bool)

func FindAutoProvPolicyData

func FindAutoProvPolicyData(key *edgeproto.PolicyKey, testData []edgeproto.AutoProvPolicy) (*edgeproto.AutoProvPolicy, bool)

func FindAutoScalePolicyData

func FindAutoScalePolicyData(key *edgeproto.PolicyKey, testData []edgeproto.AutoScalePolicy) (*edgeproto.AutoScalePolicy, bool)

func FindCloudletData

func FindCloudletData(key *edgeproto.CloudletKey, testData []edgeproto.Cloudlet) (*edgeproto.Cloudlet, bool)

func FindCloudletInfoData

func FindCloudletInfoData(key *edgeproto.CloudletKey, testData []edgeproto.CloudletInfo) (*edgeproto.CloudletInfo, bool)

func FindCloudletNodeData

func FindCloudletNodeData(key *edgeproto.CloudletNodeKey, testData []edgeproto.CloudletNode) (*edgeproto.CloudletNode, bool)

func FindCloudletPoolData

func FindCloudletPoolData(key *edgeproto.CloudletPoolKey, testData []edgeproto.CloudletPool) (*edgeproto.CloudletPool, bool)

func FindCloudletRefsData

func FindCloudletRefsData(key *edgeproto.CloudletKey, testData []edgeproto.CloudletRefs) (*edgeproto.CloudletRefs, bool)

func FindClusterInstData

func FindClusterInstData(key *edgeproto.ClusterKey, testData []edgeproto.ClusterInst) (*edgeproto.ClusterInst, bool)

func FindClusterInstInfoData

func FindClusterInstInfoData(key *edgeproto.ClusterKey, testData []edgeproto.ClusterInstInfo) (*edgeproto.ClusterInstInfo, bool)

func FindClusterRefsData

func FindClusterRefsData(key *edgeproto.ClusterKey, testData []edgeproto.ClusterRefs) (*edgeproto.ClusterRefs, bool)

func FindDeviceData

func FindDeviceData(key *edgeproto.DeviceKey, testData []edgeproto.Device) (*edgeproto.Device, bool)

func FindFlavorData

func FindFlavorData(key *edgeproto.FlavorKey, testData []edgeproto.Flavor) (*edgeproto.Flavor, bool)

func FindGPUDriverData

func FindGPUDriverData(key *edgeproto.GPUDriverKey, testData []edgeproto.GPUDriver) (*edgeproto.GPUDriver, bool)

func FindNetworkData

func FindNetworkData(key *edgeproto.NetworkKey, testData []edgeproto.Network) (*edgeproto.Network, bool)

func FindNodeData

func FindNodeData(key *edgeproto.NodeKey, testData []edgeproto.Node) (*edgeproto.Node, bool)

func FindOperatorCodeData

func FindOperatorCodeData(key *edgeproto.OperatorCodeKey, testData []edgeproto.OperatorCode) (*edgeproto.OperatorCode, bool)

func FindResTagTableData

func FindResTagTableData(key *edgeproto.ResTagTableKey, testData []edgeproto.ResTagTable) (*edgeproto.ResTagTable, bool)

func FindTrustPolicyData

func FindTrustPolicyData(key *edgeproto.PolicyKey, testData []edgeproto.TrustPolicy) (*edgeproto.TrustPolicy, bool)

func FindVMPoolData

func FindVMPoolData(key *edgeproto.VMPoolKey, testData []edgeproto.VMPool) (*edgeproto.VMPool, bool)

func FlavorData

func FlavorData() []edgeproto.Flavor

func FlavorKeyReadStream

func FlavorKeyReadStream(stream FlavorKeyStream) ([]edgeproto.FlavorKey, error)

func FlavorReadStream

func FlavorReadStream(stream FlavorStream) ([]edgeproto.Flavor, error)

func GPUDriverData

func GPUDriverData() []edgeproto.GPUDriver

func GPUDriverReadResultStream

func GPUDriverReadResultStream(stream ResultStream, err error) error

func GPUDriverReadStream

func GPUDriverReadStream(stream GPUDriverStream) ([]edgeproto.GPUDriver, error)

func GetAlert

func GetAlert(t *testing.T, ctx context.Context, api *AlertCommonApi, key *edgeproto.AlertKey, out *edgeproto.Alert) bool

func GetApp

func GetApp(t *testing.T, ctx context.Context, api *AppCommonApi, key *edgeproto.AppKey, out *edgeproto.App) bool

func GetAppInst

func GetAppInst(t *testing.T, ctx context.Context, api *AppInstCommonApi, key *edgeproto.AppInstKey, out *edgeproto.AppInst) bool

func GetAppInstRefs

func GetAppInstRefs(t *testing.T, ctx context.Context, api *AppInstRefsCommonApi, key *edgeproto.AppKey, out *edgeproto.AppInstRefs) bool

func GetAppInstRefsData

func GetAppInstRefsData() []edgeproto.AppInstRefs

func GetCloudlet

func GetCloudlet(t *testing.T, ctx context.Context, api *CloudletCommonApi, key *edgeproto.CloudletKey, out *edgeproto.Cloudlet) bool

func GetDevice

func GetDevice(t *testing.T, ctx context.Context, api *DeviceCommonApi, key *edgeproto.DeviceKey, out *edgeproto.Device) bool

func GetFlavor

func GetFlavor(t *testing.T, ctx context.Context, api *FlavorCommonApi, key *edgeproto.FlavorKey, out *edgeproto.Flavor) bool

func GetNetwork

func GetNetwork(t *testing.T, ctx context.Context, api *NetworkCommonApi, key *edgeproto.NetworkKey, out *edgeproto.Network) bool

func GetNode

func GetNode(t *testing.T, ctx context.Context, api *NodeCommonApi, key *edgeproto.NodeKey, out *edgeproto.Node) bool

func GetTimestamp

func GetTimestamp(t time.Time) *types.Timestamp

func GetVMPool

func GetVMPool(t *testing.T, ctx context.Context, api *VMPoolCommonApi, key *edgeproto.VMPoolKey, out *edgeproto.VMPool) bool

func InternalAlertPolicyCreate

func InternalAlertPolicyCreate(t *testing.T, api edgeproto.AlertPolicyApiServer, testData []edgeproto.AlertPolicy)

func InternalAlertPolicyDelete

func InternalAlertPolicyDelete(t *testing.T, api edgeproto.AlertPolicyApiServer, testData []edgeproto.AlertPolicy)

func InternalAlertPolicyDeleteAll

func InternalAlertPolicyDeleteAll(t *testing.T, ctx context.Context, api edgeproto.AlertPolicyApiServer, data []edgeproto.AlertPolicy)

func InternalAlertPolicyTest

func InternalAlertPolicyTest(t *testing.T, test string, api edgeproto.AlertPolicyApiServer, testData []edgeproto.AlertPolicy, ops ...AlertPolicyTestOp)

func InternalAlertTest

func InternalAlertTest(t *testing.T, test string, api edgeproto.AlertApiServer, testData []edgeproto.Alert, ops ...AlertTestOp)

func InternalAppCreate

func InternalAppCreate(t *testing.T, api edgeproto.AppApiServer, testData []edgeproto.App)

func InternalAppDelete

func InternalAppDelete(t *testing.T, api edgeproto.AppApiServer, testData []edgeproto.App)

func InternalAppDeleteAll

func InternalAppDeleteAll(t *testing.T, ctx context.Context, api edgeproto.AppApiServer, data []edgeproto.App)

func InternalAppInstCreate

func InternalAppInstCreate(t *testing.T, api edgeproto.AppInstApiServer, testData []edgeproto.AppInst)

func InternalAppInstDelete

func InternalAppInstDelete(t *testing.T, api edgeproto.AppInstApiServer, testData []edgeproto.AppInst)

func InternalAppInstDeleteAll

func InternalAppInstDeleteAll(t *testing.T, ctx context.Context, api edgeproto.AppInstApiServer, data []edgeproto.AppInst)

func InternalAppInstInfoTest

func InternalAppInstInfoTest(t *testing.T, test string, api edgeproto.AppInstInfoApiServer, testData []edgeproto.AppInstInfo, ops ...AppInstInfoTestOp)

func InternalAppInstRefsTest

func InternalAppInstRefsTest(t *testing.T, test string, api edgeproto.AppInstRefsApiServer, testData []edgeproto.AppInstRefs, ops ...AppInstRefsTestOp)

func InternalAppInstTest

func InternalAppInstTest(t *testing.T, test string, api edgeproto.AppInstApiServer, testData []edgeproto.AppInst, ops ...AppInstTestOp)

func InternalAppTest

func InternalAppTest(t *testing.T, test string, api edgeproto.AppApiServer, testData []edgeproto.App, ops ...AppTestOp)

func InternalAutoProvPolicyCreate

func InternalAutoProvPolicyCreate(t *testing.T, api edgeproto.AutoProvPolicyApiServer, testData []edgeproto.AutoProvPolicy)

func InternalAutoProvPolicyDelete

func InternalAutoProvPolicyDelete(t *testing.T, api edgeproto.AutoProvPolicyApiServer, testData []edgeproto.AutoProvPolicy)

func InternalAutoProvPolicyDeleteAll

func InternalAutoProvPolicyDeleteAll(t *testing.T, ctx context.Context, api edgeproto.AutoProvPolicyApiServer, data []edgeproto.AutoProvPolicy)

func InternalAutoProvPolicyTest

func InternalAutoProvPolicyTest(t *testing.T, test string, api edgeproto.AutoProvPolicyApiServer, testData []edgeproto.AutoProvPolicy, ops ...AutoProvPolicyTestOp)

func InternalAutoScalePolicyCreate

func InternalAutoScalePolicyCreate(t *testing.T, api edgeproto.AutoScalePolicyApiServer, testData []edgeproto.AutoScalePolicy)

func InternalAutoScalePolicyDelete

func InternalAutoScalePolicyDelete(t *testing.T, api edgeproto.AutoScalePolicyApiServer, testData []edgeproto.AutoScalePolicy)

func InternalAutoScalePolicyDeleteAll

func InternalAutoScalePolicyDeleteAll(t *testing.T, ctx context.Context, api edgeproto.AutoScalePolicyApiServer, data []edgeproto.AutoScalePolicy)

func InternalAutoScalePolicyTest

func InternalAutoScalePolicyTest(t *testing.T, test string, api edgeproto.AutoScalePolicyApiServer, testData []edgeproto.AutoScalePolicy, ops ...AutoScalePolicyTestOp)

func InternalCloudletCreate

func InternalCloudletCreate(t *testing.T, api edgeproto.CloudletApiServer, testData []edgeproto.Cloudlet)

func InternalCloudletDelete

func InternalCloudletDelete(t *testing.T, api edgeproto.CloudletApiServer, testData []edgeproto.Cloudlet)

func InternalCloudletDeleteAll

func InternalCloudletDeleteAll(t *testing.T, ctx context.Context, api edgeproto.CloudletApiServer, data []edgeproto.Cloudlet)

func InternalCloudletInfoTest

func InternalCloudletInfoTest(t *testing.T, test string, api edgeproto.CloudletInfoApiServer, testData []edgeproto.CloudletInfo, ops ...CloudletInfoTestOp)

func InternalCloudletNodeCreate

func InternalCloudletNodeCreate(t *testing.T, api edgeproto.CloudletNodeApiServer, testData []edgeproto.CloudletNode)

func InternalCloudletNodeDelete

func InternalCloudletNodeDelete(t *testing.T, api edgeproto.CloudletNodeApiServer, testData []edgeproto.CloudletNode)

func InternalCloudletNodeDeleteAll

func InternalCloudletNodeDeleteAll(t *testing.T, ctx context.Context, api edgeproto.CloudletNodeApiServer, data []edgeproto.CloudletNode)

func InternalCloudletNodeTest

func InternalCloudletNodeTest(t *testing.T, test string, api edgeproto.CloudletNodeApiServer, testData []edgeproto.CloudletNode, ops ...CloudletNodeTestOp)

func InternalCloudletPoolCreate

func InternalCloudletPoolCreate(t *testing.T, api edgeproto.CloudletPoolApiServer, testData []edgeproto.CloudletPool)

func InternalCloudletPoolDelete

func InternalCloudletPoolDelete(t *testing.T, api edgeproto.CloudletPoolApiServer, testData []edgeproto.CloudletPool)

func InternalCloudletPoolDeleteAll

func InternalCloudletPoolDeleteAll(t *testing.T, ctx context.Context, api edgeproto.CloudletPoolApiServer, data []edgeproto.CloudletPool)

func InternalCloudletPoolTest

func InternalCloudletPoolTest(t *testing.T, test string, api edgeproto.CloudletPoolApiServer, testData []edgeproto.CloudletPool, ops ...CloudletPoolTestOp)

func InternalCloudletRefsTest

func InternalCloudletRefsTest(t *testing.T, test string, api edgeproto.CloudletRefsApiServer, testData []edgeproto.CloudletRefs, ops ...CloudletRefsTestOp)

func InternalCloudletTest

func InternalCloudletTest(t *testing.T, test string, api edgeproto.CloudletApiServer, testData []edgeproto.Cloudlet, ops ...CloudletTestOp)

func InternalClusterInstCreate

func InternalClusterInstCreate(t *testing.T, api edgeproto.ClusterInstApiServer, testData []edgeproto.ClusterInst)

func InternalClusterInstDelete

func InternalClusterInstDelete(t *testing.T, api edgeproto.ClusterInstApiServer, testData []edgeproto.ClusterInst)

func InternalClusterInstDeleteAll

func InternalClusterInstDeleteAll(t *testing.T, ctx context.Context, api edgeproto.ClusterInstApiServer, data []edgeproto.ClusterInst)

func InternalClusterInstInfoTest

func InternalClusterInstInfoTest(t *testing.T, test string, api edgeproto.ClusterInstInfoApiServer, testData []edgeproto.ClusterInstInfo, ops ...ClusterInstInfoTestOp)

func InternalClusterInstTest

func InternalClusterInstTest(t *testing.T, test string, api edgeproto.ClusterInstApiServer, testData []edgeproto.ClusterInst, ops ...ClusterInstTestOp)

func InternalClusterRefsTest

func InternalClusterRefsTest(t *testing.T, test string, api edgeproto.ClusterRefsApiServer, testData []edgeproto.ClusterRefs, ops ...ClusterRefsTestOp)

func InternalDeviceTest

func InternalDeviceTest(t *testing.T, test string, api edgeproto.DeviceApiServer, testData []edgeproto.Device, ops ...DeviceTestOp)

func InternalFlavorCreate

func InternalFlavorCreate(t *testing.T, api edgeproto.FlavorApiServer, testData []edgeproto.Flavor)

func InternalFlavorDelete

func InternalFlavorDelete(t *testing.T, api edgeproto.FlavorApiServer, testData []edgeproto.Flavor)

func InternalFlavorDeleteAll

func InternalFlavorDeleteAll(t *testing.T, ctx context.Context, api edgeproto.FlavorApiServer, data []edgeproto.Flavor)

func InternalFlavorTest

func InternalFlavorTest(t *testing.T, test string, api edgeproto.FlavorApiServer, testData []edgeproto.Flavor, ops ...FlavorTestOp)

func InternalGPUDriverCreate

func InternalGPUDriverCreate(t *testing.T, api edgeproto.GPUDriverApiServer, testData []edgeproto.GPUDriver)

func InternalGPUDriverDelete

func InternalGPUDriverDelete(t *testing.T, api edgeproto.GPUDriverApiServer, testData []edgeproto.GPUDriver)

func InternalGPUDriverDeleteAll

func InternalGPUDriverDeleteAll(t *testing.T, ctx context.Context, api edgeproto.GPUDriverApiServer, data []edgeproto.GPUDriver)

func InternalGPUDriverTest

func InternalGPUDriverTest(t *testing.T, test string, api edgeproto.GPUDriverApiServer, testData []edgeproto.GPUDriver, ops ...GPUDriverTestOp)

func InternalNetworkCreate

func InternalNetworkCreate(t *testing.T, api edgeproto.NetworkApiServer, testData []edgeproto.Network)

func InternalNetworkDelete

func InternalNetworkDelete(t *testing.T, api edgeproto.NetworkApiServer, testData []edgeproto.Network)

func InternalNetworkDeleteAll

func InternalNetworkDeleteAll(t *testing.T, ctx context.Context, api edgeproto.NetworkApiServer, data []edgeproto.Network)

func InternalNetworkTest

func InternalNetworkTest(t *testing.T, test string, api edgeproto.NetworkApiServer, testData []edgeproto.Network, ops ...NetworkTestOp)

func InternalNodeTest

func InternalNodeTest(t *testing.T, test string, api edgeproto.NodeApiServer, testData []edgeproto.Node, ops ...NodeTestOp)

func InternalOperatorCodeCreate

func InternalOperatorCodeCreate(t *testing.T, api edgeproto.OperatorCodeApiServer, testData []edgeproto.OperatorCode)

func InternalOperatorCodeDelete

func InternalOperatorCodeDelete(t *testing.T, api edgeproto.OperatorCodeApiServer, testData []edgeproto.OperatorCode)

func InternalOperatorCodeDeleteAll

func InternalOperatorCodeDeleteAll(t *testing.T, ctx context.Context, api edgeproto.OperatorCodeApiServer, data []edgeproto.OperatorCode)

func InternalOperatorCodeTest

func InternalOperatorCodeTest(t *testing.T, test string, api edgeproto.OperatorCodeApiServer, testData []edgeproto.OperatorCode, ops ...OperatorCodeTestOp)

func InternalResTagTableCreate

func InternalResTagTableCreate(t *testing.T, api edgeproto.ResTagTableApiServer, testData []edgeproto.ResTagTable)

func InternalResTagTableDelete

func InternalResTagTableDelete(t *testing.T, api edgeproto.ResTagTableApiServer, testData []edgeproto.ResTagTable)

func InternalResTagTableDeleteAll

func InternalResTagTableDeleteAll(t *testing.T, ctx context.Context, api edgeproto.ResTagTableApiServer, data []edgeproto.ResTagTable)

func InternalResTagTableTest

func InternalResTagTableTest(t *testing.T, test string, api edgeproto.ResTagTableApiServer, testData []edgeproto.ResTagTable, ops ...ResTagTableTestOp)

func InternalTrustPolicyCreate

func InternalTrustPolicyCreate(t *testing.T, api edgeproto.TrustPolicyApiServer, testData []edgeproto.TrustPolicy)

func InternalTrustPolicyDelete

func InternalTrustPolicyDelete(t *testing.T, api edgeproto.TrustPolicyApiServer, testData []edgeproto.TrustPolicy)

func InternalTrustPolicyDeleteAll

func InternalTrustPolicyDeleteAll(t *testing.T, ctx context.Context, api edgeproto.TrustPolicyApiServer, data []edgeproto.TrustPolicy)

func InternalTrustPolicyExceptionCreate

func InternalTrustPolicyExceptionCreate(t *testing.T, api edgeproto.TrustPolicyExceptionApiServer, testData []edgeproto.TrustPolicyException)

func InternalTrustPolicyExceptionDelete

func InternalTrustPolicyExceptionDelete(t *testing.T, api edgeproto.TrustPolicyExceptionApiServer, testData []edgeproto.TrustPolicyException)

func InternalTrustPolicyTest

func InternalTrustPolicyTest(t *testing.T, test string, api edgeproto.TrustPolicyApiServer, testData []edgeproto.TrustPolicy, ops ...TrustPolicyTestOp)

func InternalVMPoolCreate

func InternalVMPoolCreate(t *testing.T, api edgeproto.VMPoolApiServer, testData []edgeproto.VMPool)

func InternalVMPoolDelete

func InternalVMPoolDelete(t *testing.T, api edgeproto.VMPoolApiServer, testData []edgeproto.VMPool)

func InternalVMPoolDeleteAll

func InternalVMPoolDeleteAll(t *testing.T, ctx context.Context, api edgeproto.VMPoolApiServer, data []edgeproto.VMPool)

func InternalVMPoolTest

func InternalVMPoolTest(t *testing.T, test string, api edgeproto.VMPoolApiServer, testData []edgeproto.VMPool, ops ...VMPoolTestOp)

func IsAutoClusterAutoDeleteApp

func IsAutoClusterAutoDeleteApp(inst *edgeproto.AppInst) bool

func NetworkData

func NetworkData() []edgeproto.Network

func NetworkErrorData

func NetworkErrorData() []edgeproto.Network

func NetworkReadResultStream

func NetworkReadResultStream(stream ResultStream, err error) error

func NetworkReadStream

func NetworkReadStream(stream NetworkStream) ([]edgeproto.Network, error)

func NewVaultTestCluster

func NewVaultTestCluster(t *testing.T, p *process.Vault) (*docker.DockerCluster, *process.VaultRoles, func())

Start an in-memory docker test vault. Returns test cluster, vault roles, and cleanup func. The input process's ListenAddr should be set to the unit test name, which will be used as the docker cluster's name. The ListenAddr will then be overwritten to whatever local address the cluster is listening on.

func NewVaultTestClusterBasic

func NewVaultTestClusterBasic(t *testing.T, listenAddr string) (*docker.DockerCluster, *api.Client)

NewVaultTestClusterBasic starts a basic in-memory docker test vault. Returns test cluster and client. Call cluster.Cleanup() when done.

func NodeReadStream

func NodeReadStream(stream NodeStream) ([]edgeproto.Node, error)

func OperatorCodeData

func OperatorCodeData() []edgeproto.OperatorCode

func OperatorCodeReadStream

func OperatorCodeReadStream(stream OperatorCodeStream) ([]edgeproto.OperatorCode, error)

func OperatorData

func OperatorData() []string

func OrganizationReadStream

func OrganizationReadStream(stream OrganizationStream) ([]edgeproto.Organization, error)

func PlatformDeviceClientData

func PlatformDeviceClientData() []edgeproto.Device

func PlatformDeviceClientDataKeys

func PlatformDeviceClientDataKeys() []edgeproto.DeviceKey

func PlatformFeaturesData

func PlatformFeaturesData() []edgeproto.PlatformFeatures

func PlatformFeaturesReadStream

func PlatformFeaturesReadStream(stream PlatformFeaturesStream) ([]edgeproto.PlatformFeatures, error)

func RateLimitSettingsReadStream

func RateLimitSettingsReadStream(stream RateLimitSettingsStream) ([]edgeproto.RateLimitSettings, error)

func ResTagTableData

func ResTagTableData() []edgeproto.ResTagTable

func ResTagTableReadStream

func ResTagTableReadStream(stream ResTagTableStream) ([]edgeproto.ResTagTable, error)

func Restblkeys

func Restblkeys() []edgeproto.ResTagTableKey

func ResultReadStream

func ResultReadStream(stream ResultStream) ([]edgeproto.Result, error)

func RunAllDataApis

func RunAllDataApis(run *Run, in *edgeproto.AllData, inMap map[string]interface{}, out *AllDataOut, apicb RunAllDataApiCallback)

func RunAllDataReverseApis

func RunAllDataReverseApis(run *Run, in *edgeproto.AllData, inMap map[string]interface{}, out *AllDataOut, apicb RunAllDataApiCallback)

func RunAllDataShowApis

func RunAllDataShowApis(run *Run, in *edgeproto.AllData, selector edgeproto.AllSelector, out *edgeproto.AllData)

func RunAllDataStreamApis

func RunAllDataStreamApis(run *Run, in *edgeproto.AllData, out *AllDataStreamOut)

func RunDebugDataApis

func RunDebugDataApis(run *Run, in *edgeproto.DebugData, inMap map[string]interface{}, out *DebugDataOut, apicb RunDebugDataApiCallback)

func RunDebugDataReverseApis

func RunDebugDataReverseApis(run *Run, in *edgeproto.DebugData, inMap map[string]interface{}, out *DebugDataOut, apicb RunDebugDataApiCallback)

func RunDebugDataShowApis

func RunDebugDataShowApis(run *Run, in *edgeproto.DebugData, selector edgeproto.AllSelector, out *edgeproto.DebugData)

func RunDeviceDataApis

func RunDeviceDataApis(run *Run, in *edgeproto.DeviceData, inMap map[string]interface{}, out *DeviceDataOut, apicb RunDeviceDataApiCallback)

func RunDeviceDataReverseApis

func RunDeviceDataReverseApis(run *Run, in *edgeproto.DeviceData, inMap map[string]interface{}, out *DeviceDataOut, apicb RunDeviceDataApiCallback)

func RunDeviceDataShowApis

func RunDeviceDataShowApis(run *Run, in *edgeproto.DeviceData, selector edgeproto.AllSelector, out *edgeproto.DeviceData)

func RunNodeDataApis

func RunNodeDataApis(run *Run, in *edgeproto.NodeData, inMap map[string]interface{}, out *NodeDataOut, apicb RunNodeDataApiCallback)

func RunNodeDataReverseApis

func RunNodeDataReverseApis(run *Run, in *edgeproto.NodeData, inMap map[string]interface{}, out *NodeDataOut, apicb RunNodeDataApiCallback)

func RunNodeDataShowApis

func RunNodeDataShowApis(run *Run, in *edgeproto.NodeData, selector edgeproto.AllSelector, out *edgeproto.NodeData)

func RunOrganizationDataApis

func RunOrganizationDataApis(run *Run, in *edgeproto.OrganizationData, inMap map[string]interface{}, out *OrganizationDataOut, apicb RunOrganizationDataApiCallback)

func RunOrganizationDataReverseApis

func RunOrganizationDataReverseApis(run *Run, in *edgeproto.OrganizationData, inMap map[string]interface{}, out *OrganizationDataOut, apicb RunOrganizationDataApiCallback)

func RunOrganizationDataShowApis

func RunOrganizationDataShowApis(run *Run, in *edgeproto.OrganizationData, selector edgeproto.AllSelector, out *edgeproto.OrganizationData)

func RunRateLimitSettingsDataApis

func RunRateLimitSettingsDataApis(run *Run, in *edgeproto.RateLimitSettingsData, inMap map[string]interface{}, out *RateLimitSettingsDataOut, apicb RunRateLimitSettingsDataApiCallback)

func RunRateLimitSettingsDataReverseApis

func RunRateLimitSettingsDataReverseApis(run *Run, in *edgeproto.RateLimitSettingsData, inMap map[string]interface{}, out *RateLimitSettingsDataOut, apicb RunRateLimitSettingsDataApiCallback)

func RunRateLimitSettingsDataShowApis

func RunRateLimitSettingsDataShowApis(run *Run, in *edgeproto.RateLimitSettingsData, selector edgeproto.AllSelector, out *edgeproto.RateLimitSettingsData)

func StreamInterceptor

func StreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func TrustPolicyData

func TrustPolicyData() []edgeproto.TrustPolicy

func TrustPolicyErrorData

func TrustPolicyErrorData() []edgeproto.TrustPolicy

func TrustPolicyExceptionData

func TrustPolicyExceptionData() []edgeproto.TrustPolicyException

func TrustPolicyExceptionErrorData

func TrustPolicyExceptionErrorData() []edgeproto.TrustPolicyException

func TrustPolicyReadResultStream

func TrustPolicyReadResultStream(stream ResultStream, err error) error

func TrustPolicyReadStream

func TrustPolicyReadStream(stream TrustPolicyStream) ([]edgeproto.TrustPolicy, error)

func UnaryInterceptor

func UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

func VMPoolData

func VMPoolData() []edgeproto.VMPool

func VMPoolReadStream

func VMPoolReadStream(stream VMPoolStream) ([]edgeproto.VMPool, error)

func VaultMountTotp

func VaultMountTotp(t *testing.T, client *api.Client, region string)

This is separate because the setup-region.sh script does it as well.

func WaitAssertFoundAlert

func WaitAssertFoundAlert(t *testing.T, api edgeproto.AlertApiClient, obj *edgeproto.Alert, count int, retry time.Duration)

func WaitAssertFoundAlertPolicy

func WaitAssertFoundAlertPolicy(t *testing.T, api edgeproto.AlertPolicyApiClient, obj *edgeproto.AlertPolicy, count int, retry time.Duration)

func WaitAssertFoundApp

func WaitAssertFoundApp(t *testing.T, api edgeproto.AppApiClient, obj *edgeproto.App, count int, retry time.Duration)

func WaitAssertFoundAppInst

func WaitAssertFoundAppInst(t *testing.T, api edgeproto.AppInstApiClient, obj *edgeproto.AppInst, count int, retry time.Duration)

func WaitAssertFoundAppInstInfo

func WaitAssertFoundAppInstInfo(t *testing.T, api edgeproto.AppInstInfoApiClient, obj *edgeproto.AppInstInfo, count int, retry time.Duration)

func WaitAssertFoundAppInstRefs

func WaitAssertFoundAppInstRefs(t *testing.T, api edgeproto.AppInstRefsApiClient, obj *edgeproto.AppInstRefs, count int, retry time.Duration)

func WaitAssertFoundAutoProvPolicy

func WaitAssertFoundAutoProvPolicy(t *testing.T, api edgeproto.AutoProvPolicyApiClient, obj *edgeproto.AutoProvPolicy, count int, retry time.Duration)

func WaitAssertFoundAutoScalePolicy

func WaitAssertFoundAutoScalePolicy(t *testing.T, api edgeproto.AutoScalePolicyApiClient, obj *edgeproto.AutoScalePolicy, count int, retry time.Duration)

func WaitAssertFoundCloudlet

func WaitAssertFoundCloudlet(t *testing.T, api edgeproto.CloudletApiClient, obj *edgeproto.Cloudlet, count int, retry time.Duration)

func WaitAssertFoundCloudletInfo

func WaitAssertFoundCloudletInfo(t *testing.T, api edgeproto.CloudletInfoApiClient, obj *edgeproto.CloudletInfo, count int, retry time.Duration)

func WaitAssertFoundCloudletNode

func WaitAssertFoundCloudletNode(t *testing.T, api edgeproto.CloudletNodeApiClient, obj *edgeproto.CloudletNode, count int, retry time.Duration)

func WaitAssertFoundCloudletPool

func WaitAssertFoundCloudletPool(t *testing.T, api edgeproto.CloudletPoolApiClient, obj *edgeproto.CloudletPool, count int, retry time.Duration)

func WaitAssertFoundCloudletRefs

func WaitAssertFoundCloudletRefs(t *testing.T, api edgeproto.CloudletRefsApiClient, obj *edgeproto.CloudletRefs, count int, retry time.Duration)

func WaitAssertFoundClusterInst

func WaitAssertFoundClusterInst(t *testing.T, api edgeproto.ClusterInstApiClient, obj *edgeproto.ClusterInst, count int, retry time.Duration)

func WaitAssertFoundClusterInstInfo

func WaitAssertFoundClusterInstInfo(t *testing.T, api edgeproto.ClusterInstInfoApiClient, obj *edgeproto.ClusterInstInfo, count int, retry time.Duration)

func WaitAssertFoundClusterRefs

func WaitAssertFoundClusterRefs(t *testing.T, api edgeproto.ClusterRefsApiClient, obj *edgeproto.ClusterRefs, count int, retry time.Duration)

func WaitAssertFoundDevice

func WaitAssertFoundDevice(t *testing.T, api edgeproto.DeviceApiClient, obj *edgeproto.Device, count int, retry time.Duration)

func WaitAssertFoundFlavor

func WaitAssertFoundFlavor(t *testing.T, api edgeproto.FlavorApiClient, obj *edgeproto.Flavor, count int, retry time.Duration)

func WaitAssertFoundGPUDriver

func WaitAssertFoundGPUDriver(t *testing.T, api edgeproto.GPUDriverApiClient, obj *edgeproto.GPUDriver, count int, retry time.Duration)

func WaitAssertFoundNetwork

func WaitAssertFoundNetwork(t *testing.T, api edgeproto.NetworkApiClient, obj *edgeproto.Network, count int, retry time.Duration)

func WaitAssertFoundNode

func WaitAssertFoundNode(t *testing.T, api edgeproto.NodeApiClient, obj *edgeproto.Node, count int, retry time.Duration)

func WaitAssertFoundOperatorCode

func WaitAssertFoundOperatorCode(t *testing.T, api edgeproto.OperatorCodeApiClient, obj *edgeproto.OperatorCode, count int, retry time.Duration)

func WaitAssertFoundResTagTable

func WaitAssertFoundResTagTable(t *testing.T, api edgeproto.ResTagTableApiClient, obj *edgeproto.ResTagTable, count int, retry time.Duration)

func WaitAssertFoundTrustPolicy

func WaitAssertFoundTrustPolicy(t *testing.T, api edgeproto.TrustPolicyApiClient, obj *edgeproto.TrustPolicy, count int, retry time.Duration)

func WaitAssertFoundTrustPolicyException

func WaitAssertFoundTrustPolicyException(t *testing.T, api edgeproto.TrustPolicyExceptionApiClient, obj *edgeproto.TrustPolicyException, count int, retry time.Duration)

func WaitAssertFoundVMPool

func WaitAssertFoundVMPool(t *testing.T, api edgeproto.VMPoolApiClient, obj *edgeproto.VMPool, count int, retry time.Duration)

func WaitAssertNotFoundAlert

func WaitAssertNotFoundAlert(t *testing.T, api edgeproto.AlertApiClient, obj *edgeproto.Alert, count int, retry time.Duration)

func WaitAssertNotFoundAlertPolicy

func WaitAssertNotFoundAlertPolicy(t *testing.T, api edgeproto.AlertPolicyApiClient, obj *edgeproto.AlertPolicy, count int, retry time.Duration)

func WaitAssertNotFoundApp

func WaitAssertNotFoundApp(t *testing.T, api edgeproto.AppApiClient, obj *edgeproto.App, count int, retry time.Duration)

func WaitAssertNotFoundAppInst

func WaitAssertNotFoundAppInst(t *testing.T, api edgeproto.AppInstApiClient, obj *edgeproto.AppInst, count int, retry time.Duration)

func WaitAssertNotFoundAppInstInfo

func WaitAssertNotFoundAppInstInfo(t *testing.T, api edgeproto.AppInstInfoApiClient, obj *edgeproto.AppInstInfo, count int, retry time.Duration)

func WaitAssertNotFoundAppInstRefs

func WaitAssertNotFoundAppInstRefs(t *testing.T, api edgeproto.AppInstRefsApiClient, obj *edgeproto.AppInstRefs, count int, retry time.Duration)

func WaitAssertNotFoundAutoProvPolicy

func WaitAssertNotFoundAutoProvPolicy(t *testing.T, api edgeproto.AutoProvPolicyApiClient, obj *edgeproto.AutoProvPolicy, count int, retry time.Duration)

func WaitAssertNotFoundAutoScalePolicy

func WaitAssertNotFoundAutoScalePolicy(t *testing.T, api edgeproto.AutoScalePolicyApiClient, obj *edgeproto.AutoScalePolicy, count int, retry time.Duration)

func WaitAssertNotFoundCloudlet

func WaitAssertNotFoundCloudlet(t *testing.T, api edgeproto.CloudletApiClient, obj *edgeproto.Cloudlet, count int, retry time.Duration)

func WaitAssertNotFoundCloudletInfo

func WaitAssertNotFoundCloudletInfo(t *testing.T, api edgeproto.CloudletInfoApiClient, obj *edgeproto.CloudletInfo, count int, retry time.Duration)

func WaitAssertNotFoundCloudletNode

func WaitAssertNotFoundCloudletNode(t *testing.T, api edgeproto.CloudletNodeApiClient, obj *edgeproto.CloudletNode, count int, retry time.Duration)

func WaitAssertNotFoundCloudletPool

func WaitAssertNotFoundCloudletPool(t *testing.T, api edgeproto.CloudletPoolApiClient, obj *edgeproto.CloudletPool, count int, retry time.Duration)

func WaitAssertNotFoundCloudletRefs

func WaitAssertNotFoundCloudletRefs(t *testing.T, api edgeproto.CloudletRefsApiClient, obj *edgeproto.CloudletRefs, count int, retry time.Duration)

func WaitAssertNotFoundClusterInst

func WaitAssertNotFoundClusterInst(t *testing.T, api edgeproto.ClusterInstApiClient, obj *edgeproto.ClusterInst, count int, retry time.Duration)

func WaitAssertNotFoundClusterInstInfo

func WaitAssertNotFoundClusterInstInfo(t *testing.T, api edgeproto.ClusterInstInfoApiClient, obj *edgeproto.ClusterInstInfo, count int, retry time.Duration)

func WaitAssertNotFoundClusterRefs

func WaitAssertNotFoundClusterRefs(t *testing.T, api edgeproto.ClusterRefsApiClient, obj *edgeproto.ClusterRefs, count int, retry time.Duration)

func WaitAssertNotFoundDevice

func WaitAssertNotFoundDevice(t *testing.T, api edgeproto.DeviceApiClient, obj *edgeproto.Device, count int, retry time.Duration)

func WaitAssertNotFoundFlavor

func WaitAssertNotFoundFlavor(t *testing.T, api edgeproto.FlavorApiClient, obj *edgeproto.Flavor, count int, retry time.Duration)

func WaitAssertNotFoundGPUDriver

func WaitAssertNotFoundGPUDriver(t *testing.T, api edgeproto.GPUDriverApiClient, obj *edgeproto.GPUDriver, count int, retry time.Duration)

func WaitAssertNotFoundNetwork

func WaitAssertNotFoundNetwork(t *testing.T, api edgeproto.NetworkApiClient, obj *edgeproto.Network, count int, retry time.Duration)

func WaitAssertNotFoundNode

func WaitAssertNotFoundNode(t *testing.T, api edgeproto.NodeApiClient, obj *edgeproto.Node, count int, retry time.Duration)

func WaitAssertNotFoundOperatorCode

func WaitAssertNotFoundOperatorCode(t *testing.T, api edgeproto.OperatorCodeApiClient, obj *edgeproto.OperatorCode, count int, retry time.Duration)

func WaitAssertNotFoundResTagTable

func WaitAssertNotFoundResTagTable(t *testing.T, api edgeproto.ResTagTableApiClient, obj *edgeproto.ResTagTable, count int, retry time.Duration)

func WaitAssertNotFoundTrustPolicy

func WaitAssertNotFoundTrustPolicy(t *testing.T, api edgeproto.TrustPolicyApiClient, obj *edgeproto.TrustPolicy, count int, retry time.Duration)

func WaitAssertNotFoundTrustPolicyException

func WaitAssertNotFoundTrustPolicyException(t *testing.T, api edgeproto.TrustPolicyExceptionApiClient, obj *edgeproto.TrustPolicyException, count int, retry time.Duration)

func WaitAssertNotFoundVMPool

func WaitAssertNotFoundVMPool(t *testing.T, api edgeproto.VMPoolApiClient, obj *edgeproto.VMPool, count int, retry time.Duration)

Types

type Action

type Action int
const (
	Create Action = iota
	Delete
)

type AlertApiClient

type AlertApiClient interface {
	ShowAlert(ctx context.Context, in *edgeproto.Alert) ([]edgeproto.Alert, error)
}

type AlertCommonApi

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

Wrap the api with a common interface

func NewClientAlertApi

func NewClientAlertApi(api edgeproto.AlertApiClient) *AlertCommonApi

func NewInternalAlertApi

func NewInternalAlertApi(api edgeproto.AlertApiServer) *AlertCommonApi

func (*AlertCommonApi) ShowAlert

func (x *AlertCommonApi) ShowAlert(ctx context.Context, filter *edgeproto.Alert, showData *ShowAlert) error

type AlertPolicyApiClient

type AlertPolicyApiClient interface {
	CreateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)
	DeleteAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)
	UpdateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)
	ShowAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) ([]edgeproto.AlertPolicy, error)
}

type AlertPolicyCommonApi

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

Wrap the api with a common interface

func (*AlertPolicyCommonApi) CreateAlertPolicy

func (x *AlertPolicyCommonApi) CreateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*AlertPolicyCommonApi) DeleteAlertPolicy

func (x *AlertPolicyCommonApi) DeleteAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*AlertPolicyCommonApi) ShowAlertPolicy

func (x *AlertPolicyCommonApi) ShowAlertPolicy(ctx context.Context, filter *edgeproto.AlertPolicy, showData *ShowAlertPolicy) error

func (*AlertPolicyCommonApi) UpdateAlertPolicy

func (x *AlertPolicyCommonApi) UpdateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

type AlertPolicyStream

type AlertPolicyStream interface {
	Recv() (*edgeproto.AlertPolicy, error)
}

type AlertPolicyTestOp

type AlertPolicyTestOp func(opts *AlertPolicyTestOptions)

func WithCreatedAlertPolicyTestData

func WithCreatedAlertPolicyTestData(createdData []edgeproto.AlertPolicy) AlertPolicyTestOp

type AlertPolicyTestOptions

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

type AlertStream

type AlertStream interface {
	Recv() (*edgeproto.Alert, error)
}

type AlertTestOp

type AlertTestOp func(opts *AlertTestOptions)

func WithCreatedAlertTestData

func WithCreatedAlertTestData(createdData []edgeproto.Alert) AlertTestOp

type AlertTestOptions

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

type AllDataOut

type AllDataOut struct {
	Flavors                    []edgeproto.Result
	Settings                   *edgeproto.Result
	OperatorCodes              []edgeproto.Result
	ResTagTables               []edgeproto.Result
	TrustPolicies              [][]edgeproto.Result
	GpuDrivers                 [][]edgeproto.Result
	PlatformFeatures           []edgeproto.Result
	Cloudlets                  [][]edgeproto.Result
	CloudletInfos              []edgeproto.Result
	CloudletPools              []edgeproto.Result
	Networks                   [][]edgeproto.Result
	AutoProvPolicies           []edgeproto.Result
	AutoProvPolicyCloudlets    []edgeproto.Result
	AutoScalePolicies          []edgeproto.Result
	IdleReservableClusterInsts *edgeproto.Result
	ClusterInsts               [][]edgeproto.Result
	Apps                       []edgeproto.Result
	AppInstances               [][]edgeproto.Result
	VmPools                    []edgeproto.Result
	AlertPolicies              []edgeproto.Result
	FlowRateLimitSettings      []edgeproto.Result
	MaxReqsRateLimitSettings   []edgeproto.Result
	TrustPolicyExceptions      []edgeproto.Result
	Errors                     []Err
}

Auto-generated code: DO NOT EDIT

type AllDataStreamOut

type AllDataStreamOut struct {
	StreamAppInsts     []StreamAppInst
	StreamClusterInsts []StreamClusterInst
	StreamCloudlets    []StreamCloudlet
}

type ApiClient

type ApiClient struct {
	Conn *grpc.ClientConn
}

func (*ApiClient) AccessCloudlet

func (s *ApiClient) AccessCloudlet(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)

func (*ApiClient) AddAppAlertPolicy

func (s *ApiClient) AddAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)

func (*ApiClient) AddAppAutoProvPolicy

func (s *ApiClient) AddAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)

func (*ApiClient) AddAutoProvPolicyCloudlet

func (s *ApiClient) AddAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)

func (*ApiClient) AddCloudletAllianceOrg

func (s *ApiClient) AddCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)

func (*ApiClient) AddCloudletPoolMember

func (s *ApiClient) AddCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)

func (*ApiClient) AddCloudletResMapping

func (s *ApiClient) AddCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)

func (*ApiClient) AddFlavorRes

func (s *ApiClient) AddFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*ApiClient) AddGPUDriverBuild

func (s *ApiClient) AddGPUDriverBuild(ctx context.Context, in *edgeproto.GPUDriverBuildMember) ([]edgeproto.Result, error)

func (*ApiClient) AddResTag

func (s *ApiClient) AddResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ApiClient) AddVMPoolMember

func (s *ApiClient) AddVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error)

func (*ApiClient) ChangeCloudletDNS

func (s *ApiClient) ChangeCloudletDNS(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Result, error)

func (*ApiClient) CreateAlertPolicy

func (s *ApiClient) CreateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*ApiClient) CreateApp

func (s *ApiClient) CreateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*ApiClient) CreateAppInst

func (s *ApiClient) CreateAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*ApiClient) CreateAutoProvPolicy

func (s *ApiClient) CreateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*ApiClient) CreateAutoScalePolicy

func (s *ApiClient) CreateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*ApiClient) CreateCloudlet

func (s *ApiClient) CreateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)

func (*ApiClient) CreateCloudletNode

func (s *ApiClient) CreateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*ApiClient) CreateCloudletPool

func (s *ApiClient) CreateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*ApiClient) CreateClusterInst

func (s *ApiClient) CreateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)

func (*ApiClient) CreateFlavor

func (s *ApiClient) CreateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*ApiClient) CreateFlowRateLimitSettings

func (s *ApiClient) CreateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*ApiClient) CreateGPUDriver

func (s *ApiClient) CreateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)

func (*ApiClient) CreateMaxReqsRateLimitSettings

func (s *ApiClient) CreateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*ApiClient) CreateNetwork

func (s *ApiClient) CreateNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)

func (*ApiClient) CreateOperatorCode

func (s *ApiClient) CreateOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*ApiClient) CreateResTagTable

func (s *ApiClient) CreateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ApiClient) CreateTrustPolicy

func (s *ApiClient) CreateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)

func (*ApiClient) CreateTrustPolicyException

func (s *ApiClient) CreateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*ApiClient) CreateVMPool

func (s *ApiClient) CreateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*ApiClient) DeleteAlertPolicy

func (s *ApiClient) DeleteAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*ApiClient) DeleteApp

func (s *ApiClient) DeleteApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*ApiClient) DeleteAppInst

func (s *ApiClient) DeleteAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*ApiClient) DeleteAutoProvPolicy

func (s *ApiClient) DeleteAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*ApiClient) DeleteAutoScalePolicy

func (s *ApiClient) DeleteAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*ApiClient) DeleteCloudlet

func (s *ApiClient) DeleteCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)

func (*ApiClient) DeleteCloudletNode

func (s *ApiClient) DeleteCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*ApiClient) DeleteCloudletPool

func (s *ApiClient) DeleteCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*ApiClient) DeleteClusterInst

func (s *ApiClient) DeleteClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)

func (*ApiClient) DeleteFlavor

func (s *ApiClient) DeleteFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*ApiClient) DeleteFlowRateLimitSettings

func (s *ApiClient) DeleteFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*ApiClient) DeleteGPUDriver

func (s *ApiClient) DeleteGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)

func (*ApiClient) DeleteIdleReservableClusterInsts

func (s *ApiClient) DeleteIdleReservableClusterInsts(ctx context.Context, in *edgeproto.IdleReservableClusterInsts) (*edgeproto.Result, error)

func (*ApiClient) DeleteMaxReqsRateLimitSettings

func (s *ApiClient) DeleteMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*ApiClient) DeleteNetwork

func (s *ApiClient) DeleteNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)

func (*ApiClient) DeleteOperatorCode

func (s *ApiClient) DeleteOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*ApiClient) DeletePlatformFeatures

func (s *ApiClient) DeletePlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) (*edgeproto.Result, error)

func (*ApiClient) DeleteResTagTable

func (s *ApiClient) DeleteResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ApiClient) DeleteTrustPolicy

func (s *ApiClient) DeleteTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)

func (*ApiClient) DeleteTrustPolicyException

func (s *ApiClient) DeleteTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*ApiClient) DeleteVMPool

func (s *ApiClient) DeleteVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*ApiClient) DisableDebugLevels

func (s *ApiClient) DisableDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)

func (*ApiClient) EnableDebugLevels

func (s *ApiClient) EnableDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)

func (*ApiClient) EvictCloudletInfo

func (s *ApiClient) EvictCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)

func (*ApiClient) EvictDevice

func (s *ApiClient) EvictDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)

func (*ApiClient) FindFlavorMatch

func (s *ApiClient) FindFlavorMatch(ctx context.Context, in *edgeproto.FlavorMatch) (*edgeproto.FlavorMatch, error)

func (*ApiClient) GenerateAccessKey

func (s *ApiClient) GenerateAccessKey(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*ApiClient) GetAccessData

func (*ApiClient) GetCas

func (*ApiClient) GetCloudletGPUDriverLicenseConfig

func (s *ApiClient) GetCloudletGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*ApiClient) GetCloudletManifest

func (s *ApiClient) GetCloudletManifest(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.CloudletManifest, error)

func (*ApiClient) GetCloudletProps

func (s *ApiClient) GetCloudletProps(ctx context.Context, in *edgeproto.CloudletProps) (*edgeproto.CloudletProps, error)

func (*ApiClient) GetCloudletResourceUsage

func (*ApiClient) GetGPUDriverBuildURL

func (*ApiClient) GetGPUDriverLicenseConfig

func (s *ApiClient) GetGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.GPUDriverKey) (*edgeproto.Result, error)

func (*ApiClient) GetOrganizationsOnCloudlet

func (s *ApiClient) GetOrganizationsOnCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Organization, error)

func (*ApiClient) GetResTagTable

func (s *ApiClient) GetResTagTable(ctx context.Context, in *edgeproto.ResTagTableKey) (*edgeproto.ResTagTable, error)

func (*ApiClient) HandleFedAppInstEvent

func (s *ApiClient) HandleFedAppInstEvent(ctx context.Context, in *edgeproto.FedAppInstEvent) (*edgeproto.Result, error)

func (*ApiClient) InjectCloudletInfo

func (s *ApiClient) InjectCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)

func (*ApiClient) InjectDevice

func (s *ApiClient) InjectDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)

func (*ApiClient) IssueCert

func (*ApiClient) OrganizationInUse

func (s *ApiClient) OrganizationInUse(ctx context.Context, in *edgeproto.Organization) (*edgeproto.Result, error)

func (*ApiClient) RefreshAppInst

func (s *ApiClient) RefreshAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*ApiClient) RemoveAppAlertPolicy

func (s *ApiClient) RemoveAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)

func (*ApiClient) RemoveAppAutoProvPolicy

func (s *ApiClient) RemoveAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)

func (*ApiClient) RemoveAutoProvPolicyCloudlet

func (s *ApiClient) RemoveAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)

func (*ApiClient) RemoveCloudletAllianceOrg

func (s *ApiClient) RemoveCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)

func (*ApiClient) RemoveCloudletPoolMember

func (s *ApiClient) RemoveCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)

func (*ApiClient) RemoveCloudletResMapping

func (s *ApiClient) RemoveCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)

func (*ApiClient) RemoveFlavorRes

func (s *ApiClient) RemoveFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*ApiClient) RemoveGPUDriverBuild

func (s *ApiClient) RemoveGPUDriverBuild(ctx context.Context, in *edgeproto.GPUDriverBuildMember) ([]edgeproto.Result, error)

func (*ApiClient) RemoveResTag

func (s *ApiClient) RemoveResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ApiClient) RemoveVMPoolMember

func (s *ApiClient) RemoveVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error)

func (*ApiClient) RequestAppInstLatency

func (s *ApiClient) RequestAppInstLatency(ctx context.Context, in *edgeproto.AppInstLatency) (*edgeproto.Result, error)

func (*ApiClient) ResetSettings

func (s *ApiClient) ResetSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)

func (*ApiClient) RevokeAccessKey

func (s *ApiClient) RevokeAccessKey(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*ApiClient) RunCommand

func (*ApiClient) RunConsole

func (*ApiClient) RunDebug

func (*ApiClient) SendLocalRequest

func (s *ApiClient) SendLocalRequest(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)

func (*ApiClient) ShowAlert

func (s *ApiClient) ShowAlert(ctx context.Context, in *edgeproto.Alert) ([]edgeproto.Alert, error)

func (*ApiClient) ShowAlertPolicy

func (s *ApiClient) ShowAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) ([]edgeproto.AlertPolicy, error)

func (*ApiClient) ShowApp

func (s *ApiClient) ShowApp(ctx context.Context, in *edgeproto.App) ([]edgeproto.App, error)

func (*ApiClient) ShowAppInst

func (s *ApiClient) ShowAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.AppInst, error)

func (*ApiClient) ShowAppInstClient

func (s *ApiClient) ShowAppInstClient(ctx context.Context, in *edgeproto.AppInstClientKey) ([]edgeproto.AppInstClient, error)

func (*ApiClient) ShowAppInstInfo

func (s *ApiClient) ShowAppInstInfo(ctx context.Context, in *edgeproto.AppInstInfo) ([]edgeproto.AppInstInfo, error)

func (*ApiClient) ShowAppInstMetrics

func (s *ApiClient) ShowAppInstMetrics(ctx context.Context, in *edgeproto.AppInstMetrics) ([]edgeproto.AppInstMetrics, error)

func (*ApiClient) ShowAppInstRefs

func (s *ApiClient) ShowAppInstRefs(ctx context.Context, in *edgeproto.AppInstRefs) ([]edgeproto.AppInstRefs, error)

func (*ApiClient) ShowAutoProvPolicy

func (s *ApiClient) ShowAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) ([]edgeproto.AutoProvPolicy, error)

func (*ApiClient) ShowAutoScalePolicy

func (s *ApiClient) ShowAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) ([]edgeproto.AutoScalePolicy, error)

func (*ApiClient) ShowCloudlet

func (s *ApiClient) ShowCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Cloudlet, error)

func (*ApiClient) ShowCloudletInfo

func (s *ApiClient) ShowCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) ([]edgeproto.CloudletInfo, error)

func (*ApiClient) ShowCloudletMetrics

func (s *ApiClient) ShowCloudletMetrics(ctx context.Context, in *edgeproto.CloudletMetrics) ([]edgeproto.CloudletMetrics, error)

func (*ApiClient) ShowCloudletNode

func (s *ApiClient) ShowCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) ([]edgeproto.CloudletNode, error)

func (*ApiClient) ShowCloudletPool

func (s *ApiClient) ShowCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) ([]edgeproto.CloudletPool, error)

func (*ApiClient) ShowCloudletRefs

func (s *ApiClient) ShowCloudletRefs(ctx context.Context, in *edgeproto.CloudletRefs) ([]edgeproto.CloudletRefs, error)

func (*ApiClient) ShowCloudletsForAppDeployment

func (s *ApiClient) ShowCloudletsForAppDeployment(ctx context.Context, in *edgeproto.DeploymentCloudletRequest) ([]edgeproto.CloudletKey, error)

func (*ApiClient) ShowClusterInst

func (s *ApiClient) ShowClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.ClusterInst, error)

func (*ApiClient) ShowClusterInstInfo

func (s *ApiClient) ShowClusterInstInfo(ctx context.Context, in *edgeproto.ClusterInstInfo) ([]edgeproto.ClusterInstInfo, error)

func (*ApiClient) ShowClusterRefs

func (s *ApiClient) ShowClusterRefs(ctx context.Context, in *edgeproto.ClusterRefs) ([]edgeproto.ClusterRefs, error)

func (*ApiClient) ShowController

func (s *ApiClient) ShowController(ctx context.Context, in *edgeproto.Controller) ([]edgeproto.Controller, error)

func (*ApiClient) ShowDebugLevels

func (s *ApiClient) ShowDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)

func (*ApiClient) ShowDevice

func (s *ApiClient) ShowDevice(ctx context.Context, in *edgeproto.Device) ([]edgeproto.Device, error)

func (*ApiClient) ShowDeviceReport

func (s *ApiClient) ShowDeviceReport(ctx context.Context, in *edgeproto.DeviceReport) ([]edgeproto.Device, error)

func (*ApiClient) ShowFlavor

func (s *ApiClient) ShowFlavor(ctx context.Context, in *edgeproto.Flavor) ([]edgeproto.Flavor, error)

func (*ApiClient) ShowFlavorsForCloudlet

func (s *ApiClient) ShowFlavorsForCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.FlavorKey, error)

func (*ApiClient) ShowFlowRateLimitSettings

func (s *ApiClient) ShowFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) ([]edgeproto.FlowRateLimitSettings, error)

func (*ApiClient) ShowGPUDriver

func (s *ApiClient) ShowGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.GPUDriver, error)

func (*ApiClient) ShowLogs

func (*ApiClient) ShowMaxReqsRateLimitSettings

func (s *ApiClient) ShowMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) ([]edgeproto.MaxReqsRateLimitSettings, error)

func (*ApiClient) ShowNetwork

func (s *ApiClient) ShowNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Network, error)

func (*ApiClient) ShowNode

func (s *ApiClient) ShowNode(ctx context.Context, in *edgeproto.Node) ([]edgeproto.Node, error)

func (*ApiClient) ShowOperatorCode

func (s *ApiClient) ShowOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) ([]edgeproto.OperatorCode, error)

func (*ApiClient) ShowPlatformFeatures

func (s *ApiClient) ShowPlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) ([]edgeproto.PlatformFeatures, error)

func (*ApiClient) ShowRateLimitSettings

func (s *ApiClient) ShowRateLimitSettings(ctx context.Context, in *edgeproto.RateLimitSettings) ([]edgeproto.RateLimitSettings, error)

func (*ApiClient) ShowResTagTable

func (s *ApiClient) ShowResTagTable(ctx context.Context, in *edgeproto.ResTagTable) ([]edgeproto.ResTagTable, error)

func (*ApiClient) ShowSettings

func (s *ApiClient) ShowSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Settings, error)

func (*ApiClient) ShowTrustPolicy

func (s *ApiClient) ShowTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.TrustPolicy, error)

func (*ApiClient) ShowTrustPolicyException

func (s *ApiClient) ShowTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) ([]edgeproto.TrustPolicyException, error)

func (*ApiClient) ShowVMPool

func (s *ApiClient) ShowVMPool(ctx context.Context, in *edgeproto.VMPool) ([]edgeproto.VMPool, error)

func (*ApiClient) StreamAppInst

func (s *ApiClient) StreamAppInst(ctx context.Context, in *edgeproto.AppInstKey) ([]edgeproto.Result, error)

func (*ApiClient) StreamAppInstClientsLocal

func (s *ApiClient) StreamAppInstClientsLocal(ctx context.Context, in *edgeproto.AppInstClientKey) ([]edgeproto.AppInstClient, error)

func (*ApiClient) StreamCloudlet

func (s *ApiClient) StreamCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Result, error)

func (*ApiClient) StreamClusterInst

func (s *ApiClient) StreamClusterInst(ctx context.Context, in *edgeproto.ClusterKey) ([]edgeproto.Result, error)

func (*ApiClient) StreamGPUDriver

func (s *ApiClient) StreamGPUDriver(ctx context.Context, in *edgeproto.GPUDriverKey) ([]edgeproto.Result, error)

func (*ApiClient) UpdateAlertPolicy

func (s *ApiClient) UpdateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*ApiClient) UpdateApp

func (s *ApiClient) UpdateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*ApiClient) UpdateAppInst

func (s *ApiClient) UpdateAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*ApiClient) UpdateAutoProvPolicy

func (s *ApiClient) UpdateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*ApiClient) UpdateAutoScalePolicy

func (s *ApiClient) UpdateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*ApiClient) UpdateCloudlet

func (s *ApiClient) UpdateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)

func (*ApiClient) UpdateCloudletNode

func (s *ApiClient) UpdateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*ApiClient) UpdateCloudletPool

func (s *ApiClient) UpdateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*ApiClient) UpdateClusterInst

func (s *ApiClient) UpdateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)

func (*ApiClient) UpdateFlavor

func (s *ApiClient) UpdateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*ApiClient) UpdateFlowRateLimitSettings

func (s *ApiClient) UpdateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*ApiClient) UpdateGPUDriver

func (s *ApiClient) UpdateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)

func (*ApiClient) UpdateMaxReqsRateLimitSettings

func (s *ApiClient) UpdateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*ApiClient) UpdateNetwork

func (s *ApiClient) UpdateNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)

func (*ApiClient) UpdateResTagTable

func (s *ApiClient) UpdateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ApiClient) UpdateSettings

func (s *ApiClient) UpdateSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)

func (*ApiClient) UpdateTrustPolicy

func (s *ApiClient) UpdateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)

func (*ApiClient) UpdateTrustPolicyException

func (s *ApiClient) UpdateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*ApiClient) UpdateVMPool

func (s *ApiClient) UpdateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

type AppApiClient

type AppApiClient interface {
	CreateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)
	DeleteApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)
	UpdateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)
	ShowApp(ctx context.Context, in *edgeproto.App) ([]edgeproto.App, error)
	AddAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)
	RemoveAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)
	AddAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)
	RemoveAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)
	ShowCloudletsForAppDeployment(ctx context.Context, in *edgeproto.DeploymentCloudletRequest) ([]edgeproto.CloudletKey, error)
}

type AppCommonApi

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

Wrap the api with a common interface

func NewClientAppApi

func NewClientAppApi(api edgeproto.AppApiClient) *AppCommonApi

func NewInternalAppApi

func NewInternalAppApi(api edgeproto.AppApiServer) *AppCommonApi

func (*AppCommonApi) CreateApp

func (x *AppCommonApi) CreateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*AppCommonApi) DeleteApp

func (x *AppCommonApi) DeleteApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*AppCommonApi) ShowApp

func (x *AppCommonApi) ShowApp(ctx context.Context, filter *edgeproto.App, showData *ShowApp) error

func (*AppCommonApi) ShowCloudletsForAppDeployment

func (x *AppCommonApi) ShowCloudletsForAppDeployment(ctx context.Context, filter *edgeproto.DeploymentCloudletRequest, showData *ShowCloudletsForAppDeployment) error

func (*AppCommonApi) UpdateApp

func (x *AppCommonApi) UpdateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

type AppInstApiClient

type AppInstApiClient interface {
	CreateAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)
	DeleteAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)
	RefreshAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)
	UpdateAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)
	ShowAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.AppInst, error)
	HandleFedAppInstEvent(ctx context.Context, in *edgeproto.FedAppInstEvent) (*edgeproto.Result, error)
}

type AppInstClientApiClient

type AppInstClientApiClient interface {
	ShowAppInstClient(ctx context.Context, in *edgeproto.AppInstClientKey) ([]edgeproto.AppInstClient, error)
	StreamAppInstClientsLocal(ctx context.Context, in *edgeproto.AppInstClientKey) ([]edgeproto.AppInstClient, error)
}

type AppInstClientStream

type AppInstClientStream interface {
	Recv() (*edgeproto.AppInstClient, error)
}

type AppInstCommonApi

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

Wrap the api with a common interface

func NewClientAppInstApi

func NewClientAppInstApi(api edgeproto.AppInstApiClient) *AppInstCommonApi

func NewInternalAppInstApi

func NewInternalAppInstApi(api edgeproto.AppInstApiServer) *AppInstCommonApi

func (*AppInstCommonApi) CreateAppInst

func (x *AppInstCommonApi) CreateAppInst(ctx context.Context, in *edgeproto.AppInst) (*edgeproto.Result, error)

func (*AppInstCommonApi) DeleteAppInst

func (x *AppInstCommonApi) DeleteAppInst(ctx context.Context, in *edgeproto.AppInst) (*edgeproto.Result, error)

func (*AppInstCommonApi) ShowAppInst

func (x *AppInstCommonApi) ShowAppInst(ctx context.Context, filter *edgeproto.AppInst, showData *ShowAppInst) error

func (*AppInstCommonApi) UpdateAppInst

func (x *AppInstCommonApi) UpdateAppInst(ctx context.Context, in *edgeproto.AppInst) (*edgeproto.Result, error)

type AppInstInfoApiClient

type AppInstInfoApiClient interface {
	ShowAppInstInfo(ctx context.Context, in *edgeproto.AppInstInfo) ([]edgeproto.AppInstInfo, error)
}

type AppInstInfoCommonApi

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

Wrap the api with a common interface

func (*AppInstInfoCommonApi) ShowAppInstInfo

func (x *AppInstInfoCommonApi) ShowAppInstInfo(ctx context.Context, filter *edgeproto.AppInstInfo, showData *ShowAppInstInfo) error

type AppInstInfoStream

type AppInstInfoStream interface {
	Recv() (*edgeproto.AppInstInfo, error)
}

type AppInstInfoTestOp

type AppInstInfoTestOp func(opts *AppInstInfoTestOptions)

func WithCreatedAppInstInfoTestData

func WithCreatedAppInstInfoTestData(createdData []edgeproto.AppInstInfo) AppInstInfoTestOp

type AppInstInfoTestOptions

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

type AppInstLatencyApiClient

type AppInstLatencyApiClient interface {
	RequestAppInstLatency(ctx context.Context, in *edgeproto.AppInstLatency) (*edgeproto.Result, error)
}

type AppInstMetricsApiClient

type AppInstMetricsApiClient interface {
	ShowAppInstMetrics(ctx context.Context, in *edgeproto.AppInstMetrics) ([]edgeproto.AppInstMetrics, error)
}

type AppInstMetricsStream

type AppInstMetricsStream interface {
	Recv() (*edgeproto.AppInstMetrics, error)
}

type AppInstRefsApiClient

type AppInstRefsApiClient interface {
	ShowAppInstRefs(ctx context.Context, in *edgeproto.AppInstRefs) ([]edgeproto.AppInstRefs, error)
}

type AppInstRefsCommonApi

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

Wrap the api with a common interface

func (*AppInstRefsCommonApi) ShowAppInstRefs

func (x *AppInstRefsCommonApi) ShowAppInstRefs(ctx context.Context, filter *edgeproto.AppInstRefs, showData *ShowAppInstRefs) error

type AppInstRefsStream

type AppInstRefsStream interface {
	Recv() (*edgeproto.AppInstRefs, error)
}

type AppInstRefsTestOp

type AppInstRefsTestOp func(opts *AppInstRefsTestOptions)

func WithCreatedAppInstRefsTestData

func WithCreatedAppInstRefsTestData(createdData []edgeproto.AppInstRefs) AppInstRefsTestOp

type AppInstRefsTestOptions

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

type AppInstStream

type AppInstStream interface {
	Recv() (*edgeproto.AppInst, error)
}

type AppInstTestOp

type AppInstTestOp func(opts *AppInstTestOptions)

func WithCreatedAppInstTestData

func WithCreatedAppInstTestData(createdData []edgeproto.AppInst) AppInstTestOp

type AppInstTestOptions

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

type AppStream

type AppStream interface {
	Recv() (*edgeproto.App, error)
}

type AppTestOp

type AppTestOp func(opts *AppTestOptions)

func WithCreatedAppTestData

func WithCreatedAppTestData(createdData []edgeproto.App) AppTestOp

type AppTestOptions

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

type AutoProvPolicyApiClient

type AutoProvPolicyApiClient interface {
	CreateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)
	DeleteAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)
	UpdateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)
	ShowAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) ([]edgeproto.AutoProvPolicy, error)
	AddAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)
	RemoveAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)
}

type AutoProvPolicyCommonApi

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

Wrap the api with a common interface

func (*AutoProvPolicyCommonApi) CreateAutoProvPolicy

func (x *AutoProvPolicyCommonApi) CreateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*AutoProvPolicyCommonApi) DeleteAutoProvPolicy

func (x *AutoProvPolicyCommonApi) DeleteAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*AutoProvPolicyCommonApi) ShowAutoProvPolicy

func (x *AutoProvPolicyCommonApi) ShowAutoProvPolicy(ctx context.Context, filter *edgeproto.AutoProvPolicy, showData *ShowAutoProvPolicy) error

func (*AutoProvPolicyCommonApi) UpdateAutoProvPolicy

func (x *AutoProvPolicyCommonApi) UpdateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

type AutoProvPolicyStream

type AutoProvPolicyStream interface {
	Recv() (*edgeproto.AutoProvPolicy, error)
}

type AutoProvPolicyTestOp

type AutoProvPolicyTestOp func(opts *AutoProvPolicyTestOptions)

func WithCreatedAutoProvPolicyTestData

func WithCreatedAutoProvPolicyTestData(createdData []edgeproto.AutoProvPolicy) AutoProvPolicyTestOp

type AutoProvPolicyTestOptions

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

type AutoScalePolicyApiClient

type AutoScalePolicyApiClient interface {
	CreateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)
	DeleteAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)
	UpdateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)
	ShowAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) ([]edgeproto.AutoScalePolicy, error)
}

type AutoScalePolicyCommonApi

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

Wrap the api with a common interface

func (*AutoScalePolicyCommonApi) CreateAutoScalePolicy

func (x *AutoScalePolicyCommonApi) CreateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*AutoScalePolicyCommonApi) DeleteAutoScalePolicy

func (x *AutoScalePolicyCommonApi) DeleteAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*AutoScalePolicyCommonApi) ShowAutoScalePolicy

func (x *AutoScalePolicyCommonApi) ShowAutoScalePolicy(ctx context.Context, filter *edgeproto.AutoScalePolicy, showData *ShowAutoScalePolicy) error

func (*AutoScalePolicyCommonApi) UpdateAutoScalePolicy

func (x *AutoScalePolicyCommonApi) UpdateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

type AutoScalePolicyStream

type AutoScalePolicyStream interface {
	Recv() (*edgeproto.AutoScalePolicy, error)
}

type AutoScalePolicyTestOp

type AutoScalePolicyTestOp func(opts *AutoScalePolicyTestOptions)

func WithCreatedAutoScalePolicyTestData

func WithCreatedAutoScalePolicyTestData(createdData []edgeproto.AutoScalePolicy) AutoScalePolicyTestOp

type AutoScalePolicyTestOptions

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

type CliClient

type CliClient struct {
	BaseArgs []string
	RunOps   []wrapper.RunOp
}

func (*CliClient) AccessCloudlet

func (s *CliClient) AccessCloudlet(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)

func (*CliClient) AddAppAlertPolicy

func (s *CliClient) AddAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)

func (*CliClient) AddAppAutoProvPolicy

func (s *CliClient) AddAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)

func (*CliClient) AddAutoProvPolicyCloudlet

func (s *CliClient) AddAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)

func (*CliClient) AddCloudletAllianceOrg

func (s *CliClient) AddCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)

func (*CliClient) AddCloudletPoolMember

func (s *CliClient) AddCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)

func (*CliClient) AddCloudletResMapping

func (s *CliClient) AddCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)

func (*CliClient) AddFlavorRes

func (s *CliClient) AddFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*CliClient) AddGPUDriverBuild

func (s *CliClient) AddGPUDriverBuild(ctx context.Context, in *edgeproto.GPUDriverBuildMember) ([]edgeproto.Result, error)

func (*CliClient) AddResTag

func (s *CliClient) AddResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*CliClient) AddVMPoolMember

func (s *CliClient) AddVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error)

func (*CliClient) ChangeCloudletDNS

func (s *CliClient) ChangeCloudletDNS(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Result, error)

func (*CliClient) CreateAlertPolicy

func (s *CliClient) CreateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*CliClient) CreateApp

func (s *CliClient) CreateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*CliClient) CreateAppInst

func (s *CliClient) CreateAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*CliClient) CreateAutoProvPolicy

func (s *CliClient) CreateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*CliClient) CreateAutoScalePolicy

func (s *CliClient) CreateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*CliClient) CreateCloudlet

func (s *CliClient) CreateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)

func (*CliClient) CreateCloudletNode

func (s *CliClient) CreateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*CliClient) CreateCloudletPool

func (s *CliClient) CreateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*CliClient) CreateClusterInst

func (s *CliClient) CreateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)

func (*CliClient) CreateFlavor

func (s *CliClient) CreateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*CliClient) CreateFlowRateLimitSettings

func (s *CliClient) CreateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*CliClient) CreateGPUDriver

func (s *CliClient) CreateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)

func (*CliClient) CreateMaxReqsRateLimitSettings

func (s *CliClient) CreateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*CliClient) CreateNetwork

func (s *CliClient) CreateNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)

func (*CliClient) CreateOperatorCode

func (s *CliClient) CreateOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*CliClient) CreateResTagTable

func (s *CliClient) CreateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*CliClient) CreateTrustPolicy

func (s *CliClient) CreateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)

func (*CliClient) CreateTrustPolicyException

func (s *CliClient) CreateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*CliClient) CreateVMPool

func (s *CliClient) CreateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*CliClient) DeleteAlertPolicy

func (s *CliClient) DeleteAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*CliClient) DeleteApp

func (s *CliClient) DeleteApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*CliClient) DeleteAppInst

func (s *CliClient) DeleteAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*CliClient) DeleteAutoProvPolicy

func (s *CliClient) DeleteAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*CliClient) DeleteAutoScalePolicy

func (s *CliClient) DeleteAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*CliClient) DeleteCloudlet

func (s *CliClient) DeleteCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)

func (*CliClient) DeleteCloudletNode

func (s *CliClient) DeleteCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*CliClient) DeleteCloudletPool

func (s *CliClient) DeleteCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*CliClient) DeleteClusterInst

func (s *CliClient) DeleteClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)

func (*CliClient) DeleteFlavor

func (s *CliClient) DeleteFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*CliClient) DeleteFlowRateLimitSettings

func (s *CliClient) DeleteFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*CliClient) DeleteGPUDriver

func (s *CliClient) DeleteGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)

func (*CliClient) DeleteIdleReservableClusterInsts

func (s *CliClient) DeleteIdleReservableClusterInsts(ctx context.Context, in *edgeproto.IdleReservableClusterInsts) (*edgeproto.Result, error)

func (*CliClient) DeleteMaxReqsRateLimitSettings

func (s *CliClient) DeleteMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*CliClient) DeleteNetwork

func (s *CliClient) DeleteNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)

func (*CliClient) DeleteOperatorCode

func (s *CliClient) DeleteOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*CliClient) DeletePlatformFeatures

func (s *CliClient) DeletePlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) (*edgeproto.Result, error)

func (*CliClient) DeleteResTagTable

func (s *CliClient) DeleteResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*CliClient) DeleteTrustPolicy

func (s *CliClient) DeleteTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)

func (*CliClient) DeleteTrustPolicyException

func (s *CliClient) DeleteTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*CliClient) DeleteVMPool

func (s *CliClient) DeleteVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*CliClient) DisableDebugLevels

func (s *CliClient) DisableDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)

func (*CliClient) EnableDebugLevels

func (s *CliClient) EnableDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)

func (*CliClient) EvictCloudletInfo

func (s *CliClient) EvictCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)

func (*CliClient) EvictDevice

func (s *CliClient) EvictDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)

func (*CliClient) FindFlavorMatch

func (s *CliClient) FindFlavorMatch(ctx context.Context, in *edgeproto.FlavorMatch) (*edgeproto.FlavorMatch, error)

func (*CliClient) GenerateAccessKey

func (s *CliClient) GenerateAccessKey(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*CliClient) GetAccessData

func (*CliClient) GetCas

func (*CliClient) GetCloudletGPUDriverLicenseConfig

func (s *CliClient) GetCloudletGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*CliClient) GetCloudletManifest

func (s *CliClient) GetCloudletManifest(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.CloudletManifest, error)

func (*CliClient) GetCloudletProps

func (s *CliClient) GetCloudletProps(ctx context.Context, in *edgeproto.CloudletProps) (*edgeproto.CloudletProps, error)

func (*CliClient) GetCloudletResourceUsage

func (*CliClient) GetGPUDriverBuildURL

func (*CliClient) GetGPUDriverLicenseConfig

func (s *CliClient) GetGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.GPUDriverKey) (*edgeproto.Result, error)

func (*CliClient) GetOrganizationsOnCloudlet

func (s *CliClient) GetOrganizationsOnCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Organization, error)

func (*CliClient) GetResTagTable

func (s *CliClient) GetResTagTable(ctx context.Context, in *edgeproto.ResTagTableKey) (*edgeproto.ResTagTable, error)

func (*CliClient) HandleFedAppInstEvent

func (s *CliClient) HandleFedAppInstEvent(ctx context.Context, in *edgeproto.FedAppInstEvent) (*edgeproto.Result, error)

func (*CliClient) InjectCloudletInfo

func (s *CliClient) InjectCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)

func (*CliClient) InjectDevice

func (s *CliClient) InjectDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)

func (*CliClient) IssueCert

func (*CliClient) OrganizationInUse

func (s *CliClient) OrganizationInUse(ctx context.Context, in *edgeproto.Organization) (*edgeproto.Result, error)

func (*CliClient) RefreshAppInst

func (s *CliClient) RefreshAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*CliClient) RemoveAppAlertPolicy

func (s *CliClient) RemoveAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)

func (*CliClient) RemoveAppAutoProvPolicy

func (s *CliClient) RemoveAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)

func (*CliClient) RemoveAutoProvPolicyCloudlet

func (s *CliClient) RemoveAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)

func (*CliClient) RemoveCloudletAllianceOrg

func (s *CliClient) RemoveCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)

func (*CliClient) RemoveCloudletPoolMember

func (s *CliClient) RemoveCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)

func (*CliClient) RemoveCloudletResMapping

func (s *CliClient) RemoveCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)

func (*CliClient) RemoveFlavorRes

func (s *CliClient) RemoveFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*CliClient) RemoveGPUDriverBuild

func (s *CliClient) RemoveGPUDriverBuild(ctx context.Context, in *edgeproto.GPUDriverBuildMember) ([]edgeproto.Result, error)

func (*CliClient) RemoveResTag

func (s *CliClient) RemoveResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*CliClient) RemoveVMPoolMember

func (s *CliClient) RemoveVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error)

func (*CliClient) RequestAppInstLatency

func (s *CliClient) RequestAppInstLatency(ctx context.Context, in *edgeproto.AppInstLatency) (*edgeproto.Result, error)

func (*CliClient) ResetSettings

func (s *CliClient) ResetSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)

func (*CliClient) RevokeAccessKey

func (s *CliClient) RevokeAccessKey(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*CliClient) RunCommand

func (*CliClient) RunConsole

func (*CliClient) RunDebug

func (*CliClient) SendLocalRequest

func (s *CliClient) SendLocalRequest(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)

func (*CliClient) ShowAlert

func (s *CliClient) ShowAlert(ctx context.Context, in *edgeproto.Alert) ([]edgeproto.Alert, error)

func (*CliClient) ShowAlertPolicy

func (s *CliClient) ShowAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) ([]edgeproto.AlertPolicy, error)

func (*CliClient) ShowApp

func (s *CliClient) ShowApp(ctx context.Context, in *edgeproto.App) ([]edgeproto.App, error)

func (*CliClient) ShowAppInst

func (s *CliClient) ShowAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.AppInst, error)

func (*CliClient) ShowAppInstClient

func (s *CliClient) ShowAppInstClient(ctx context.Context, in *edgeproto.AppInstClientKey) ([]edgeproto.AppInstClient, error)

func (*CliClient) ShowAppInstInfo

func (s *CliClient) ShowAppInstInfo(ctx context.Context, in *edgeproto.AppInstInfo) ([]edgeproto.AppInstInfo, error)

func (*CliClient) ShowAppInstMetrics

func (s *CliClient) ShowAppInstMetrics(ctx context.Context, in *edgeproto.AppInstMetrics) ([]edgeproto.AppInstMetrics, error)

func (*CliClient) ShowAppInstRefs

func (s *CliClient) ShowAppInstRefs(ctx context.Context, in *edgeproto.AppInstRefs) ([]edgeproto.AppInstRefs, error)

func (*CliClient) ShowAutoProvPolicy

func (s *CliClient) ShowAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) ([]edgeproto.AutoProvPolicy, error)

func (*CliClient) ShowAutoScalePolicy

func (s *CliClient) ShowAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) ([]edgeproto.AutoScalePolicy, error)

func (*CliClient) ShowCloudlet

func (s *CliClient) ShowCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Cloudlet, error)

func (*CliClient) ShowCloudletInfo

func (s *CliClient) ShowCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) ([]edgeproto.CloudletInfo, error)

func (*CliClient) ShowCloudletMetrics

func (s *CliClient) ShowCloudletMetrics(ctx context.Context, in *edgeproto.CloudletMetrics) ([]edgeproto.CloudletMetrics, error)

func (*CliClient) ShowCloudletNode

func (s *CliClient) ShowCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) ([]edgeproto.CloudletNode, error)

func (*CliClient) ShowCloudletPool

func (s *CliClient) ShowCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) ([]edgeproto.CloudletPool, error)

func (*CliClient) ShowCloudletRefs

func (s *CliClient) ShowCloudletRefs(ctx context.Context, in *edgeproto.CloudletRefs) ([]edgeproto.CloudletRefs, error)

func (*CliClient) ShowCloudletsForAppDeployment

func (s *CliClient) ShowCloudletsForAppDeployment(ctx context.Context, in *edgeproto.DeploymentCloudletRequest) ([]edgeproto.CloudletKey, error)

func (*CliClient) ShowClusterInst

func (s *CliClient) ShowClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.ClusterInst, error)

func (*CliClient) ShowClusterInstInfo

func (s *CliClient) ShowClusterInstInfo(ctx context.Context, in *edgeproto.ClusterInstInfo) ([]edgeproto.ClusterInstInfo, error)

func (*CliClient) ShowClusterRefs

func (s *CliClient) ShowClusterRefs(ctx context.Context, in *edgeproto.ClusterRefs) ([]edgeproto.ClusterRefs, error)

func (*CliClient) ShowController

func (s *CliClient) ShowController(ctx context.Context, in *edgeproto.Controller) ([]edgeproto.Controller, error)

func (*CliClient) ShowDebugLevels

func (s *CliClient) ShowDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)

func (*CliClient) ShowDevice

func (s *CliClient) ShowDevice(ctx context.Context, in *edgeproto.Device) ([]edgeproto.Device, error)

func (*CliClient) ShowDeviceReport

func (s *CliClient) ShowDeviceReport(ctx context.Context, in *edgeproto.DeviceReport) ([]edgeproto.Device, error)

func (*CliClient) ShowFlavor

func (s *CliClient) ShowFlavor(ctx context.Context, in *edgeproto.Flavor) ([]edgeproto.Flavor, error)

func (*CliClient) ShowFlavorsForCloudlet

func (s *CliClient) ShowFlavorsForCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.FlavorKey, error)

func (*CliClient) ShowFlowRateLimitSettings

func (s *CliClient) ShowFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) ([]edgeproto.FlowRateLimitSettings, error)

func (*CliClient) ShowGPUDriver

func (s *CliClient) ShowGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.GPUDriver, error)

func (*CliClient) ShowLogs

func (*CliClient) ShowMaxReqsRateLimitSettings

func (s *CliClient) ShowMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) ([]edgeproto.MaxReqsRateLimitSettings, error)

func (*CliClient) ShowNetwork

func (s *CliClient) ShowNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Network, error)

func (*CliClient) ShowNode

func (s *CliClient) ShowNode(ctx context.Context, in *edgeproto.Node) ([]edgeproto.Node, error)

func (*CliClient) ShowOperatorCode

func (s *CliClient) ShowOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) ([]edgeproto.OperatorCode, error)

func (*CliClient) ShowPlatformFeatures

func (s *CliClient) ShowPlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) ([]edgeproto.PlatformFeatures, error)

func (*CliClient) ShowRateLimitSettings

func (s *CliClient) ShowRateLimitSettings(ctx context.Context, in *edgeproto.RateLimitSettings) ([]edgeproto.RateLimitSettings, error)

func (*CliClient) ShowResTagTable

func (s *CliClient) ShowResTagTable(ctx context.Context, in *edgeproto.ResTagTable) ([]edgeproto.ResTagTable, error)

func (*CliClient) ShowSettings

func (s *CliClient) ShowSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Settings, error)

func (*CliClient) ShowTrustPolicy

func (s *CliClient) ShowTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.TrustPolicy, error)

func (*CliClient) ShowTrustPolicyException

func (s *CliClient) ShowTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) ([]edgeproto.TrustPolicyException, error)

func (*CliClient) ShowVMPool

func (s *CliClient) ShowVMPool(ctx context.Context, in *edgeproto.VMPool) ([]edgeproto.VMPool, error)

func (*CliClient) StreamAppInst

func (s *CliClient) StreamAppInst(ctx context.Context, in *edgeproto.AppInstKey) ([]edgeproto.Result, error)

func (*CliClient) StreamAppInstClientsLocal

func (s *CliClient) StreamAppInstClientsLocal(ctx context.Context, in *edgeproto.AppInstClientKey) ([]edgeproto.AppInstClient, error)

func (*CliClient) StreamCloudlet

func (s *CliClient) StreamCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Result, error)

func (*CliClient) StreamClusterInst

func (s *CliClient) StreamClusterInst(ctx context.Context, in *edgeproto.ClusterKey) ([]edgeproto.Result, error)

func (*CliClient) StreamGPUDriver

func (s *CliClient) StreamGPUDriver(ctx context.Context, in *edgeproto.GPUDriverKey) ([]edgeproto.Result, error)

func (*CliClient) UpdateAlertPolicy

func (s *CliClient) UpdateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*CliClient) UpdateApp

func (s *CliClient) UpdateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*CliClient) UpdateAppInst

func (s *CliClient) UpdateAppInst(ctx context.Context, in *edgeproto.AppInst) ([]edgeproto.Result, error)

func (*CliClient) UpdateAutoProvPolicy

func (s *CliClient) UpdateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*CliClient) UpdateAutoScalePolicy

func (s *CliClient) UpdateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*CliClient) UpdateCloudlet

func (s *CliClient) UpdateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)

func (*CliClient) UpdateCloudletNode

func (s *CliClient) UpdateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*CliClient) UpdateCloudletPool

func (s *CliClient) UpdateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*CliClient) UpdateClusterInst

func (s *CliClient) UpdateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)

func (*CliClient) UpdateFlavor

func (s *CliClient) UpdateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*CliClient) UpdateFlowRateLimitSettings

func (s *CliClient) UpdateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*CliClient) UpdateGPUDriver

func (s *CliClient) UpdateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)

func (*CliClient) UpdateMaxReqsRateLimitSettings

func (s *CliClient) UpdateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*CliClient) UpdateNetwork

func (s *CliClient) UpdateNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)

func (*CliClient) UpdateResTagTable

func (s *CliClient) UpdateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*CliClient) UpdateSettings

func (s *CliClient) UpdateSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)

func (*CliClient) UpdateTrustPolicy

func (s *CliClient) UpdateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)

func (*CliClient) UpdateTrustPolicyException

func (s *CliClient) UpdateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*CliClient) UpdateVMPool

func (s *CliClient) UpdateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

type CloudletApiClient

type CloudletApiClient interface {
	CreateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)
	DeleteCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)
	UpdateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Result, error)
	ShowCloudlet(ctx context.Context, in *edgeproto.Cloudlet) ([]edgeproto.Cloudlet, error)
	GetCloudletManifest(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.CloudletManifest, error)
	GetCloudletProps(ctx context.Context, in *edgeproto.CloudletProps) (*edgeproto.CloudletProps, error)
	GetCloudletResourceQuotaProps(ctx context.Context, in *edgeproto.CloudletResourceQuotaProps) (*edgeproto.CloudletResourceQuotaProps, error)
	GetCloudletResourceUsage(ctx context.Context, in *edgeproto.CloudletResourceUsage) (*edgeproto.CloudletResourceUsage, error)
	AddCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)
	RemoveCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)
	AddCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)
	RemoveCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)
	FindFlavorMatch(ctx context.Context, in *edgeproto.FlavorMatch) (*edgeproto.FlavorMatch, error)
	ShowFlavorsForCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.FlavorKey, error)
	GetOrganizationsOnCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Organization, error)
	RevokeAccessKey(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)
	GenerateAccessKey(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)
	GetCloudletGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)
	ChangeCloudletDNS(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Result, error)
}

type CloudletCommonApi

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

Wrap the api with a common interface

func NewInternalCloudletApi

func NewInternalCloudletApi(api edgeproto.CloudletApiServer) *CloudletCommonApi

func (*CloudletCommonApi) CreateCloudlet

func (x *CloudletCommonApi) CreateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) (*edgeproto.Result, error)

func (*CloudletCommonApi) DeleteCloudlet

func (x *CloudletCommonApi) DeleteCloudlet(ctx context.Context, in *edgeproto.Cloudlet) (*edgeproto.Result, error)

func (*CloudletCommonApi) ShowCloudlet

func (x *CloudletCommonApi) ShowCloudlet(ctx context.Context, filter *edgeproto.Cloudlet, showData *ShowCloudlet) error

func (*CloudletCommonApi) ShowFlavorsForCloudlet

func (x *CloudletCommonApi) ShowFlavorsForCloudlet(ctx context.Context, filter *edgeproto.CloudletKey, showData *ShowFlavorsForCloudlet) error

func (*CloudletCommonApi) UpdateCloudlet

func (x *CloudletCommonApi) UpdateCloudlet(ctx context.Context, in *edgeproto.Cloudlet) (*edgeproto.Result, error)

type CloudletInfoApiClient

type CloudletInfoApiClient interface {
	ShowCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) ([]edgeproto.CloudletInfo, error)
	InjectCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)
	EvictCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)
}

type CloudletInfoCommonApi

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

Wrap the api with a common interface

func (*CloudletInfoCommonApi) ShowCloudletInfo

func (x *CloudletInfoCommonApi) ShowCloudletInfo(ctx context.Context, filter *edgeproto.CloudletInfo, showData *ShowCloudletInfo) error

type CloudletInfoStream

type CloudletInfoStream interface {
	Recv() (*edgeproto.CloudletInfo, error)
}

type CloudletInfoTestOp

type CloudletInfoTestOp func(opts *CloudletInfoTestOptions)

func WithCreatedCloudletInfoTestData

func WithCreatedCloudletInfoTestData(createdData []edgeproto.CloudletInfo) CloudletInfoTestOp

type CloudletInfoTestOptions

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

type CloudletKeyStream

type CloudletKeyStream interface {
	Recv() (*edgeproto.CloudletKey, error)
}

type CloudletMetricsApiClient

type CloudletMetricsApiClient interface {
	ShowCloudletMetrics(ctx context.Context, in *edgeproto.CloudletMetrics) ([]edgeproto.CloudletMetrics, error)
}

type CloudletMetricsStream

type CloudletMetricsStream interface {
	Recv() (*edgeproto.CloudletMetrics, error)
}

type CloudletNodeApiClient

type CloudletNodeApiClient interface {
	CreateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)
	UpdateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)
	ShowCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) ([]edgeproto.CloudletNode, error)
	DeleteCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)
}

type CloudletNodeCommonApi

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

Wrap the api with a common interface

func (*CloudletNodeCommonApi) CreateCloudletNode

func (x *CloudletNodeCommonApi) CreateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*CloudletNodeCommonApi) DeleteCloudletNode

func (x *CloudletNodeCommonApi) DeleteCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*CloudletNodeCommonApi) ShowCloudletNode

func (x *CloudletNodeCommonApi) ShowCloudletNode(ctx context.Context, filter *edgeproto.CloudletNode, showData *ShowCloudletNode) error

func (*CloudletNodeCommonApi) UpdateCloudletNode

func (x *CloudletNodeCommonApi) UpdateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

type CloudletNodeStream

type CloudletNodeStream interface {
	Recv() (*edgeproto.CloudletNode, error)
}

type CloudletNodeTestOp

type CloudletNodeTestOp func(opts *CloudletNodeTestOptions)

func WithCreatedCloudletNodeTestData

func WithCreatedCloudletNodeTestData(createdData []edgeproto.CloudletNode) CloudletNodeTestOp

type CloudletNodeTestOptions

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

type CloudletPoolApiClient

type CloudletPoolApiClient interface {
	CreateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)
	DeleteCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)
	UpdateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)
	ShowCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) ([]edgeproto.CloudletPool, error)
	AddCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)
	RemoveCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)
}

type CloudletPoolCommonApi

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

Wrap the api with a common interface

func (*CloudletPoolCommonApi) CreateCloudletPool

func (x *CloudletPoolCommonApi) CreateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*CloudletPoolCommonApi) DeleteCloudletPool

func (x *CloudletPoolCommonApi) DeleteCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*CloudletPoolCommonApi) ShowCloudletPool

func (x *CloudletPoolCommonApi) ShowCloudletPool(ctx context.Context, filter *edgeproto.CloudletPool, showData *ShowCloudletPool) error

type CloudletPoolStream

type CloudletPoolStream interface {
	Recv() (*edgeproto.CloudletPool, error)
}

type CloudletPoolTestOp

type CloudletPoolTestOp func(opts *CloudletPoolTestOptions)

func WithCreatedCloudletPoolTestData

func WithCreatedCloudletPoolTestData(createdData []edgeproto.CloudletPool) CloudletPoolTestOp

type CloudletPoolTestOptions

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

type CloudletRefsApiClient

type CloudletRefsApiClient interface {
	ShowCloudletRefs(ctx context.Context, in *edgeproto.CloudletRefs) ([]edgeproto.CloudletRefs, error)
}

type CloudletRefsCommonApi

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

Wrap the api with a common interface

func (*CloudletRefsCommonApi) ShowCloudletRefs

func (x *CloudletRefsCommonApi) ShowCloudletRefs(ctx context.Context, filter *edgeproto.CloudletRefs, showData *ShowCloudletRefs) error

type CloudletRefsStream

type CloudletRefsStream interface {
	Recv() (*edgeproto.CloudletRefs, error)
}

type CloudletRefsTestOp

type CloudletRefsTestOp func(opts *CloudletRefsTestOptions)

func WithCreatedCloudletRefsTestData

func WithCreatedCloudletRefsTestData(createdData []edgeproto.CloudletRefs) CloudletRefsTestOp

type CloudletRefsTestOptions

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

type CloudletStream

type CloudletStream interface {
	Recv() (*edgeproto.Cloudlet, error)
}

type CloudletTestOp

type CloudletTestOp func(opts *CloudletTestOptions)

func WithCreatedCloudletTestData

func WithCreatedCloudletTestData(createdData []edgeproto.Cloudlet) CloudletTestOp

type CloudletTestOptions

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

type ClusterInstApiClient

type ClusterInstApiClient interface {
	CreateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)
	DeleteClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)
	UpdateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.Result, error)
	ShowClusterInst(ctx context.Context, in *edgeproto.ClusterInst) ([]edgeproto.ClusterInst, error)
	DeleteIdleReservableClusterInsts(ctx context.Context, in *edgeproto.IdleReservableClusterInsts) (*edgeproto.Result, error)
}

type ClusterInstCommonApi

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

Wrap the api with a common interface

func (*ClusterInstCommonApi) CreateClusterInst

func (x *ClusterInstCommonApi) CreateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) (*edgeproto.Result, error)

func (*ClusterInstCommonApi) DeleteClusterInst

func (x *ClusterInstCommonApi) DeleteClusterInst(ctx context.Context, in *edgeproto.ClusterInst) (*edgeproto.Result, error)

func (*ClusterInstCommonApi) ShowClusterInst

func (x *ClusterInstCommonApi) ShowClusterInst(ctx context.Context, filter *edgeproto.ClusterInst, showData *ShowClusterInst) error

func (*ClusterInstCommonApi) UpdateClusterInst

func (x *ClusterInstCommonApi) UpdateClusterInst(ctx context.Context, in *edgeproto.ClusterInst) (*edgeproto.Result, error)

type ClusterInstInfoApiClient

type ClusterInstInfoApiClient interface {
	ShowClusterInstInfo(ctx context.Context, in *edgeproto.ClusterInstInfo) ([]edgeproto.ClusterInstInfo, error)
}

type ClusterInstInfoCommonApi

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

Wrap the api with a common interface

func (*ClusterInstInfoCommonApi) ShowClusterInstInfo

func (x *ClusterInstInfoCommonApi) ShowClusterInstInfo(ctx context.Context, filter *edgeproto.ClusterInstInfo, showData *ShowClusterInstInfo) error

type ClusterInstInfoStream

type ClusterInstInfoStream interface {
	Recv() (*edgeproto.ClusterInstInfo, error)
}

type ClusterInstInfoTestOp

type ClusterInstInfoTestOp func(opts *ClusterInstInfoTestOptions)

func WithCreatedClusterInstInfoTestData

func WithCreatedClusterInstInfoTestData(createdData []edgeproto.ClusterInstInfo) ClusterInstInfoTestOp

type ClusterInstInfoTestOptions

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

type ClusterInstStream

type ClusterInstStream interface {
	Recv() (*edgeproto.ClusterInst, error)
}

type ClusterInstTestOp

type ClusterInstTestOp func(opts *ClusterInstTestOptions)

func WithCreatedClusterInstTestData

func WithCreatedClusterInstTestData(createdData []edgeproto.ClusterInst) ClusterInstTestOp

type ClusterInstTestOptions

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

type ClusterRefsApiClient

type ClusterRefsApiClient interface {
	ShowClusterRefs(ctx context.Context, in *edgeproto.ClusterRefs) ([]edgeproto.ClusterRefs, error)
}

type ClusterRefsCommonApi

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

Wrap the api with a common interface

func (*ClusterRefsCommonApi) ShowClusterRefs

func (x *ClusterRefsCommonApi) ShowClusterRefs(ctx context.Context, filter *edgeproto.ClusterRefs, showData *ShowClusterRefs) error

type ClusterRefsStream

type ClusterRefsStream interface {
	Recv() (*edgeproto.ClusterRefs, error)
}

type ClusterRefsTestOp

type ClusterRefsTestOp func(opts *ClusterRefsTestOptions)

func WithCreatedClusterRefsTestData

func WithCreatedClusterRefsTestData(createdData []edgeproto.ClusterRefs) ClusterRefsTestOp

type ClusterRefsTestOptions

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

type ControllerApiClient

type ControllerApiClient interface {
	ShowController(ctx context.Context, in *edgeproto.Controller) ([]edgeproto.Controller, error)
}

type ControllerStream

type ControllerStream interface {
	Recv() (*edgeproto.Controller, error)
}

type CudStreamoutAppInst

type CudStreamoutAppInst struct {
	grpc.ServerStream
	Ctx context.Context
}

func NewCudStreamoutAppInst

func NewCudStreamoutAppInst(ctx context.Context) *CudStreamoutAppInst

func (*CudStreamoutAppInst) Context

func (x *CudStreamoutAppInst) Context() context.Context

func (*CudStreamoutAppInst) Send

func (x *CudStreamoutAppInst) Send(res *edgeproto.Result) error

type CudStreamoutCloudlet

type CudStreamoutCloudlet struct {
	grpc.ServerStream
	Ctx context.Context
}

func NewCudStreamoutCloudlet

func NewCudStreamoutCloudlet(ctx context.Context) *CudStreamoutCloudlet

func (*CudStreamoutCloudlet) Context

func (x *CudStreamoutCloudlet) Context() context.Context

func (*CudStreamoutCloudlet) Send

type CudStreamoutClusterInst

type CudStreamoutClusterInst struct {
	grpc.ServerStream
	Ctx context.Context
}

func NewCudStreamoutClusterInst

func NewCudStreamoutClusterInst(ctx context.Context) *CudStreamoutClusterInst

func (*CudStreamoutClusterInst) Context

func (*CudStreamoutClusterInst) Send

type CudStreamoutGPUDriver

type CudStreamoutGPUDriver struct {
	grpc.ServerStream
	Ctx context.Context
}

func NewCudStreamoutGPUDriver

func NewCudStreamoutGPUDriver(ctx context.Context) *CudStreamoutGPUDriver

func (*CudStreamoutGPUDriver) Context

func (x *CudStreamoutGPUDriver) Context() context.Context

func (*CudStreamoutGPUDriver) Send

type CudStreamoutNetwork

type CudStreamoutNetwork struct {
	grpc.ServerStream
	Ctx context.Context
}

func NewCudStreamoutNetwork

func NewCudStreamoutNetwork(ctx context.Context) *CudStreamoutNetwork

func (*CudStreamoutNetwork) Context

func (x *CudStreamoutNetwork) Context() context.Context

func (*CudStreamoutNetwork) Send

func (x *CudStreamoutNetwork) Send(res *edgeproto.Result) error

type CudStreamoutTrustPolicy

type CudStreamoutTrustPolicy struct {
	grpc.ServerStream
	Ctx context.Context
}

func NewCudStreamoutTrustPolicy

func NewCudStreamoutTrustPolicy(ctx context.Context) *CudStreamoutTrustPolicy

func (*CudStreamoutTrustPolicy) Context

func (*CudStreamoutTrustPolicy) Send

type CustomData

type CustomData struct {
	OrgsOnCloudlet map[edgeproto.CloudletKey][]string
}

func (*CustomData) Init

func (s *CustomData) Init()

type DebugApiClient

type DebugApiClient interface {
	EnableDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)
	DisableDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)
	ShowDebugLevels(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)
	RunDebug(ctx context.Context, in *edgeproto.DebugRequest) ([]edgeproto.DebugReply, error)
}

type DebugDataOut

type DebugDataOut struct {
	Requests [][]edgeproto.DebugReply
	Errors   []Err
}

Auto-generated code: DO NOT EDIT

func (*DebugDataOut) Sort

func (s *DebugDataOut) Sort()

type DebugReplyStream

type DebugReplyStream interface {
	Recv() (*edgeproto.DebugReply, error)
}

type DeviceApiClient

type DeviceApiClient interface {
	InjectDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)
	ShowDevice(ctx context.Context, in *edgeproto.Device) ([]edgeproto.Device, error)
	EvictDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)
	ShowDeviceReport(ctx context.Context, in *edgeproto.DeviceReport) ([]edgeproto.Device, error)
}

type DeviceCommonApi

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

Wrap the api with a common interface

func NewClientDeviceApi

func NewClientDeviceApi(api edgeproto.DeviceApiClient) *DeviceCommonApi

func NewInternalDeviceApi

func NewInternalDeviceApi(api edgeproto.DeviceApiServer) *DeviceCommonApi

func (*DeviceCommonApi) ShowDevice

func (x *DeviceCommonApi) ShowDevice(ctx context.Context, filter *edgeproto.Device, showData *ShowDevice) error

type DeviceDataOut

type DeviceDataOut struct {
	Devices []edgeproto.Result
	Errors  []Err
}

type DeviceStream

type DeviceStream interface {
	Recv() (*edgeproto.Device, error)
}

type DeviceTestOp

type DeviceTestOp func(opts *DeviceTestOptions)

func WithCreatedDeviceTestData

func WithCreatedDeviceTestData(createdData []edgeproto.Device) DeviceTestOp

type DeviceTestOptions

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

type DummyServer

type DummyServer struct {
	CustomData
	AlertCache                    edgeproto.AlertCache
	AlertPolicyCache              edgeproto.AlertPolicyCache
	SettingsCache                 edgeproto.SettingsCache
	FlavorCache                   edgeproto.FlavorCache
	OperatorCodeCache             edgeproto.OperatorCodeCache
	ResTagTableCache              edgeproto.ResTagTableCache
	AutoScalePolicyCache          edgeproto.AutoScalePolicyCache
	TrustPolicyCache              edgeproto.TrustPolicyCache
	AppCache                      edgeproto.AppCache
	AppInstCache                  edgeproto.AppInstCache
	AppInstInfoCache              edgeproto.AppInstInfoCache
	FedAppInstCache               edgeproto.FedAppInstCache
	CloudletInternalCache         edgeproto.CloudletInternalCache
	PlatformFeaturesCache         edgeproto.PlatformFeaturesCache
	GPUDriverCache                edgeproto.GPUDriverCache
	CloudletCache                 edgeproto.CloudletCache
	CloudletInfoCache             edgeproto.CloudletInfoCache
	CloudletPoolCache             edgeproto.CloudletPoolCache
	VMPoolCache                   edgeproto.VMPoolCache
	VMPoolInfoCache               edgeproto.VMPoolInfoCache
	ClusterInstCache              edgeproto.ClusterInstCache
	ClusterInstInfoCache          edgeproto.ClusterInstInfoCache
	AutoProvPolicyCache           edgeproto.AutoProvPolicyCache
	AutoProvInfoCache             edgeproto.AutoProvInfoCache
	TrustPolicyExceptionCache     edgeproto.TrustPolicyExceptionCache
	TPEInstanceStateCache         edgeproto.TPEInstanceStateCache
	NetworkCache                  edgeproto.NetworkCache
	CloudletRefsCache             edgeproto.CloudletRefsCache
	ClusterRefsCache              edgeproto.ClusterRefsCache
	AppInstRefsCache              edgeproto.AppInstRefsCache
	FlowRateLimitSettingsCache    edgeproto.FlowRateLimitSettingsCache
	MaxReqsRateLimitSettingsCache edgeproto.MaxReqsRateLimitSettingsCache
	AppInstClientKeyCache         edgeproto.AppInstClientKeyCache
	CloudletNodeCache             edgeproto.CloudletNodeCache
	ControllerCache               edgeproto.ControllerCache
	NodeCache                     edgeproto.NodeCache
	DeviceCache                   edgeproto.DeviceCache
	ShowDummyCount                int
	CudNoop                       bool
	MidstreamFailChs              map[string]chan bool
}

func RegisterDummyServer

func RegisterDummyServer(server *grpc.Server) *DummyServer

func (*DummyServer) AddAppAlertPolicy

func (s *DummyServer) AddAppAlertPolicy(ctx context.Context, alert *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)

func (*DummyServer) AddAppAutoProvPolicy

func (s *DummyServer) AddAppAutoProvPolicy(ctx context.Context, apppolicy *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)

func (*DummyServer) AddAutoProvPolicyCloudlet

func (s *DummyServer) AddAutoProvPolicyCloudlet(ctx context.Context, cloudlet *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)

func (*DummyServer) AddCloudletAllianceOrg

func (s *DummyServer) AddCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)

func (*DummyServer) AddCloudletPoolMember

func (s *DummyServer) AddCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)

func (*DummyServer) AddCloudletResMapping

func (s *DummyServer) AddCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)

func (*DummyServer) AddFlavorRes

func (s *DummyServer) AddFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*DummyServer) AddResTag

func (*DummyServer) AddVMPoolMember

func (s *DummyServer) AddVMPoolMember(ctx context.Context, cloudlet *edgeproto.VMPoolMember) (*edgeproto.Result, error)

func (*DummyServer) ChangeCloudletDNS

func (*DummyServer) CreateAlertPolicy

func (s *DummyServer) CreateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*DummyServer) CreateApp

func (s *DummyServer) CreateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*DummyServer) CreateAppInst

func (*DummyServer) CreateAutoProvPolicy

func (s *DummyServer) CreateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*DummyServer) CreateAutoScalePolicy

func (s *DummyServer) CreateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*DummyServer) CreateCloudlet

func (*DummyServer) CreateCloudletNode

func (s *DummyServer) CreateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*DummyServer) CreateCloudletPool

func (s *DummyServer) CreateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*DummyServer) CreateClusterInst

func (*DummyServer) CreateFlavor

func (s *DummyServer) CreateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*DummyServer) CreateFlowRateLimitSettings

func (s *DummyServer) CreateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*DummyServer) CreateGPUDriver

func (*DummyServer) CreateMaxReqsRateLimitSettings

func (s *DummyServer) CreateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*DummyServer) CreateNetwork

func (*DummyServer) CreateOperatorCode

func (s *DummyServer) CreateOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*DummyServer) CreateResTagTable

func (s *DummyServer) CreateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*DummyServer) CreateTrustPolicy

func (*DummyServer) CreateTrustPolicyException

func (s *DummyServer) CreateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*DummyServer) CreateVMPool

func (s *DummyServer) CreateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*DummyServer) DeleteAlertPolicy

func (s *DummyServer) DeleteAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*DummyServer) DeleteApp

func (s *DummyServer) DeleteApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*DummyServer) DeleteAppInst

func (*DummyServer) DeleteAutoProvPolicy

func (s *DummyServer) DeleteAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*DummyServer) DeleteAutoScalePolicy

func (s *DummyServer) DeleteAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*DummyServer) DeleteCloudlet

func (*DummyServer) DeleteCloudletNode

func (s *DummyServer) DeleteCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*DummyServer) DeleteCloudletPool

func (s *DummyServer) DeleteCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*DummyServer) DeleteClusterInst

func (*DummyServer) DeleteFlavor

func (s *DummyServer) DeleteFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*DummyServer) DeleteFlowRateLimitSettings

func (s *DummyServer) DeleteFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*DummyServer) DeleteGPUDriver

func (*DummyServer) DeleteIdleReservableClusterInsts

func (s *DummyServer) DeleteIdleReservableClusterInsts(ctx context.Context, in *edgeproto.IdleReservableClusterInsts) (*edgeproto.Result, error)

func (*DummyServer) DeleteMaxReqsRateLimitSettings

func (s *DummyServer) DeleteMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*DummyServer) DeleteNetwork

func (*DummyServer) DeleteOperatorCode

func (s *DummyServer) DeleteOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*DummyServer) DeletePlatformFeatures

func (s *DummyServer) DeletePlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) (*edgeproto.Result, error)

func (*DummyServer) DeleteResTagTable

func (s *DummyServer) DeleteResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*DummyServer) DeleteTrustPolicy

func (*DummyServer) DeleteTrustPolicyException

func (s *DummyServer) DeleteTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*DummyServer) DeleteVMPool

func (s *DummyServer) DeleteVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*DummyServer) DisableMidstreamFailure

func (s *DummyServer) DisableMidstreamFailure(api string)

func (*DummyServer) EnableMidstreamFailure

func (s *DummyServer) EnableMidstreamFailure(api string, syncCh chan bool)

func (*DummyServer) EvictCloudletInfo

func (s *DummyServer) EvictCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)

func (*DummyServer) EvictDevice

func (s *DummyServer) EvictDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)

func (*DummyServer) FindFlavorMatch

func (s *DummyServer) FindFlavorMatch(ctx context.Context, in *edgeproto.FlavorMatch) (*edgeproto.FlavorMatch, error)

func (*DummyServer) GenerateAccessKey

func (s *DummyServer) GenerateAccessKey(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*DummyServer) GetCloudletGPUDriverLicenseConfig

func (s *DummyServer) GetCloudletGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*DummyServer) GetCloudletManifest

func (s *DummyServer) GetCloudletManifest(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.CloudletManifest, error)

func (*DummyServer) GetCloudletProps

func (s *DummyServer) GetCloudletProps(ctx context.Context, in *edgeproto.CloudletProps) (*edgeproto.CloudletProps, error)

func (*DummyServer) GetCloudletResourceUsage

func (s *DummyServer) GetCloudletResourceUsage(ctx context.Context, usage *edgeproto.CloudletResourceUsage) (*edgeproto.CloudletResourceUsage, error)

func (*DummyServer) GetGPUDriverBuildURL

func (*DummyServer) GetGPUDriverLicenseConfig

func (s *DummyServer) GetGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.GPUDriverKey) (*edgeproto.Result, error)

func (*DummyServer) HandleFedAppInstEvent

func (s *DummyServer) HandleFedAppInstEvent(ctx context.Context, in *edgeproto.FedAppInstEvent) (*edgeproto.Result, error)

func (*DummyServer) InjectCloudletInfo

func (s *DummyServer) InjectCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error)

func (*DummyServer) InjectDevice

func (s *DummyServer) InjectDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error)

func (*DummyServer) OrganizationInUse

func (s *DummyServer) OrganizationInUse(ctx context.Context, in *edgeproto.Organization) (*edgeproto.Result, error)

func (*DummyServer) RefreshAppInst

func (*DummyServer) RemoveAppAlertPolicy

func (s *DummyServer) RemoveAppAlertPolicy(ctx context.Context, alert *edgeproto.AppAlertPolicy) (*edgeproto.Result, error)

func (*DummyServer) RemoveAppAutoProvPolicy

func (s *DummyServer) RemoveAppAutoProvPolicy(ctx context.Context, apppolicy *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error)

func (*DummyServer) RemoveAutoProvPolicyCloudlet

func (s *DummyServer) RemoveAutoProvPolicyCloudlet(ctx context.Context, cloudlet *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error)

func (*DummyServer) RemoveCloudletAllianceOrg

func (s *DummyServer) RemoveCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error)

func (*DummyServer) RemoveCloudletPoolMember

func (s *DummyServer) RemoveCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error)

func (*DummyServer) RemoveCloudletResMapping

func (s *DummyServer) RemoveCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error)

func (*DummyServer) RemoveFlavorRes

func (s *DummyServer) RemoveFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*DummyServer) RemoveResTag

func (s *DummyServer) RemoveResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*DummyServer) RemoveVMPoolMember

func (s *DummyServer) RemoveVMPoolMember(ctx context.Context, cloudlet *edgeproto.VMPoolMember) (*edgeproto.Result, error)

func (*DummyServer) ResetSettings

func (s *DummyServer) ResetSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)

func (*DummyServer) RevokeAccessKey

func (s *DummyServer) RevokeAccessKey(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.Result, error)

func (*DummyServer) SetDummyObjs

func (s *DummyServer) SetDummyObjs(ctx context.Context, a Action, tag string, num int)

func (*DummyServer) SetDummyOrgObjs

func (s *DummyServer) SetDummyOrgObjs(ctx context.Context, a Action, org string, num int)

func (*DummyServer) ShowAlert

func (*DummyServer) ShowAlertPolicy

func (*DummyServer) ShowApp

func (s *DummyServer) ShowApp(in *edgeproto.App, server edgeproto.AppApi_ShowAppServer) error

func (*DummyServer) ShowAppInst

func (*DummyServer) ShowAppInstInfo

func (*DummyServer) ShowAppInstRefs

func (*DummyServer) ShowCloudlet

func (*DummyServer) ShowCloudletInfo

func (*DummyServer) ShowCloudletNode

func (*DummyServer) ShowCloudletPool

func (*DummyServer) ShowCloudletRefs

func (*DummyServer) ShowClusterInst

func (*DummyServer) ShowClusterRefs

func (*DummyServer) ShowController

func (*DummyServer) ShowDevice

func (*DummyServer) ShowDeviceReport

func (*DummyServer) ShowFlavor

func (*DummyServer) ShowGPUDriver

func (*DummyServer) ShowNetwork

func (*DummyServer) ShowNode

func (*DummyServer) ShowOperatorCode

func (*DummyServer) ShowResTagTable

func (*DummyServer) ShowSettings

func (s *DummyServer) ShowSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Settings, error)

func (*DummyServer) ShowTrustPolicy

func (*DummyServer) ShowVMPool

func (*DummyServer) UpdateAlertPolicy

func (s *DummyServer) UpdateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error)

func (*DummyServer) UpdateApp

func (s *DummyServer) UpdateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error)

func (*DummyServer) UpdateAppInst

func (*DummyServer) UpdateAutoProvPolicy

func (s *DummyServer) UpdateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error)

func (*DummyServer) UpdateAutoScalePolicy

func (s *DummyServer) UpdateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error)

func (*DummyServer) UpdateCloudlet

func (*DummyServer) UpdateCloudletNode

func (s *DummyServer) UpdateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error)

func (*DummyServer) UpdateCloudletPool

func (s *DummyServer) UpdateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error)

func (*DummyServer) UpdateClusterInst

func (*DummyServer) UpdateFlavor

func (s *DummyServer) UpdateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*DummyServer) UpdateFlowRateLimitSettings

func (s *DummyServer) UpdateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)

func (*DummyServer) UpdateGPUDriver

func (*DummyServer) UpdateMaxReqsRateLimitSettings

func (s *DummyServer) UpdateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)

func (*DummyServer) UpdateNetwork

func (*DummyServer) UpdateResTagTable

func (s *DummyServer) UpdateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*DummyServer) UpdateSettings

func (s *DummyServer) UpdateSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)

func (*DummyServer) UpdateTrustPolicy

func (*DummyServer) UpdateTrustPolicyException

func (s *DummyServer) UpdateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)

func (*DummyServer) UpdateVMPool

func (s *DummyServer) UpdateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*DummyServer) UpgradeAccessKey

type Err

type Err struct {
	Desc string
	Msg  string
}

type ExecApiClient

type ExecApiClient interface {
	RunCommand(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)
	RunConsole(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)
	ShowLogs(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)
	AccessCloudlet(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)
	SendLocalRequest(ctx context.Context, in *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error)
}

type FlavorApiClient

type FlavorApiClient interface {
	CreateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)
	DeleteFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)
	UpdateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)
	ShowFlavor(ctx context.Context, in *edgeproto.Flavor) ([]edgeproto.Flavor, error)
	AddFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)
	RemoveFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)
}

type FlavorCommonApi

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

Wrap the api with a common interface

func NewClientFlavorApi

func NewClientFlavorApi(api edgeproto.FlavorApiClient) *FlavorCommonApi

func NewInternalFlavorApi

func NewInternalFlavorApi(api edgeproto.FlavorApiServer) *FlavorCommonApi

func (*FlavorCommonApi) CreateFlavor

func (x *FlavorCommonApi) CreateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*FlavorCommonApi) DeleteFlavor

func (x *FlavorCommonApi) DeleteFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

func (*FlavorCommonApi) ShowFlavor

func (x *FlavorCommonApi) ShowFlavor(ctx context.Context, filter *edgeproto.Flavor, showData *ShowFlavor) error

func (*FlavorCommonApi) UpdateFlavor

func (x *FlavorCommonApi) UpdateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error)

type FlavorKeyStream

type FlavorKeyStream interface {
	Recv() (*edgeproto.FlavorKey, error)
}

type FlavorStream

type FlavorStream interface {
	Recv() (*edgeproto.Flavor, error)
}

type FlavorTestOp

type FlavorTestOp func(opts *FlavorTestOptions)

func WithCreatedFlavorTestData

func WithCreatedFlavorTestData(createdData []edgeproto.Flavor) FlavorTestOp

type FlavorTestOptions

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

type FlowRateLimitSettingsStream

type FlowRateLimitSettingsStream interface {
	Recv() (*edgeproto.FlowRateLimitSettings, error)
}

type GPUDriverApiClient

type GPUDriverApiClient interface {
	CreateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)
	DeleteGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)
	UpdateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.Result, error)
	ShowGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) ([]edgeproto.GPUDriver, error)
	AddGPUDriverBuild(ctx context.Context, in *edgeproto.GPUDriverBuildMember) ([]edgeproto.Result, error)
	RemoveGPUDriverBuild(ctx context.Context, in *edgeproto.GPUDriverBuildMember) ([]edgeproto.Result, error)
	GetGPUDriverBuildURL(ctx context.Context, in *edgeproto.GPUDriverBuildMember) (*edgeproto.GPUDriverBuildURL, error)
	GetGPUDriverLicenseConfig(ctx context.Context, in *edgeproto.GPUDriverKey) (*edgeproto.Result, error)
}

type GPUDriverCommonApi

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

Wrap the api with a common interface

func (*GPUDriverCommonApi) CreateGPUDriver

func (x *GPUDriverCommonApi) CreateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) (*edgeproto.Result, error)

func (*GPUDriverCommonApi) DeleteGPUDriver

func (x *GPUDriverCommonApi) DeleteGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) (*edgeproto.Result, error)

func (*GPUDriverCommonApi) ShowGPUDriver

func (x *GPUDriverCommonApi) ShowGPUDriver(ctx context.Context, filter *edgeproto.GPUDriver, showData *ShowGPUDriver) error

func (*GPUDriverCommonApi) UpdateGPUDriver

func (x *GPUDriverCommonApi) UpdateGPUDriver(ctx context.Context, in *edgeproto.GPUDriver) (*edgeproto.Result, error)

type GPUDriverStream

type GPUDriverStream interface {
	Recv() (*edgeproto.GPUDriver, error)
}

type GPUDriverTestOp

type GPUDriverTestOp func(opts *GPUDriverTestOptions)

func WithCreatedGPUDriverTestData

func WithCreatedGPUDriverTestData(createdData []edgeproto.GPUDriver) GPUDriverTestOp

type GPUDriverTestOptions

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

type InternalCUDAPIs

type InternalCUDAPIs interface {
	GetAlertPolicyApi() edgeproto.AlertPolicyApiServer
	GetFlavorApi() edgeproto.FlavorApiServer
	GetOperatorCodeApi() edgeproto.OperatorCodeApiServer
	GetResTagTableApi() edgeproto.ResTagTableApiServer
	GetAutoScalePolicyApi() edgeproto.AutoScalePolicyApiServer
	GetTrustPolicyApi() edgeproto.TrustPolicyApiServer
	GetAppApi() edgeproto.AppApiServer
	GetAppInstApi() edgeproto.AppInstApiServer
	GetGPUDriverApi() edgeproto.GPUDriverApiServer
	GetCloudletApi() edgeproto.CloudletApiServer
	GetCloudletPoolApi() edgeproto.CloudletPoolApiServer
	GetVMPoolApi() edgeproto.VMPoolApiServer
	GetClusterInstApi() edgeproto.ClusterInstApiServer
	GetAutoProvPolicyApi() edgeproto.AutoProvPolicyApiServer
	GetTrustPolicyExceptionApi() edgeproto.TrustPolicyExceptionApiServer
	GetNetworkApi() edgeproto.NetworkApiServer
	GetCloudletNodeApi() edgeproto.CloudletNodeApiServer
}

type MaxReqsRateLimitSettingsStream

type MaxReqsRateLimitSettingsStream interface {
	Recv() (*edgeproto.MaxReqsRateLimitSettings, error)
}

type NetworkApiClient

type NetworkApiClient interface {
	CreateNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)
	DeleteNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)
	UpdateNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Result, error)
	ShowNetwork(ctx context.Context, in *edgeproto.Network) ([]edgeproto.Network, error)
}

type NetworkCommonApi

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

Wrap the api with a common interface

func NewClientNetworkApi

func NewClientNetworkApi(api edgeproto.NetworkApiClient) *NetworkCommonApi

func NewInternalNetworkApi

func NewInternalNetworkApi(api edgeproto.NetworkApiServer) *NetworkCommonApi

func (*NetworkCommonApi) CreateNetwork

func (x *NetworkCommonApi) CreateNetwork(ctx context.Context, in *edgeproto.Network) (*edgeproto.Result, error)

func (*NetworkCommonApi) DeleteNetwork

func (x *NetworkCommonApi) DeleteNetwork(ctx context.Context, in *edgeproto.Network) (*edgeproto.Result, error)

func (*NetworkCommonApi) ShowNetwork

func (x *NetworkCommonApi) ShowNetwork(ctx context.Context, filter *edgeproto.Network, showData *ShowNetwork) error

func (*NetworkCommonApi) UpdateNetwork

func (x *NetworkCommonApi) UpdateNetwork(ctx context.Context, in *edgeproto.Network) (*edgeproto.Result, error)

type NetworkStream

type NetworkStream interface {
	Recv() (*edgeproto.Network, error)
}

type NetworkTestOp

type NetworkTestOp func(opts *NetworkTestOptions)

func WithCreatedNetworkTestData

func WithCreatedNetworkTestData(createdData []edgeproto.Network) NetworkTestOp

type NetworkTestOptions

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

type NodeApiClient

type NodeApiClient interface {
	ShowNode(ctx context.Context, in *edgeproto.Node) ([]edgeproto.Node, error)
}

type NodeCommonApi

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

Wrap the api with a common interface

func NewClientNodeApi

func NewClientNodeApi(api edgeproto.NodeApiClient) *NodeCommonApi

func NewInternalNodeApi

func NewInternalNodeApi(api edgeproto.NodeApiServer) *NodeCommonApi

func (*NodeCommonApi) ShowNode

func (x *NodeCommonApi) ShowNode(ctx context.Context, filter *edgeproto.Node, showData *ShowNode) error

type NodeDataOut

type NodeDataOut struct {
	Errors []Err
}

type NodeStream

type NodeStream interface {
	Recv() (*edgeproto.Node, error)
}

type NodeTestOp

type NodeTestOp func(opts *NodeTestOptions)

func WithCreatedNodeTestData

func WithCreatedNodeTestData(createdData []edgeproto.Node) NodeTestOp

type NodeTestOptions

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

type OperatorCodeApiClient

type OperatorCodeApiClient interface {
	CreateOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)
	DeleteOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)
	ShowOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) ([]edgeproto.OperatorCode, error)
}

type OperatorCodeCommonApi

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

Wrap the api with a common interface

func (*OperatorCodeCommonApi) CreateOperatorCode

func (x *OperatorCodeCommonApi) CreateOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*OperatorCodeCommonApi) DeleteOperatorCode

func (x *OperatorCodeCommonApi) DeleteOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error)

func (*OperatorCodeCommonApi) ShowOperatorCode

func (x *OperatorCodeCommonApi) ShowOperatorCode(ctx context.Context, filter *edgeproto.OperatorCode, showData *ShowOperatorCode) error

type OperatorCodeStream

type OperatorCodeStream interface {
	Recv() (*edgeproto.OperatorCode, error)
}

type OperatorCodeTestOp

type OperatorCodeTestOp func(opts *OperatorCodeTestOptions)

func WithCreatedOperatorCodeTestData

func WithCreatedOperatorCodeTestData(createdData []edgeproto.OperatorCode) OperatorCodeTestOp

type OperatorCodeTestOptions

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

type OrganizationApiClient

type OrganizationApiClient interface {
	OrganizationInUse(ctx context.Context, in *edgeproto.Organization) (*edgeproto.Result, error)
}

type OrganizationDataOut

type OrganizationDataOut struct {
	Orgs   []edgeproto.Result
	Errors []Err
}

Auto-generated code: DO NOT EDIT

type OrganizationStream

type OrganizationStream interface {
	Recv() (*edgeproto.Organization, error)
}

type PlatformFeaturesApiClient

type PlatformFeaturesApiClient interface {
	ShowPlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) ([]edgeproto.PlatformFeatures, error)
	DeletePlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) (*edgeproto.Result, error)
}

type PlatformFeaturesStream

type PlatformFeaturesStream interface {
	Recv() (*edgeproto.PlatformFeatures, error)
}

type RateLimitSettingsApiClient

type RateLimitSettingsApiClient interface {
	ShowRateLimitSettings(ctx context.Context, in *edgeproto.RateLimitSettings) ([]edgeproto.RateLimitSettings, error)
	CreateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)
	UpdateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)
	DeleteFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error)
	ShowFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) ([]edgeproto.FlowRateLimitSettings, error)
	CreateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)
	UpdateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)
	DeleteMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error)
	ShowMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) ([]edgeproto.MaxReqsRateLimitSettings, error)
}

type RateLimitSettingsDataOut

type RateLimitSettingsDataOut struct {
	Errors []Err
}

Auto-generated code: DO NOT EDIT

type RateLimitSettingsStream

type RateLimitSettingsStream interface {
	Recv() (*edgeproto.RateLimitSettings, error)
}

type ResTagTableApiClient

type ResTagTableApiClient interface {
	CreateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)
	DeleteResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)
	UpdateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)
	ShowResTagTable(ctx context.Context, in *edgeproto.ResTagTable) ([]edgeproto.ResTagTable, error)
	AddResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)
	RemoveResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)
	GetResTagTable(ctx context.Context, in *edgeproto.ResTagTableKey) (*edgeproto.ResTagTable, error)
}

type ResTagTableCommonApi

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

Wrap the api with a common interface

func (*ResTagTableCommonApi) CreateResTagTable

func (x *ResTagTableCommonApi) CreateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ResTagTableCommonApi) DeleteResTagTable

func (x *ResTagTableCommonApi) DeleteResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error)

func (*ResTagTableCommonApi) ShowResTagTable

func (x *ResTagTableCommonApi) ShowResTagTable(ctx context.Context, filter *edgeproto.ResTagTable, showData *ShowResTagTable) error

type ResTagTableStream

type ResTagTableStream interface {
	Recv() (*edgeproto.ResTagTable, error)
}

type ResTagTableTestOp

type ResTagTableTestOp func(opts *ResTagTableTestOptions)

func WithCreatedResTagTableTestData

func WithCreatedResTagTableTestData(createdData []edgeproto.ResTagTable) ResTagTableTestOp

type ResTagTableTestOptions

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

type ResultStream

type ResultStream interface {
	Recv() (*edgeproto.Result, error)
}

type Run

type Run struct {
	Errs []Err
	Mode string
	Rc   *bool
	// contains filtered or unexported fields
}

func NewRun

func NewRun(client Client, ctx context.Context, mode string, rc *bool) *Run

func (*Run) AlertApi

func (r *Run) AlertApi(data *[]edgeproto.Alert, dataMap interface{}, dataOut interface{})

func (*Run) AlertPolicyApi

func (r *Run) AlertPolicyApi(data *[]edgeproto.AlertPolicy, dataMap interface{}, dataOut interface{})

func (*Run) AppApi

func (r *Run) AppApi(data *[]edgeproto.App, dataMap interface{}, dataOut interface{})

func (*Run) AppApi_AppAlertPolicy

func (r *Run) AppApi_AppAlertPolicy(data *[]edgeproto.AppAlertPolicy, dataMap interface{}, dataOut interface{})

func (*Run) AppApi_AppAutoProvPolicy

func (r *Run) AppApi_AppAutoProvPolicy(data *[]edgeproto.AppAutoProvPolicy, dataMap interface{}, dataOut interface{})

func (*Run) AppApi_DeploymentCloudletRequest

func (r *Run) AppApi_DeploymentCloudletRequest(data *[]edgeproto.DeploymentCloudletRequest, dataMap interface{}, dataOut interface{})

func (*Run) AppInstApi

func (r *Run) AppInstApi(data *[]edgeproto.AppInst, dataMap interface{}, dataOut interface{})

func (*Run) AppInstApi_FedAppInstEvent

func (r *Run) AppInstApi_FedAppInstEvent(data *[]edgeproto.FedAppInstEvent, dataMap interface{}, dataOut interface{})

func (*Run) AppInstClientApi_AppInstClientKey

func (r *Run) AppInstClientApi_AppInstClientKey(data *[]edgeproto.AppInstClientKey, dataMap interface{}, dataOut interface{})

func (*Run) AppInstInfoApi

func (r *Run) AppInstInfoApi(data *[]edgeproto.AppInstInfo, dataMap interface{}, dataOut interface{})

func (*Run) AppInstLatencyApi

func (r *Run) AppInstLatencyApi(data *[]edgeproto.AppInstLatency, dataMap interface{}, dataOut interface{})

func (*Run) AppInstMetricsApi

func (r *Run) AppInstMetricsApi(data *[]edgeproto.AppInstMetrics, dataMap interface{}, dataOut interface{})

func (*Run) AppInstRefsApi

func (r *Run) AppInstRefsApi(data *[]edgeproto.AppInstRefs, dataMap interface{}, dataOut interface{})

func (*Run) AutoProvPolicyApi

func (r *Run) AutoProvPolicyApi(data *[]edgeproto.AutoProvPolicy, dataMap interface{}, dataOut interface{})

func (*Run) AutoProvPolicyApi_AutoProvPolicyCloudlet

func (r *Run) AutoProvPolicyApi_AutoProvPolicyCloudlet(data *[]edgeproto.AutoProvPolicyCloudlet, dataMap interface{}, dataOut interface{})

func (*Run) AutoScalePolicyApi

func (r *Run) AutoScalePolicyApi(data *[]edgeproto.AutoScalePolicy, dataMap interface{}, dataOut interface{})

func (*Run) CheckErrs

func (r *Run) CheckErrs(api, tag string)

func (*Run) CloudletAccessApi_AccessDataRequest

func (r *Run) CloudletAccessApi_AccessDataRequest(data *[]edgeproto.AccessDataRequest, dataMap interface{}, dataOut interface{})

func (*Run) CloudletAccessApi_GetCasRequest

func (r *Run) CloudletAccessApi_GetCasRequest(data *[]edgeproto.GetCasRequest, dataMap interface{}, dataOut interface{})

func (*Run) CloudletAccessApi_IssueCertRequest

func (r *Run) CloudletAccessApi_IssueCertRequest(data *[]edgeproto.IssueCertRequest, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi

func (r *Run) CloudletApi(data *[]edgeproto.Cloudlet, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_CloudletAllianceOrg

func (r *Run) CloudletApi_CloudletAllianceOrg(data *[]edgeproto.CloudletAllianceOrg, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_CloudletKey

func (r *Run) CloudletApi_CloudletKey(data *[]edgeproto.CloudletKey, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_CloudletProps

func (r *Run) CloudletApi_CloudletProps(data *[]edgeproto.CloudletProps, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_CloudletResMap

func (r *Run) CloudletApi_CloudletResMap(data *[]edgeproto.CloudletResMap, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_CloudletResourceQuotaProps

func (r *Run) CloudletApi_CloudletResourceQuotaProps(data *[]edgeproto.CloudletResourceQuotaProps, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_CloudletResourceUsage

func (r *Run) CloudletApi_CloudletResourceUsage(data *[]edgeproto.CloudletResourceUsage, dataMap interface{}, dataOut interface{})

func (*Run) CloudletApi_FlavorMatch

func (r *Run) CloudletApi_FlavorMatch(data *[]edgeproto.FlavorMatch, dataMap interface{}, dataOut interface{})

func (*Run) CloudletInfoApi

func (r *Run) CloudletInfoApi(data *[]edgeproto.CloudletInfo, dataMap interface{}, dataOut interface{})

func (*Run) CloudletMetricsApi

func (r *Run) CloudletMetricsApi(data *[]edgeproto.CloudletMetrics, dataMap interface{}, dataOut interface{})

func (*Run) CloudletNodeApi

func (r *Run) CloudletNodeApi(data *[]edgeproto.CloudletNode, dataMap interface{}, dataOut interface{})

func (*Run) CloudletPoolApi

func (r *Run) CloudletPoolApi(data *[]edgeproto.CloudletPool, dataMap interface{}, dataOut interface{})

func (*Run) CloudletPoolApi_CloudletPoolMember

func (r *Run) CloudletPoolApi_CloudletPoolMember(data *[]edgeproto.CloudletPoolMember, dataMap interface{}, dataOut interface{})

func (*Run) CloudletRefsApi

func (r *Run) CloudletRefsApi(data *[]edgeproto.CloudletRefs, dataMap interface{}, dataOut interface{})

func (*Run) ClusterInstApi

func (r *Run) ClusterInstApi(data *[]edgeproto.ClusterInst, dataMap interface{}, dataOut interface{})

func (*Run) ClusterInstApi_IdleReservableClusterInsts

func (r *Run) ClusterInstApi_IdleReservableClusterInsts(obj *edgeproto.IdleReservableClusterInsts, dataMap interface{}, dataOut interface{})

func (*Run) ClusterInstInfoApi

func (r *Run) ClusterInstInfoApi(data *[]edgeproto.ClusterInstInfo, dataMap interface{}, dataOut interface{})

func (*Run) ClusterRefsApi

func (r *Run) ClusterRefsApi(data *[]edgeproto.ClusterRefs, dataMap interface{}, dataOut interface{})

func (*Run) ControllerApi

func (r *Run) ControllerApi(data *[]edgeproto.Controller, dataMap interface{}, dataOut interface{})

func (*Run) DebugApi_DebugRequest

func (r *Run) DebugApi_DebugRequest(data *[]edgeproto.DebugRequest, dataMap interface{}, dataOut interface{})

func (*Run) DeviceApi

func (r *Run) DeviceApi(data *[]edgeproto.Device, dataMap interface{}, dataOut interface{})

func (*Run) DeviceApi_DeviceReport

func (r *Run) DeviceApi_DeviceReport(data *[]edgeproto.DeviceReport, dataMap interface{}, dataOut interface{})

func (*Run) ExecApi_ExecRequest

func (r *Run) ExecApi_ExecRequest(data *[]edgeproto.ExecRequest, dataMap interface{}, dataOut interface{})

func (*Run) FlavorApi

func (r *Run) FlavorApi(data *[]edgeproto.Flavor, dataMap interface{}, dataOut interface{})

func (*Run) GPUDriverApi

func (r *Run) GPUDriverApi(data *[]edgeproto.GPUDriver, dataMap interface{}, dataOut interface{})

func (*Run) GPUDriverApi_GPUDriverBuildMember

func (r *Run) GPUDriverApi_GPUDriverBuildMember(data *[]edgeproto.GPUDriverBuildMember, dataMap interface{}, dataOut interface{})

func (*Run) GPUDriverApi_GPUDriverKey

func (r *Run) GPUDriverApi_GPUDriverKey(data *[]edgeproto.GPUDriverKey, dataMap interface{}, dataOut interface{})

func (*Run) NetworkApi

func (r *Run) NetworkApi(data *[]edgeproto.Network, dataMap interface{}, dataOut interface{})

func (*Run) NodeApi

func (r *Run) NodeApi(data *[]edgeproto.Node, dataMap interface{}, dataOut interface{})

func (*Run) OperatorCodeApi

func (r *Run) OperatorCodeApi(data *[]edgeproto.OperatorCode, dataMap interface{}, dataOut interface{})

func (*Run) OrganizationApi

func (r *Run) OrganizationApi(data *[]edgeproto.Organization, dataMap interface{}, dataOut interface{})

func (*Run) PlatformFeaturesApi

func (r *Run) PlatformFeaturesApi(data *[]edgeproto.PlatformFeatures, dataMap interface{}, dataOut interface{})

func (*Run) RateLimitSettingsApi

func (r *Run) RateLimitSettingsApi(data *[]edgeproto.RateLimitSettings, dataMap interface{}, dataOut interface{})

func (*Run) RateLimitSettingsApi_FlowRateLimitSettings

func (r *Run) RateLimitSettingsApi_FlowRateLimitSettings(data *[]edgeproto.FlowRateLimitSettings, dataMap interface{}, dataOut interface{})

func (*Run) RateLimitSettingsApi_MaxReqsRateLimitSettings

func (r *Run) RateLimitSettingsApi_MaxReqsRateLimitSettings(data *[]edgeproto.MaxReqsRateLimitSettings, dataMap interface{}, dataOut interface{})

func (*Run) ResTagTableApi

func (r *Run) ResTagTableApi(data *[]edgeproto.ResTagTable, dataMap interface{}, dataOut interface{})

func (*Run) ResTagTableApi_ResTagTableKey

func (r *Run) ResTagTableApi_ResTagTableKey(data *[]edgeproto.ResTagTableKey, dataMap interface{}, dataOut interface{})

func (*Run) SettingsApi

func (r *Run) SettingsApi(obj *edgeproto.Settings, dataMap interface{}, dataOut interface{})

func (*Run) StreamObjApi_AppInstKey

func (r *Run) StreamObjApi_AppInstKey(data *[]edgeproto.AppInstKey, dataMap interface{}, dataOut interface{})

func (*Run) StreamObjApi_CloudletKey

func (r *Run) StreamObjApi_CloudletKey(data *[]edgeproto.CloudletKey, dataMap interface{}, dataOut interface{})

func (*Run) StreamObjApi_ClusterKey

func (r *Run) StreamObjApi_ClusterKey(data *[]edgeproto.ClusterKey, dataMap interface{}, dataOut interface{})

func (*Run) StreamObjApi_GPUDriverKey

func (r *Run) StreamObjApi_GPUDriverKey(data *[]edgeproto.GPUDriverKey, dataMap interface{}, dataOut interface{})

func (*Run) TrustPolicyApi

func (r *Run) TrustPolicyApi(data *[]edgeproto.TrustPolicy, dataMap interface{}, dataOut interface{})

func (*Run) TrustPolicyExceptionApi

func (r *Run) TrustPolicyExceptionApi(data *[]edgeproto.TrustPolicyException, dataMap interface{}, dataOut interface{})

func (*Run) VMPoolApi

func (r *Run) VMPoolApi(data *[]edgeproto.VMPool, dataMap interface{}, dataOut interface{})

func (*Run) VMPoolApi_VMPoolMember

func (r *Run) VMPoolApi_VMPoolMember(data *[]edgeproto.VMPoolMember, dataMap interface{}, dataOut interface{})

type RunAllDataApiCallback

type RunAllDataApiCallback func(objs string)

used to intersperse other creates/deletes/checks note the objs value is the previous one for create, but the next one for delete

type RunDebugDataApiCallback

type RunDebugDataApiCallback func(objs string)

used to intersperse other creates/deletes/checks note the objs value is the previous one for create, but the next one for delete

type RunDeviceDataApiCallback

type RunDeviceDataApiCallback func(objs string)

used to intersperse other creates/deletes/checks note the objs value is the previous one for create, but the next one for delete

type RunNodeDataApiCallback

type RunNodeDataApiCallback func(objs string)

used to intersperse other creates/deletes/checks note the objs value is the previous one for create, but the next one for delete

type RunOrganizationDataApiCallback

type RunOrganizationDataApiCallback func(objs string)

used to intersperse other creates/deletes/checks note the objs value is the previous one for create, but the next one for delete

type RunRateLimitSettingsDataApiCallback

type RunRateLimitSettingsDataApiCallback func(objs string)

used to intersperse other creates/deletes/checks note the objs value is the previous one for create, but the next one for delete

type ServerStream

type ServerStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func (*ServerStream) Context

func (s *ServerStream) Context() context.Context

type SettingsApiClient

type SettingsApiClient interface {
	UpdateSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)
	ResetSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error)
	ShowSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Settings, error)
}

type ShowAlert

type ShowAlert struct {
	Data map[string]edgeproto.Alert
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAlert) AssertFound

func (x *ShowAlert) AssertFound(t *testing.T, obj *edgeproto.Alert)

func (*ShowAlert) AssertNotFound

func (x *ShowAlert) AssertNotFound(t *testing.T, obj *edgeproto.Alert)

func (*ShowAlert) CheckFound

func (x *ShowAlert) CheckFound(obj *edgeproto.Alert) bool

func (*ShowAlert) Context

func (x *ShowAlert) Context() context.Context

func (*ShowAlert) Init

func (x *ShowAlert) Init()

func (*ShowAlert) ReadStream

func (x *ShowAlert) ReadStream(stream edgeproto.AlertApi_ShowAlertClient, err error)

func (*ShowAlert) Send

func (x *ShowAlert) Send(m *edgeproto.Alert) error

type ShowAlertPolicy

type ShowAlertPolicy struct {
	Data map[string]edgeproto.AlertPolicy
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAlertPolicy) AssertFound

func (x *ShowAlertPolicy) AssertFound(t *testing.T, obj *edgeproto.AlertPolicy)

func (*ShowAlertPolicy) AssertNotFound

func (x *ShowAlertPolicy) AssertNotFound(t *testing.T, obj *edgeproto.AlertPolicy)

func (*ShowAlertPolicy) CheckFound

func (x *ShowAlertPolicy) CheckFound(obj *edgeproto.AlertPolicy) bool

func (*ShowAlertPolicy) Context

func (x *ShowAlertPolicy) Context() context.Context

func (*ShowAlertPolicy) Init

func (x *ShowAlertPolicy) Init()

func (*ShowAlertPolicy) ReadStream

func (*ShowAlertPolicy) Send

type ShowApp

type ShowApp struct {
	Data map[string]edgeproto.App
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowApp) AssertFound

func (x *ShowApp) AssertFound(t *testing.T, obj *edgeproto.App)

func (*ShowApp) AssertNotFound

func (x *ShowApp) AssertNotFound(t *testing.T, obj *edgeproto.App)

func (*ShowApp) CheckFound

func (x *ShowApp) CheckFound(obj *edgeproto.App) bool

func (*ShowApp) Context

func (x *ShowApp) Context() context.Context

func (*ShowApp) Init

func (x *ShowApp) Init()

func (*ShowApp) ReadStream

func (x *ShowApp) ReadStream(stream edgeproto.AppApi_ShowAppClient, err error)

func (*ShowApp) Send

func (x *ShowApp) Send(m *edgeproto.App) error

type ShowAppInst

type ShowAppInst struct {
	Data map[string]edgeproto.AppInst
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAppInst) AssertFound

func (x *ShowAppInst) AssertFound(t *testing.T, obj *edgeproto.AppInst)

func (*ShowAppInst) AssertNotFound

func (x *ShowAppInst) AssertNotFound(t *testing.T, obj *edgeproto.AppInst)

func (*ShowAppInst) CheckFound

func (x *ShowAppInst) CheckFound(obj *edgeproto.AppInst) bool

func (*ShowAppInst) Context

func (x *ShowAppInst) Context() context.Context

func (*ShowAppInst) Init

func (x *ShowAppInst) Init()

func (*ShowAppInst) ReadStream

func (x *ShowAppInst) ReadStream(stream edgeproto.AppInstApi_ShowAppInstClient, err error)

func (*ShowAppInst) Send

func (x *ShowAppInst) Send(m *edgeproto.AppInst) error

type ShowAppInstInfo

type ShowAppInstInfo struct {
	Data map[string]edgeproto.AppInstInfo
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAppInstInfo) AssertFound

func (x *ShowAppInstInfo) AssertFound(t *testing.T, obj *edgeproto.AppInstInfo)

func (*ShowAppInstInfo) AssertNotFound

func (x *ShowAppInstInfo) AssertNotFound(t *testing.T, obj *edgeproto.AppInstInfo)

func (*ShowAppInstInfo) CheckFound

func (x *ShowAppInstInfo) CheckFound(obj *edgeproto.AppInstInfo) bool

func (*ShowAppInstInfo) Context

func (x *ShowAppInstInfo) Context() context.Context

func (*ShowAppInstInfo) Init

func (x *ShowAppInstInfo) Init()

func (*ShowAppInstInfo) ReadStream

func (*ShowAppInstInfo) Send

type ShowAppInstRefs

type ShowAppInstRefs struct {
	Data map[string]edgeproto.AppInstRefs
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAppInstRefs) AssertFound

func (x *ShowAppInstRefs) AssertFound(t *testing.T, obj *edgeproto.AppInstRefs)

func (*ShowAppInstRefs) AssertNotFound

func (x *ShowAppInstRefs) AssertNotFound(t *testing.T, obj *edgeproto.AppInstRefs)

func (*ShowAppInstRefs) CheckFound

func (x *ShowAppInstRefs) CheckFound(obj *edgeproto.AppInstRefs) bool

func (*ShowAppInstRefs) Context

func (x *ShowAppInstRefs) Context() context.Context

func (*ShowAppInstRefs) Init

func (x *ShowAppInstRefs) Init()

func (*ShowAppInstRefs) ReadStream

func (*ShowAppInstRefs) Send

type ShowAutoProvPolicy

type ShowAutoProvPolicy struct {
	Data map[string]edgeproto.AutoProvPolicy
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAutoProvPolicy) AssertFound

func (x *ShowAutoProvPolicy) AssertFound(t *testing.T, obj *edgeproto.AutoProvPolicy)

func (*ShowAutoProvPolicy) AssertNotFound

func (x *ShowAutoProvPolicy) AssertNotFound(t *testing.T, obj *edgeproto.AutoProvPolicy)

func (*ShowAutoProvPolicy) CheckFound

func (x *ShowAutoProvPolicy) CheckFound(obj *edgeproto.AutoProvPolicy) bool

func (*ShowAutoProvPolicy) Context

func (x *ShowAutoProvPolicy) Context() context.Context

func (*ShowAutoProvPolicy) Init

func (x *ShowAutoProvPolicy) Init()

func (*ShowAutoProvPolicy) ReadStream

func (*ShowAutoProvPolicy) Send

type ShowAutoScalePolicy

type ShowAutoScalePolicy struct {
	Data map[string]edgeproto.AutoScalePolicy
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowAutoScalePolicy) AssertFound

func (x *ShowAutoScalePolicy) AssertFound(t *testing.T, obj *edgeproto.AutoScalePolicy)

func (*ShowAutoScalePolicy) AssertNotFound

func (x *ShowAutoScalePolicy) AssertNotFound(t *testing.T, obj *edgeproto.AutoScalePolicy)

func (*ShowAutoScalePolicy) CheckFound

func (x *ShowAutoScalePolicy) CheckFound(obj *edgeproto.AutoScalePolicy) bool

func (*ShowAutoScalePolicy) Context

func (x *ShowAutoScalePolicy) Context() context.Context

func (*ShowAutoScalePolicy) Init

func (x *ShowAutoScalePolicy) Init()

func (*ShowAutoScalePolicy) ReadStream

func (*ShowAutoScalePolicy) Send

type ShowCloudlet

type ShowCloudlet struct {
	Data map[string]edgeproto.Cloudlet
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowCloudlet) AssertFound

func (x *ShowCloudlet) AssertFound(t *testing.T, obj *edgeproto.Cloudlet)

func (*ShowCloudlet) AssertNotFound

func (x *ShowCloudlet) AssertNotFound(t *testing.T, obj *edgeproto.Cloudlet)

func (*ShowCloudlet) CheckFound

func (x *ShowCloudlet) CheckFound(obj *edgeproto.Cloudlet) bool

func (*ShowCloudlet) Context

func (x *ShowCloudlet) Context() context.Context

func (*ShowCloudlet) Init

func (x *ShowCloudlet) Init()

func (*ShowCloudlet) ReadStream

func (x *ShowCloudlet) ReadStream(stream edgeproto.CloudletApi_ShowCloudletClient, err error)

func (*ShowCloudlet) Send

func (x *ShowCloudlet) Send(m *edgeproto.Cloudlet) error

type ShowCloudletInfo

type ShowCloudletInfo struct {
	Data map[string]edgeproto.CloudletInfo
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowCloudletInfo) AssertFound

func (x *ShowCloudletInfo) AssertFound(t *testing.T, obj *edgeproto.CloudletInfo)

func (*ShowCloudletInfo) AssertNotFound

func (x *ShowCloudletInfo) AssertNotFound(t *testing.T, obj *edgeproto.CloudletInfo)

func (*ShowCloudletInfo) CheckFound

func (x *ShowCloudletInfo) CheckFound(obj *edgeproto.CloudletInfo) bool

func (*ShowCloudletInfo) Context

func (x *ShowCloudletInfo) Context() context.Context

func (*ShowCloudletInfo) Init

func (x *ShowCloudletInfo) Init()

func (*ShowCloudletInfo) ReadStream

func (*ShowCloudletInfo) Send

type ShowCloudletNode

type ShowCloudletNode struct {
	Data map[string]edgeproto.CloudletNode
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowCloudletNode) AssertFound

func (x *ShowCloudletNode) AssertFound(t *testing.T, obj *edgeproto.CloudletNode)

func (*ShowCloudletNode) AssertNotFound

func (x *ShowCloudletNode) AssertNotFound(t *testing.T, obj *edgeproto.CloudletNode)

func (*ShowCloudletNode) CheckFound

func (x *ShowCloudletNode) CheckFound(obj *edgeproto.CloudletNode) bool

func (*ShowCloudletNode) Context

func (x *ShowCloudletNode) Context() context.Context

func (*ShowCloudletNode) Init

func (x *ShowCloudletNode) Init()

func (*ShowCloudletNode) ReadStream

func (*ShowCloudletNode) Send

type ShowCloudletPool

type ShowCloudletPool struct {
	Data map[string]edgeproto.CloudletPool
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowCloudletPool) AssertFound

func (x *ShowCloudletPool) AssertFound(t *testing.T, obj *edgeproto.CloudletPool)

func (*ShowCloudletPool) AssertNotFound

func (x *ShowCloudletPool) AssertNotFound(t *testing.T, obj *edgeproto.CloudletPool)

func (*ShowCloudletPool) CheckFound

func (x *ShowCloudletPool) CheckFound(obj *edgeproto.CloudletPool) bool

func (*ShowCloudletPool) Context

func (x *ShowCloudletPool) Context() context.Context

func (*ShowCloudletPool) Init

func (x *ShowCloudletPool) Init()

func (*ShowCloudletPool) ReadStream

func (*ShowCloudletPool) Send

type ShowCloudletRefs

type ShowCloudletRefs struct {
	Data map[string]edgeproto.CloudletRefs
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowCloudletRefs) AssertFound

func (x *ShowCloudletRefs) AssertFound(t *testing.T, obj *edgeproto.CloudletRefs)

func (*ShowCloudletRefs) AssertNotFound

func (x *ShowCloudletRefs) AssertNotFound(t *testing.T, obj *edgeproto.CloudletRefs)

func (*ShowCloudletRefs) CheckFound

func (x *ShowCloudletRefs) CheckFound(obj *edgeproto.CloudletRefs) bool

func (*ShowCloudletRefs) Context

func (x *ShowCloudletRefs) Context() context.Context

func (*ShowCloudletRefs) Init

func (x *ShowCloudletRefs) Init()

func (*ShowCloudletRefs) ReadStream

func (*ShowCloudletRefs) Send

type ShowCloudletsForAppDeployment

type ShowCloudletsForAppDeployment struct {
	Data map[string]edgeproto.CloudletKey
	grpc.ServerStream
	Ctx context.Context
}

minimal bits not currently generated for cloudletkey.proto and app.proto in support of CLI test for an rpc that streams cloudletkeys as its result

func (*ShowCloudletsForAppDeployment) Context

func (*ShowCloudletsForAppDeployment) Init

func (*ShowCloudletsForAppDeployment) ReadStream

func (*ShowCloudletsForAppDeployment) Send

type ShowClusterInst

type ShowClusterInst struct {
	Data map[string]edgeproto.ClusterInst
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowClusterInst) AssertFound

func (x *ShowClusterInst) AssertFound(t *testing.T, obj *edgeproto.ClusterInst)

func (*ShowClusterInst) AssertNotFound

func (x *ShowClusterInst) AssertNotFound(t *testing.T, obj *edgeproto.ClusterInst)

func (*ShowClusterInst) CheckFound

func (x *ShowClusterInst) CheckFound(obj *edgeproto.ClusterInst) bool

func (*ShowClusterInst) Context

func (x *ShowClusterInst) Context() context.Context

func (*ShowClusterInst) Init

func (x *ShowClusterInst) Init()

func (*ShowClusterInst) ReadStream

func (*ShowClusterInst) Send

type ShowClusterInstInfo

type ShowClusterInstInfo struct {
	Data map[string]edgeproto.ClusterInstInfo
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowClusterInstInfo) AssertFound

func (x *ShowClusterInstInfo) AssertFound(t *testing.T, obj *edgeproto.ClusterInstInfo)

func (*ShowClusterInstInfo) AssertNotFound

func (x *ShowClusterInstInfo) AssertNotFound(t *testing.T, obj *edgeproto.ClusterInstInfo)

func (*ShowClusterInstInfo) CheckFound

func (x *ShowClusterInstInfo) CheckFound(obj *edgeproto.ClusterInstInfo) bool

func (*ShowClusterInstInfo) Context

func (x *ShowClusterInstInfo) Context() context.Context

func (*ShowClusterInstInfo) Init

func (x *ShowClusterInstInfo) Init()

func (*ShowClusterInstInfo) ReadStream

func (*ShowClusterInstInfo) Send

type ShowClusterRefs

type ShowClusterRefs struct {
	Data map[string]edgeproto.ClusterRefs
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowClusterRefs) AssertFound

func (x *ShowClusterRefs) AssertFound(t *testing.T, obj *edgeproto.ClusterRefs)

func (*ShowClusterRefs) AssertNotFound

func (x *ShowClusterRefs) AssertNotFound(t *testing.T, obj *edgeproto.ClusterRefs)

func (*ShowClusterRefs) CheckFound

func (x *ShowClusterRefs) CheckFound(obj *edgeproto.ClusterRefs) bool

func (*ShowClusterRefs) Context

func (x *ShowClusterRefs) Context() context.Context

func (*ShowClusterRefs) Init

func (x *ShowClusterRefs) Init()

func (*ShowClusterRefs) ReadStream

func (*ShowClusterRefs) Send

type ShowDevice

type ShowDevice struct {
	Data map[string]edgeproto.Device
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowDevice) AssertFound

func (x *ShowDevice) AssertFound(t *testing.T, obj *edgeproto.Device)

func (*ShowDevice) AssertNotFound

func (x *ShowDevice) AssertNotFound(t *testing.T, obj *edgeproto.Device)

func (*ShowDevice) CheckFound

func (x *ShowDevice) CheckFound(obj *edgeproto.Device) bool

func (*ShowDevice) Context

func (x *ShowDevice) Context() context.Context

func (*ShowDevice) Init

func (x *ShowDevice) Init()

func (*ShowDevice) ReadStream

func (x *ShowDevice) ReadStream(stream edgeproto.DeviceApi_ShowDeviceClient, err error)

func (*ShowDevice) Send

func (x *ShowDevice) Send(m *edgeproto.Device) error

type ShowFlavor

type ShowFlavor struct {
	Data map[string]edgeproto.Flavor
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowFlavor) AssertFound

func (x *ShowFlavor) AssertFound(t *testing.T, obj *edgeproto.Flavor)

func (*ShowFlavor) AssertNotFound

func (x *ShowFlavor) AssertNotFound(t *testing.T, obj *edgeproto.Flavor)

func (*ShowFlavor) CheckFound

func (x *ShowFlavor) CheckFound(obj *edgeproto.Flavor) bool

func (*ShowFlavor) Context

func (x *ShowFlavor) Context() context.Context

func (*ShowFlavor) Init

func (x *ShowFlavor) Init()

func (*ShowFlavor) ReadStream

func (x *ShowFlavor) ReadStream(stream edgeproto.FlavorApi_ShowFlavorClient, err error)

func (*ShowFlavor) Send

func (x *ShowFlavor) Send(m *edgeproto.Flavor) error

type ShowFlavorsForCloudlet

type ShowFlavorsForCloudlet struct {
	Data map[string]edgeproto.FlavorKey
	grpc.ServerStream
	Ctx context.Context
}

minimal bits not currently generated for flavorkey.proto to stream flavorKey objs for ShowFlavorsForCloudlet cli

func (*ShowFlavorsForCloudlet) Context

func (x *ShowFlavorsForCloudlet) Context() context.Context

func (*ShowFlavorsForCloudlet) Init

func (x *ShowFlavorsForCloudlet) Init()

func (*ShowFlavorsForCloudlet) ReadStream

func (*ShowFlavorsForCloudlet) Send

type ShowGPUDriver

type ShowGPUDriver struct {
	Data map[string]edgeproto.GPUDriver
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowGPUDriver) AssertFound

func (x *ShowGPUDriver) AssertFound(t *testing.T, obj *edgeproto.GPUDriver)

func (*ShowGPUDriver) AssertNotFound

func (x *ShowGPUDriver) AssertNotFound(t *testing.T, obj *edgeproto.GPUDriver)

func (*ShowGPUDriver) CheckFound

func (x *ShowGPUDriver) CheckFound(obj *edgeproto.GPUDriver) bool

func (*ShowGPUDriver) Context

func (x *ShowGPUDriver) Context() context.Context

func (*ShowGPUDriver) Init

func (x *ShowGPUDriver) Init()

func (*ShowGPUDriver) ReadStream

func (*ShowGPUDriver) Send

func (x *ShowGPUDriver) Send(m *edgeproto.GPUDriver) error

type ShowNetwork

type ShowNetwork struct {
	Data map[string]edgeproto.Network
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowNetwork) AssertFound

func (x *ShowNetwork) AssertFound(t *testing.T, obj *edgeproto.Network)

func (*ShowNetwork) AssertNotFound

func (x *ShowNetwork) AssertNotFound(t *testing.T, obj *edgeproto.Network)

func (*ShowNetwork) CheckFound

func (x *ShowNetwork) CheckFound(obj *edgeproto.Network) bool

func (*ShowNetwork) Context

func (x *ShowNetwork) Context() context.Context

func (*ShowNetwork) Init

func (x *ShowNetwork) Init()

func (*ShowNetwork) ReadStream

func (x *ShowNetwork) ReadStream(stream edgeproto.NetworkApi_ShowNetworkClient, err error)

func (*ShowNetwork) Send

func (x *ShowNetwork) Send(m *edgeproto.Network) error

type ShowNode

type ShowNode struct {
	Data map[string]edgeproto.Node
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowNode) AssertFound

func (x *ShowNode) AssertFound(t *testing.T, obj *edgeproto.Node)

func (*ShowNode) AssertNotFound

func (x *ShowNode) AssertNotFound(t *testing.T, obj *edgeproto.Node)

func (*ShowNode) CheckFound

func (x *ShowNode) CheckFound(obj *edgeproto.Node) bool

func (*ShowNode) Context

func (x *ShowNode) Context() context.Context

func (*ShowNode) Init

func (x *ShowNode) Init()

func (*ShowNode) ReadStream

func (x *ShowNode) ReadStream(stream edgeproto.NodeApi_ShowNodeClient, err error)

func (*ShowNode) Send

func (x *ShowNode) Send(m *edgeproto.Node) error

type ShowOperatorCode

type ShowOperatorCode struct {
	Data map[string]edgeproto.OperatorCode
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowOperatorCode) AssertFound

func (x *ShowOperatorCode) AssertFound(t *testing.T, obj *edgeproto.OperatorCode)

func (*ShowOperatorCode) AssertNotFound

func (x *ShowOperatorCode) AssertNotFound(t *testing.T, obj *edgeproto.OperatorCode)

func (*ShowOperatorCode) CheckFound

func (x *ShowOperatorCode) CheckFound(obj *edgeproto.OperatorCode) bool

func (*ShowOperatorCode) Context

func (x *ShowOperatorCode) Context() context.Context

func (*ShowOperatorCode) Init

func (x *ShowOperatorCode) Init()

func (*ShowOperatorCode) ReadStream

func (*ShowOperatorCode) Send

type ShowResTagTable

type ShowResTagTable struct {
	Data map[string]edgeproto.ResTagTable
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowResTagTable) AssertFound

func (x *ShowResTagTable) AssertFound(t *testing.T, obj *edgeproto.ResTagTable)

func (*ShowResTagTable) AssertNotFound

func (x *ShowResTagTable) AssertNotFound(t *testing.T, obj *edgeproto.ResTagTable)

func (*ShowResTagTable) CheckFound

func (x *ShowResTagTable) CheckFound(obj *edgeproto.ResTagTable) bool

func (*ShowResTagTable) Context

func (x *ShowResTagTable) Context() context.Context

func (*ShowResTagTable) Init

func (x *ShowResTagTable) Init()

func (*ShowResTagTable) ReadStream

func (*ShowResTagTable) Send

type ShowTrustPolicy

type ShowTrustPolicy struct {
	Data map[string]edgeproto.TrustPolicy
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowTrustPolicy) AssertFound

func (x *ShowTrustPolicy) AssertFound(t *testing.T, obj *edgeproto.TrustPolicy)

func (*ShowTrustPolicy) AssertNotFound

func (x *ShowTrustPolicy) AssertNotFound(t *testing.T, obj *edgeproto.TrustPolicy)

func (*ShowTrustPolicy) CheckFound

func (x *ShowTrustPolicy) CheckFound(obj *edgeproto.TrustPolicy) bool

func (*ShowTrustPolicy) Context

func (x *ShowTrustPolicy) Context() context.Context

func (*ShowTrustPolicy) Init

func (x *ShowTrustPolicy) Init()

func (*ShowTrustPolicy) ReadStream

func (*ShowTrustPolicy) Send

type ShowTrustPolicyException

type ShowTrustPolicyException struct {
	Data map[string]edgeproto.TrustPolicyException
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowTrustPolicyException) AssertFound

func (*ShowTrustPolicyException) AssertNotFound

func (x *ShowTrustPolicyException) AssertNotFound(t *testing.T, obj *edgeproto.TrustPolicyException)

func (*ShowTrustPolicyException) CheckFound

func (*ShowTrustPolicyException) Context

func (*ShowTrustPolicyException) Init

func (x *ShowTrustPolicyException) Init()

func (*ShowTrustPolicyException) ReadStream

func (*ShowTrustPolicyException) Send

type ShowVMPool

type ShowVMPool struct {
	Data map[string]edgeproto.VMPool
	grpc.ServerStream
	Ctx context.Context
}

func (*ShowVMPool) AssertFound

func (x *ShowVMPool) AssertFound(t *testing.T, obj *edgeproto.VMPool)

func (*ShowVMPool) AssertNotFound

func (x *ShowVMPool) AssertNotFound(t *testing.T, obj *edgeproto.VMPool)

func (*ShowVMPool) CheckFound

func (x *ShowVMPool) CheckFound(obj *edgeproto.VMPool) bool

func (*ShowVMPool) Context

func (x *ShowVMPool) Context() context.Context

func (*ShowVMPool) Init

func (x *ShowVMPool) Init()

func (*ShowVMPool) ReadStream

func (x *ShowVMPool) ReadStream(stream edgeproto.VMPoolApi_ShowVMPoolClient, err error)

func (*ShowVMPool) Send

func (x *ShowVMPool) Send(m *edgeproto.VMPool) error

type StreamAppInst

type StreamAppInst struct {
	Key  edgeproto.AppInstKey
	Msgs []edgeproto.Result
}

type StreamCloudlet

type StreamCloudlet struct {
	Key  edgeproto.CloudletKey
	Msgs []edgeproto.Result
}

type StreamClusterInst

type StreamClusterInst struct {
	Key  edgeproto.ClusterKey
	Msgs []edgeproto.Result
}

type StreamObjApiClient

type StreamObjApiClient interface {
	StreamAppInst(ctx context.Context, in *edgeproto.AppInstKey) ([]edgeproto.Result, error)
	StreamClusterInst(ctx context.Context, in *edgeproto.ClusterKey) ([]edgeproto.Result, error)
	StreamCloudlet(ctx context.Context, in *edgeproto.CloudletKey) ([]edgeproto.Result, error)
	StreamGPUDriver(ctx context.Context, in *edgeproto.GPUDriverKey) ([]edgeproto.Result, error)
}

type TrustPolicyApiClient

type TrustPolicyApiClient interface {
	CreateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)
	DeleteTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)
	UpdateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.Result, error)
	ShowTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) ([]edgeproto.TrustPolicy, error)
}

type TrustPolicyCommonApi

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

Wrap the api with a common interface

func (*TrustPolicyCommonApi) CreateTrustPolicy

func (x *TrustPolicyCommonApi) CreateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) (*edgeproto.Result, error)

func (*TrustPolicyCommonApi) DeleteTrustPolicy

func (x *TrustPolicyCommonApi) DeleteTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) (*edgeproto.Result, error)

func (*TrustPolicyCommonApi) ShowTrustPolicy

func (x *TrustPolicyCommonApi) ShowTrustPolicy(ctx context.Context, filter *edgeproto.TrustPolicy, showData *ShowTrustPolicy) error

func (*TrustPolicyCommonApi) UpdateTrustPolicy

func (x *TrustPolicyCommonApi) UpdateTrustPolicy(ctx context.Context, in *edgeproto.TrustPolicy) (*edgeproto.Result, error)

type TrustPolicyExceptionApiClient

type TrustPolicyExceptionApiClient interface {
	CreateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)
	UpdateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)
	DeleteTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error)
	ShowTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) ([]edgeproto.TrustPolicyException, error)
}

type TrustPolicyExceptionCommonApi

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

Wrap the api with a common interface

func (*TrustPolicyExceptionCommonApi) CreateTrustPolicyException

func (*TrustPolicyExceptionCommonApi) DeleteTrustPolicyException

func (*TrustPolicyExceptionCommonApi) ShowTrustPolicyException

func (x *TrustPolicyExceptionCommonApi) ShowTrustPolicyException(ctx context.Context, filter *edgeproto.TrustPolicyException, showData *ShowTrustPolicyException) error

func (*TrustPolicyExceptionCommonApi) UpdateTrustPolicyException

type TrustPolicyExceptionStream

type TrustPolicyExceptionStream interface {
	Recv() (*edgeproto.TrustPolicyException, error)
}

type TrustPolicyExceptionTestOp

type TrustPolicyExceptionTestOp func(opts *TrustPolicyExceptionTestOptions)

func WithCreatedTrustPolicyExceptionTestData

func WithCreatedTrustPolicyExceptionTestData(createdData []edgeproto.TrustPolicyException) TrustPolicyExceptionTestOp

type TrustPolicyExceptionTestOptions

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

type TrustPolicyStream

type TrustPolicyStream interface {
	Recv() (*edgeproto.TrustPolicy, error)
}

type TrustPolicyTestOp

type TrustPolicyTestOp func(opts *TrustPolicyTestOptions)

func WithCreatedTrustPolicyTestData

func WithCreatedTrustPolicyTestData(createdData []edgeproto.TrustPolicy) TrustPolicyTestOp

type TrustPolicyTestOptions

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

type VMPoolApiClient

type VMPoolApiClient interface {
	CreateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)
	DeleteVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)
	UpdateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)
	ShowVMPool(ctx context.Context, in *edgeproto.VMPool) ([]edgeproto.VMPool, error)
	AddVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error)
	RemoveVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error)
}

type VMPoolCommonApi

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

Wrap the api with a common interface

func NewClientVMPoolApi

func NewClientVMPoolApi(api edgeproto.VMPoolApiClient) *VMPoolCommonApi

func NewInternalVMPoolApi

func NewInternalVMPoolApi(api edgeproto.VMPoolApiServer) *VMPoolCommonApi

func (*VMPoolCommonApi) CreateVMPool

func (x *VMPoolCommonApi) CreateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*VMPoolCommonApi) DeleteVMPool

func (x *VMPoolCommonApi) DeleteVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

func (*VMPoolCommonApi) ShowVMPool

func (x *VMPoolCommonApi) ShowVMPool(ctx context.Context, filter *edgeproto.VMPool, showData *ShowVMPool) error

func (*VMPoolCommonApi) UpdateVMPool

func (x *VMPoolCommonApi) UpdateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error)

type VMPoolStream

type VMPoolStream interface {
	Recv() (*edgeproto.VMPool, error)
}

type VMPoolTestOp

type VMPoolTestOp func(opts *VMPoolTestOptions)

func WithCreatedVMPoolTestData

func WithCreatedVMPoolTestData(createdData []edgeproto.VMPool) VMPoolTestOp

type VMPoolTestOptions

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

Directories

Path Synopsis
This file is not in the same package as notify to avoid including the testing packages in the notify package.
This file is not in the same package as notify to avoid including the testing packages in the notify package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL