Versions in this module Expand all Collapse all v1 v1.2.5 Sep 23, 2024 Changes in this version + const AllCloudlets + const ChangeInProgress + const CloudletCertRefreshTaskKey + const CloudletResourceRefreshTaskKey + const DataModelVersion0Prefix + const DataModelVersion2Prefix + const DefaultResourceAlertThreshold + const DummyInfoDelay + const GPUDriverBuildURLValidity + const GenResourceAlerts + const LongTimeout + const NoGenResourceAlerts + const NotifyChangeMaxLen + const PlatformInitTimeout + const RootLBSharedPortBegin + const ShortTimeout + const ShowControllers + const ToggleFlavorMatchVerbose + var ActionInProgressMsg = "action is already in progress" + var AppUsageInfluxQueryTemplate = `SELECT %s from "%s" WHERE ` + getInfluxQueryWhere(cloudcommon.AppInstEventSelectors) + ` AND time >= '%s' AND time < '%s' order by time desc` + var ClusterUsageInfluxQueryTemplate = `SELECT %s from "%s" WHERE ` + getInfluxQueryWhere(cloudcommon.ClusterInstEventSelectors) + ` %sAND time >= '%s' AND time < '%s' order by time desc` + var ControllerCreatedAlerts = "ControllerCreatedAlerts" + var ControllerId = "" + var CreateAppInstTransitions = map[edgeproto.TrackedState]struct + var CreateCheckpointInfluxQueryTemplate = `SELECT %s from "%s" WHERE time >= '%s' AND time < '%s' order by time desc` + var CreateCloudletTransitions = map[dme.CloudletState]struct{} + var CreateClusterInstTransitions = map[edgeproto.TrackedState]struct + var DeleteAppInstTransitions = map[edgeproto.TrackedState]struct + var DeleteClusterInstTransitions = map[edgeproto.TrackedState]struct + var ErrCtrlAlreadyInProgress = errors.New("Change already in progress") + var ErrCtrlUpgradeRequired = errors.New("data mode upgrade required") + var GetCheckpointInfluxQueryTemplate = `SELECT %s from "%s" WHERE "org"='%s' AND time <= '%s' order by time desc` + var InfluxDBName = cloudcommon.DeveloperMetricsDbName + var InfluxMaximumTimestamp = time.Parse(time.RFC3339, "2262-04-11T23:47:15Z") + var InfluxMinimumTimestamp = time.Parse(time.RFC3339, "1677-09-21T00:13:44Z") + var NextCheckpoint = InfluxMaximumTimestamp + var ObjBusyDeletionMsg = "busy, cannot be deleted" + var PrevCheckpoint = InfluxMinimumTimestamp + var RequireAppInstPortConsistency = false + var StreamMsgInfoReadTimeout = 3 * time.Second + var StreamMsgKeyID = "id" + var StreamMsgKeyModRev = "modRev" + var StreamMsgReadTimeout = 30 * time.Minute + var StreamMsgTypeEOM = "end-of-stream-message" + var StreamMsgTypeError = "error" + var StreamMsgTypeInfoEOM = "end-of-info-stream-message" + var StreamMsgTypeMessage = "message" + var StreamMsgTypeSOM = "start-of-stream-message" + var UpdateAppInstTransitions = map[edgeproto.TrackedState]struct + var UpdateCloudletTransitions = map[dme.CloudletState]struct + var UpdateClusterInstTransitions = map[edgeproto.TrackedState]struct + var UpdateVMPoolTransitions = map[edgeproto.TrackedState]struct + var VersionHash_UpgradeFuncs = []VersionUpgrade + func AddStaticFqdn(ctx context.Context, objStore objstore.KVStore, allApis *AllApis, ...) error + func AppInstKeyName(ctx context.Context, objStore objstore.KVStore, allApis *AllApis, ...) error + func ControllerConnect(ctx context.Context, addr string) (*grpc.ClientConn, error) + func CreateClusterUsageRecord(ctx context.Context, cluster *edgeproto.ClusterInst, endTime time.Time) error + func GetAppInstID(ctx context.Context, appInst *edgeproto.AppInst, app *edgeproto.App, ...) (string, error) + func GetPlatformVMsResources(ctx context.Context, cloudletInfo *edgeproto.CloudletInfo) ([]edgeproto.VMResource, error) + func GetRootDir() string + func GetRunTimeStats(usageType string, checkpoint, key interface{}, logs []client.Result, ...) error + func InitNotify(metricsInflux *influxq.InfluxQ, edgeEventsInflux *influxq.InfluxQ, ...) + func InstanceKeysRegionScopedName(ctx context.Context, objStore objstore.KVStore, allApis *AllApis, ...) error + func RecordCloudletEvent(ctx context.Context, cloudletKey *edgeproto.CloudletKey, ...) + func Run() + func RunSingleUpgrade(ctx context.Context, objStore objstore.KVStore, allApis *AllApis, ...) error + func StartLocalRedisServer(opts ...process.StartOp) (*process.RedisCache, error) + func TestUpgradeExample(ctx context.Context, objStore objstore.KVStore) error + func UpgradeCrmOnEdge(ctx context.Context, objStore objstore.KVStore, allApis *AllApis, ...) error + func ValidateContainerName(deployment, name string) error + type AlertApi struct + func NewAlertApi(sync *regiondata.Sync, all *AllApis) *AlertApi + func (s *AlertApi) CleanupAppInstAlerts(ctx context.Context, key *edgeproto.AppInstKey) + func (s *AlertApi) CleanupCloudletAlerts(ctx context.Context, key *edgeproto.CloudletKey) + func (s *AlertApi) CleanupClusterInstAlerts(ctx context.Context, key *edgeproto.ClusterKey, ...) + func (s *AlertApi) Delete(ctx context.Context, in *edgeproto.Alert, rev int64) + func (s *AlertApi) Flush(ctx context.Context, notifyId int64) + func (s *AlertApi) Prune(ctx context.Context, keys map[edgeproto.AlertKey]struct{}) + func (s *AlertApi) ShowAlert(in *edgeproto.Alert, cb edgeproto.AlertApi_ShowAlertServer) error + func (s *AlertApi) StoreDelete(ctx context.Context, in *edgeproto.Alert) + func (s *AlertApi) StoreUpdate(ctx context.Context, old, new *edgeproto.Alert) + func (s *AlertApi) Update(ctx context.Context, in *edgeproto.Alert, rev int64) + type AlertPolicyApi struct + func NewAlertPolicyApi(sync *regiondata.Sync, all *AllApis) *AlertPolicyApi + func (a *AlertPolicyApi) CreateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error) + func (a *AlertPolicyApi) DeleteAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (res *edgeproto.Result, reterr error) + func (a *AlertPolicyApi) ShowAlertPolicy(in *edgeproto.AlertPolicy, cb edgeproto.AlertPolicyApi_ShowAlertPolicyServer) error + func (a *AlertPolicyApi) UpdateAlertPolicy(ctx context.Context, in *edgeproto.AlertPolicy) (*edgeproto.Result, error) + type AllApis struct + func NewAllApis(sync *regiondata.Sync) *AllApis + func (s *AllApis) GetAlertPolicyApi() edgeproto.AlertPolicyApiServer + func (s *AllApis) GetAppApi() edgeproto.AppApiServer + func (s *AllApis) GetAppInstApi() edgeproto.AppInstApiServer + func (s *AllApis) GetAutoProvPolicyApi() edgeproto.AutoProvPolicyApiServer + func (s *AllApis) GetAutoScalePolicyApi() edgeproto.AutoScalePolicyApiServer + func (s *AllApis) GetCloudletApi() edgeproto.CloudletApiServer + func (s *AllApis) GetCloudletNodeApi() edgeproto.CloudletNodeApiServer + func (s *AllApis) GetCloudletPoolApi() edgeproto.CloudletPoolApiServer + func (s *AllApis) GetClusterInstApi() edgeproto.ClusterInstApiServer + func (s *AllApis) GetFlavorApi() edgeproto.FlavorApiServer + func (s *AllApis) GetGPUDriverApi() edgeproto.GPUDriverApiServer + func (s *AllApis) GetNetworkApi() edgeproto.NetworkApiServer + func (s *AllApis) GetOperatorCodeApi() edgeproto.OperatorCodeApiServer + func (s *AllApis) GetResTagTableApi() edgeproto.ResTagTableApiServer + func (s *AllApis) GetTrustPolicyApi() edgeproto.TrustPolicyApiServer + func (s *AllApis) GetTrustPolicyExceptionApi() edgeproto.TrustPolicyExceptionApiServer + func (s *AllApis) GetVMPoolApi() edgeproto.VMPoolApiServer + func (s *AllApis) Start(ctx context.Context) + func (s *AllApis) Stop() + type AppApi struct + func NewAppApi(sync *regiondata.Sync, all *AllApis) *AppApi + func (s *AppApi) AddAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error) + func (s *AppApi) AddAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error) + func (s *AppApi) AndroidPackageConflicts(a *edgeproto.App) bool + func (s *AppApi) AutoDeleteApps(ctx context.Context, key *edgeproto.FlavorKey) + func (s *AppApi) AutoDeleteAppsForOrganization(ctx context.Context, org string) + func (s *AppApi) CheckAppCompatibleWithTrustPolicy(ctx context.Context, ckey *edgeproto.CloudletKey, app *edgeproto.App, ...) error + func (s *AppApi) CreateApp(ctx context.Context, in *edgeproto.App) (res *edgeproto.Result, reterr error) + func (s *AppApi) CreateAppCheckpoint(ctx context.Context, timestamp time.Time) error + func (s *AppApi) CreateAppUsageRecord(ctx context.Context, appInst *edgeproto.AppInst, endTime time.Time) error + func (s *AppApi) DeleteApp(ctx context.Context, in *edgeproto.App) (res *edgeproto.Result, reterr error) + func (s *AppApi) Get(key *edgeproto.AppKey, buf *edgeproto.App) bool + func (s *AppApi) GetAllApps(apps map[edgeproto.AppKey]*edgeproto.App) + func (s *AppApi) HasApp(key *edgeproto.AppKey) bool + func (s *AppApi) RemoveAppAlertPolicy(ctx context.Context, in *edgeproto.AppAlertPolicy) (*edgeproto.Result, error) + func (s *AppApi) RemoveAppAutoProvPolicy(ctx context.Context, in *edgeproto.AppAutoProvPolicy) (*edgeproto.Result, error) + func (s *AppApi) ShowApp(in *edgeproto.App, cb edgeproto.AppApi_ShowAppServer) error + func (s *AppApi) ShowCloudletsForAppDeployment(in *edgeproto.DeploymentCloudletRequest, ...) error + func (s *AppApi) UpdateApp(ctx context.Context, in *edgeproto.App) (*edgeproto.Result, error) + func (s *AppApi) UsesAlertPolicy(key *edgeproto.AlertPolicyKey) *edgeproto.AppKey + func (s *AppApi) UsesAutoProvPolicy(key *edgeproto.PolicyKey) *edgeproto.AppKey + func (s *AppApi) UsesFlavor(key *edgeproto.FlavorKey) *edgeproto.AppKey + type AppCheckpoint struct + Keys []*edgeproto.AppInstKey + Org string + Status []string + Timestamp time.Time + func GetAppCheckpoint(ctx context.Context, org string, timestamp time.Time) (*AppCheckpoint, error) + type AppInstApi struct + func NewAppInstApi(sync *regiondata.Sync, all *AllApis) *AppInstApi + func (s *AppInstApi) AutoDelete(ctx context.Context, appinsts []*edgeproto.AppInst) error + func (s *AppInstApi) AutoDeleteAppInsts(ctx context.Context, dynInsts map[edgeproto.AppInstKey]struct{}, ...) error + func (s *AppInstApi) CheckCloudletAppinstsCompatibleWithTrustPolicy(ctx context.Context, ckey *edgeproto.CloudletKey, ...) error + func (s *AppInstApi) CreateAppInst(in *edgeproto.AppInst, cb edgeproto.AppInstApi_CreateAppInstServer) error + func (s *AppInstApi) DeleteAppInst(in *edgeproto.AppInst, cb edgeproto.AppInstApi_DeleteAppInstServer) error + func (s *AppInstApi) DeleteFromInfo(ctx context.Context, in *edgeproto.AppInstInfo) + func (s *AppInstApi) Get(key *edgeproto.AppInstKey, val *edgeproto.AppInst) bool + func (s *AppInstApi) HandleFedAppInstEvent(ctx context.Context, in *edgeproto.FedAppInstEvent) (*edgeproto.Result, error) + func (s *AppInstApi) HasKey(key *edgeproto.AppInstKey) bool + func (s *AppInstApi) HealthCheckUpdate(ctx context.Context, key *edgeproto.AppInstKey, state dme.HealthCheck) + func (s *AppInstApi) RecordAppInstEvent(ctx context.Context, appInst *edgeproto.AppInst, ...) + func (s *AppInstApi) RefreshAppInst(in *edgeproto.AppInst, cb edgeproto.AppInstApi_RefreshAppInstServer) error + func (s *AppInstApi) ReplaceErrorState(ctx context.Context, in *edgeproto.AppInst, newState edgeproto.TrackedState) + func (s *AppInstApi) ShowAppInst(in *edgeproto.AppInst, cb edgeproto.AppInstApi_ShowAppInstServer) error + func (s *AppInstApi) UpdateAppInst(in *edgeproto.AppInst, cb edgeproto.AppInstApi_UpdateAppInstServer) error + func (s *AppInstApi) UpdateFromInfo(ctx context.Context, in *edgeproto.AppInstInfo) + func (s *AppInstApi) UsesClusterInst(callerOrg string, in *edgeproto.ClusterKey) bool + func (s *AppInstApi) UsesFlavor(key *edgeproto.FlavorKey) *edgeproto.AppInstKey + type AppInstClientApi struct + func NewAppInstClientApi(all *AllApis) *AppInstClientApi + func (s *AppInstClientApi) AddAppInstClient(ctx context.Context, client *edgeproto.AppInstClient) + func (s *AppInstClientApi) ClearRecvChan(ctx context.Context, in *edgeproto.AppInstClientKey, ...) int + func (s *AppInstClientApi) Flush(ctx context.Context, notifyId int64) + func (s *AppInstClientApi) Prune(ctx context.Context, keys map[edgeproto.AppInstClientKey]struct{}) + func (s *AppInstClientApi) RecvAppInstClient(ctx context.Context, client *edgeproto.AppInstClient) + func (s *AppInstClientApi) SetRecvChan(ctx context.Context, in *edgeproto.AppInstClientKey, ...) *sync.WaitGroup + func (s *AppInstClientApi) ShowAppInstClient(in *edgeproto.AppInstClientKey, ...) error + func (s *AppInstClientApi) StreamAppInstClientsLocal(in *edgeproto.AppInstClientKey, ...) error + type AppInstClientKeyApi struct + func NewAppInstClientKeyApi(sync *regiondata.Sync, all *AllApis) *AppInstClientKeyApi + func (s *AppInstClientKeyApi) Delete(ctx context.Context, in *edgeproto.AppInstClientKey, rev int64) + func (s *AppInstClientKeyApi) Flush(ctx context.Context, notifyId int64) + func (s *AppInstClientKeyApi) HasKey(key *edgeproto.AppInstClientKey) bool + func (s *AppInstClientKeyApi) Prune(ctx context.Context, keys map[edgeproto.AppInstKey]struct{}) + func (s *AppInstClientKeyApi) Update(ctx context.Context, in *edgeproto.AppInstClientKey, rev int64) + type AppInstIDSanitizer struct + func NewAppInstIDSanitizer(ctx context.Context, appInstApi *AppInstApi, cloudlet *edgeproto.Cloudlet) *AppInstIDSanitizer + func (s *AppInstIDSanitizer) NameSanitize(name string) (string, error) + type AppInstInfoApi struct + func NewAppInstInfoApi(sync *regiondata.Sync, all *AllApis) *AppInstInfoApi + func (s *AppInstInfoApi) Delete(ctx context.Context, in *edgeproto.AppInstInfo, rev int64) + func (s *AppInstInfoApi) Flush(ctx context.Context, notifyId int64) + func (s *AppInstInfoApi) Prune(ctx context.Context, keys map[edgeproto.AppInstKey]struct{}) + func (s *AppInstInfoApi) Update(ctx context.Context, in *edgeproto.AppInstInfo, rev int64) + type AppInstLatencyApi struct + func NewAppInstLatencyApi(sync *regiondata.Sync, all *AllApis) *AppInstLatencyApi + func (s *AppInstLatencyApi) RequestAppInstLatency(ctx context.Context, in *edgeproto.AppInstLatency) (*edgeproto.Result, error) + type AppInstRefKeyV1 struct + AppKey edgeproto.AppKey + ClusterKey ClusterInstRefKeyV1 + type AppInstRefsApi struct + func NewAppInstRefsApi(sync *regiondata.Sync, all *AllApis) *AppInstRefsApi + func (s *AppInstRefsApi) ShowAppInstRefs(in *edgeproto.AppInstRefs, cb edgeproto.AppInstRefsApi_ShowAppInstRefsServer) error + type AutoClusterType int + const ChooseAutoCluster + const MultiTenantAutoCluster + const NoAutoCluster + const ReservableAutoCluster + type AutoProvInfoApi struct + func NewAutoProvInfoApi(sync *regiondata.Sync, all *AllApis) *AutoProvInfoApi + func (s *AutoProvInfoApi) Delete(ctx context.Context, in *edgeproto.AutoProvInfo, rev int64) + func (s *AutoProvInfoApi) Flush(ctx context.Context, notifyId int64) + func (s *AutoProvInfoApi) Prune(ctx context.Context, keys map[edgeproto.CloudletKey]struct{}) + func (s *AutoProvInfoApi) Update(ctx context.Context, in *edgeproto.AutoProvInfo, rev int64) + type AutoProvPolicyApi struct + func NewAutoProvPolicyApi(sync *regiondata.Sync, all *AllApis) *AutoProvPolicyApi + func (s *AutoProvPolicyApi) AddAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error) + func (s *AutoProvPolicyApi) CreateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error) + func (s *AutoProvPolicyApi) DeleteAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (res *edgeproto.Result, reterr error) + func (s *AutoProvPolicyApi) RecvAutoProvCounts(ctx context.Context, msg *edgeproto.AutoProvCounts) + func (s *AutoProvPolicyApi) RemoveAutoProvPolicyCloudlet(ctx context.Context, in *edgeproto.AutoProvPolicyCloudlet) (*edgeproto.Result, error) + func (s *AutoProvPolicyApi) STMFind(stm concurrency.STM, name, dev string, policy *edgeproto.AutoProvPolicy) error + func (s *AutoProvPolicyApi) SetInfluxQ(influxQ *influxq.InfluxQ) + func (s *AutoProvPolicyApi) ShowAutoProvPolicy(in *edgeproto.AutoProvPolicy, ...) error + func (s *AutoProvPolicyApi) UpdateAutoProvPolicy(ctx context.Context, in *edgeproto.AutoProvPolicy) (*edgeproto.Result, error) + func (s *AutoProvPolicyApi) UsesCloudlet(key *edgeproto.CloudletKey) []edgeproto.PolicyKey + type AutoScalePolicyApi struct + func NewAutoScalePolicyApi(sync *regiondata.Sync, all *AllApis) *AutoScalePolicyApi + func (s *AutoScalePolicyApi) CreateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error) + func (s *AutoScalePolicyApi) DeleteAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (res *edgeproto.Result, reterr error) + func (s *AutoScalePolicyApi) ShowAutoScalePolicy(in *edgeproto.AutoScalePolicy, ...) error + func (s *AutoScalePolicyApi) UpdateAutoScalePolicy(ctx context.Context, in *edgeproto.AutoScalePolicy) (*edgeproto.Result, error) + type CallContext struct + AutoCluster bool + CRMUndo bool + Override edgeproto.CRMOverride + SkipCloudletReadyCheck bool + Undo bool + func DefCallContext() *CallContext + func (c *CallContext) Clone() *CallContext + func (c *CallContext) SetOverride(o *edgeproto.CRMOverride) + func (c *CallContext) WithAutoCluster() *CallContext + func (c *CallContext) WithCRMUndo() *CallContext + func (c *CallContext) WithUndo() *CallContext + type CbWrapper struct + func (s *CbWrapper) Send(res *edgeproto.Result) error + type Checkpointer struct + func NewCheckpointer(events *influxq.InfluxQ, clusterInstApi *ClusterInstApi) *Checkpointer + func (s *Checkpointer) GetInterval() time.Duration + func (s *Checkpointer) Run(ctx context.Context) + func (s *Checkpointer) Start() + func (s *Checkpointer) StartSpan() opentracing.Span + func (s *Checkpointer) Stop() + type CleanupStreamAction bool + var CleanupStream CleanupStreamAction = true + var NoCleanupStream CleanupStreamAction = false + type CloudletApi struct + func NewCloudletApi(sync *regiondata.Sync, all *AllApis) *CloudletApi + func (s *CloudletApi) AddCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error) + func (s *CloudletApi) AddCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error) + func (s *CloudletApi) ChangeCloudletDNS(key *edgeproto.CloudletKey, inCb edgeproto.CloudletApi_ChangeCloudletDNSServer) (reterr error) + func (s *CloudletApi) CreateCloudlet(in *edgeproto.Cloudlet, cb edgeproto.CloudletApi_CreateCloudletServer) error + func (s *CloudletApi) DeleteCloudlet(in *edgeproto.Cloudlet, cb edgeproto.CloudletApi_DeleteCloudletServer) error + func (s *CloudletApi) FindFlavorMatch(ctx context.Context, in *edgeproto.FlavorMatch) (*edgeproto.FlavorMatch, error) + func (s *CloudletApi) GenerateAccessKey(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.Result, error) + func (s *CloudletApi) Get(key *edgeproto.CloudletKey, buf *edgeproto.Cloudlet) bool + func (s *CloudletApi) GetAccessData(ctx context.Context, req *edgeproto.AccessDataRequest) (*edgeproto.AccessDataReply, error) + func (s *CloudletApi) GetCas(ctx context.Context, req *edgeproto.GetCasRequest) (*edgeproto.GetCasReply, error) + func (s *CloudletApi) GetCloudletForVMPool(vmPoolKey *edgeproto.VMPoolKey) *edgeproto.Cloudlet + func (s *CloudletApi) GetCloudletGPUDriverLicenseConfig(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.Result, error) + func (s *CloudletApi) GetCloudletManifest(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.CloudletManifest, error) + func (s *CloudletApi) GetCloudletProps(ctx context.Context, in *edgeproto.CloudletProps) (*edgeproto.CloudletProps, error) + func (s *CloudletApi) GetCloudletResourceInfo(ctx context.Context, stm concurrency.STM, cloudlet *edgeproto.Cloudlet, ...) (map[string]edgeproto.InfraResource, error) + func (s *CloudletApi) GetCloudletResourceQuotaProps(ctx context.Context, in *edgeproto.CloudletResourceQuotaProps) (*edgeproto.CloudletResourceQuotaProps, error) + func (s *CloudletApi) GetCloudletResourceUsage(ctx context.Context, usage *edgeproto.CloudletResourceUsage) (*edgeproto.CloudletResourceUsage, error) + func (s *CloudletApi) GetOrganizationsOnCloudlet(in *edgeproto.CloudletKey, ...) error + func (s *CloudletApi) GetResourceUsage(ctx context.Context, stm concurrency.STM, cloudlet *edgeproto.Cloudlet, ...) ([]edgeproto.InfraResource, error) + func (s *CloudletApi) HasKey(key *edgeproto.CloudletKey) bool + func (s *CloudletApi) InitVaultClient(ctx context.Context) error + func (s *CloudletApi) IssueCert(ctx context.Context, req *edgeproto.IssueCertRequest) (*edgeproto.IssueCertReply, error) + func (s *CloudletApi) RemoveCloudletAllianceOrg(ctx context.Context, in *edgeproto.CloudletAllianceOrg) (*edgeproto.Result, error) + func (s *CloudletApi) RemoveCloudletResMapping(ctx context.Context, in *edgeproto.CloudletResMap) (*edgeproto.Result, error) + func (s *CloudletApi) ReplaceErrorState(ctx context.Context, in *edgeproto.Cloudlet, newState edgeproto.TrackedState) + func (s *CloudletApi) RevokeAccessKey(ctx context.Context, key *edgeproto.CloudletKey) (*edgeproto.Result, error) + func (s *CloudletApi) SetState(ctx context.Context, in *edgeproto.Cloudlet, newState edgeproto.TrackedState) + func (s *CloudletApi) ShowCloudlet(in *edgeproto.Cloudlet, cb edgeproto.CloudletApi_ShowCloudletServer) error + func (s *CloudletApi) ShowFlavorsForCloudlet(in *edgeproto.CloudletKey, ...) error + func (s *CloudletApi) UpdateAppInstLocations(ctx context.Context, in *edgeproto.Cloudlet) + func (s *CloudletApi) UpdateCloudlet(in *edgeproto.Cloudlet, inCb edgeproto.CloudletApi_UpdateCloudletServer) (reterr error) + func (s *CloudletApi) UpdateCloudletsUsingTrustPolicy(ctx context.Context, trustPolicy *edgeproto.TrustPolicy, ...) error + func (s *CloudletApi) UpgradeAccessKey(stream edgeproto.CloudletAccessKeyApi_UpgradeAccessKeyServer) error + func (s *CloudletApi) UsesFlavor(key *edgeproto.FlavorKey) *edgeproto.CloudletKey + func (s *CloudletApi) UsesGPUDriver(driverKey *edgeproto.GPUDriverKey) (bool, []string) + func (s *CloudletApi) UsesPlatformFeatures(pfKey *edgeproto.PlatformFeaturesKey) (bool, []string) + func (s *CloudletApi) UsesResTagTable(key *edgeproto.ResTagTableKey) *edgeproto.CloudletKey + func (s *CloudletApi) UsesTrustPolicy(key *edgeproto.PolicyKey, stateMatch edgeproto.TrackedState) *edgeproto.CloudletKey + func (s *CloudletApi) ValidateCloudletsUsingTrustPolicy(ctx context.Context, trustPolicy *edgeproto.TrustPolicy) error + func (s *CloudletApi) VerifyTrustPoliciesForAppInsts(ctx context.Context, app *edgeproto.App, ...) error + func (s *CloudletApi) WaitForTrustPolicyState(ctx context.Context, key *edgeproto.CloudletKey, ...) error + type CloudletCertRefreshTaskable struct + func NewCloudletCertRefreshTaskable(all *AllApis) *CloudletCertRefreshTaskable + func (s *CloudletCertRefreshTaskable) GetInterval() time.Duration + func (s *CloudletCertRefreshTaskable) StartSpan() opentracing.Span + type CloudletInfoApi struct + func NewCloudletInfoApi(sync *regiondata.Sync, all *AllApis) *CloudletInfoApi + func (s *CloudletInfoApi) ClearCloudletAndAppInstDownAlerts(ctx context.Context, in *edgeproto.CloudletInfo) + func (s *CloudletInfoApi) Del(ctx context.Context, key *edgeproto.CloudletKey, wait func(int64)) + func (s *CloudletInfoApi) Delete(ctx context.Context, in *edgeproto.CloudletInfo, rev int64) + func (s *CloudletInfoApi) EvictCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error) + func (s *CloudletInfoApi) FireCloudletAndAppInstDownAlerts(ctx context.Context, in *edgeproto.CloudletInfo) + func (s *CloudletInfoApi) Flush(ctx context.Context, notifyId int64) + func (s *CloudletInfoApi) InjectCloudletInfo(ctx context.Context, in *edgeproto.CloudletInfo) (*edgeproto.Result, error) + func (s *CloudletInfoApi) Prune(ctx context.Context, keys map[edgeproto.CloudletKey]struct{}) + func (s *CloudletInfoApi) ShowCloudletInfo(in *edgeproto.CloudletInfo, ...) error + func (s *CloudletInfoApi) Update(ctx context.Context, in *edgeproto.CloudletInfo, rev int64) + func (s *CloudletInfoApi) UpdateFields(ctx context.Context, in *edgeproto.CloudletInfo, rev int64) + func (s *CloudletInfoApi) UpdateRPC(ctx context.Context, in *edgeproto.CloudletInfo) + type CloudletNodeApi struct + func NewCloudletNodeApi(sync *regiondata.Sync, all *AllApis) *CloudletNodeApi + func (s *CloudletNodeApi) CreateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error) + func (s *CloudletNodeApi) CreateCloudletNodeReq(ctx context.Context, node *edgeproto.CloudletNode) (string, error) + func (s *CloudletNodeApi) DeleteCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error) + func (s *CloudletNodeApi) DeleteCloudletNodeReq(ctx context.Context, key *edgeproto.CloudletNodeKey) error + func (s *CloudletNodeApi) ShowCloudletNode(in *edgeproto.CloudletNode, ...) error + func (s *CloudletNodeApi) UpdateCloudletNode(ctx context.Context, in *edgeproto.CloudletNode) (*edgeproto.Result, error) + type CloudletPoolApi struct + func NewCloudletPoolApi(sync *regiondata.Sync, all *AllApis) *CloudletPoolApi + func (s *CloudletPoolApi) AddCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error) + func (s *CloudletPoolApi) CreateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error) + func (s *CloudletPoolApi) DeleteCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (res *edgeproto.Result, reterr error) + func (s *CloudletPoolApi) GetCloudletPoolKeysForCloudletKey(in *edgeproto.CloudletKey) []edgeproto.CloudletPoolKey + func (s *CloudletPoolApi) HasCloudletPool(key *edgeproto.CloudletPoolKey) bool + func (s *CloudletPoolApi) RemoveCloudletPoolMember(ctx context.Context, in *edgeproto.CloudletPoolMember) (*edgeproto.Result, error) + func (s *CloudletPoolApi) ShowCloudletPool(in *edgeproto.CloudletPool, ...) error + func (s *CloudletPoolApi) UpdateCloudletPool(ctx context.Context, in *edgeproto.CloudletPool) (*edgeproto.Result, error) + func (s *CloudletPoolApi) UsesCloudlet(key *edgeproto.CloudletKey) []edgeproto.CloudletPoolKey + type CloudletRefsApi struct + func NewCloudletRefsApi(sync *regiondata.Sync, all *AllApis) *CloudletRefsApi + func (s *CloudletRefsApi) Delete(ctx context.Context, key *edgeproto.CloudletKey, wait func(int64)) + func (s *CloudletRefsApi) ShowCloudletRefs(in *edgeproto.CloudletRefs, ...) error + type CloudletRefsV1 struct + ClusterInsts []ClusterInstRefKeyV1 + K8SAppInsts []AppInstRefKeyV1 + VmAppInsts []AppInstRefKeyV1 + type CloudletTaskableHelper struct + func (s *CloudletTaskableHelper) Run(ctx context.Context) + type ClusterCheckpoint struct + Keys []*edgeproto.ClusterKey + Org string + Status []string + Timestamp time.Time + func GetClusterCheckpoint(ctx context.Context, org string, timestamp time.Time) (*ClusterCheckpoint, error) + type ClusterInstApi struct + func NewClusterInstApi(sync *regiondata.Sync, all *AllApis) *ClusterInstApi + func (s *ClusterInstApi) CreateClusterCheckpoint(ctx context.Context, timestamp time.Time) error + func (s *ClusterInstApi) CreateClusterInst(in *edgeproto.ClusterInst, cb edgeproto.ClusterInstApi_CreateClusterInstServer) error + func (s *ClusterInstApi) DeleteClusterInst(in *edgeproto.ClusterInst, cb edgeproto.ClusterInstApi_DeleteClusterInstServer) error + func (s *ClusterInstApi) DeleteFromInfo(ctx context.Context, in *edgeproto.ClusterInstInfo) + func (s *ClusterInstApi) DeleteIdleReservableClusterInsts(ctx context.Context, in *edgeproto.IdleReservableClusterInsts) (*edgeproto.Result, error) + func (s *ClusterInstApi) Get(key *edgeproto.ClusterKey, buf *edgeproto.ClusterInst) bool + func (s *ClusterInstApi) GetRootLBFlavorInfo(ctx context.Context, stm concurrency.STM, cloudlet *edgeproto.Cloudlet, ...) (*edgeproto.FlavorInfo, error) + func (s *ClusterInstApi) HasKey(key *edgeproto.ClusterKey) bool + func (s *ClusterInstApi) RecordClusterInstEvent(ctx context.Context, cluster *edgeproto.ClusterInst, ...) + func (s *ClusterInstApi) ReplaceErrorState(ctx context.Context, in *edgeproto.ClusterInst, ...) + func (s *ClusterInstApi) ShowClusterInst(in *edgeproto.ClusterInst, cb edgeproto.ClusterInstApi_ShowClusterInstServer) error + func (s *ClusterInstApi) UpdateClusterInst(in *edgeproto.ClusterInst, cb edgeproto.ClusterInstApi_UpdateClusterInstServer) error + func (s *ClusterInstApi) UpdateFromInfo(ctx context.Context, in *edgeproto.ClusterInstInfo) + func (s *ClusterInstApi) UsesAutoScalePolicy(key *edgeproto.PolicyKey) *edgeproto.ClusterKey + func (s *ClusterInstApi) UsesFlavor(key *edgeproto.FlavorKey) *edgeproto.ClusterKey + func (s *ClusterInstApi) UsesNetwork(networkKey *edgeproto.NetworkKey) *edgeproto.ClusterKey + type ClusterInstInfoApi struct + func NewClusterInstInfoApi(sync *regiondata.Sync, all *AllApis) *ClusterInstInfoApi + func (s *ClusterInstInfoApi) Delete(ctx context.Context, in *edgeproto.ClusterInstInfo, rev int64) + func (s *ClusterInstInfoApi) Flush(ctx context.Context, notifyId int64) + func (s *ClusterInstInfoApi) Prune(ctx context.Context, keys map[edgeproto.ClusterKey]struct{}) + func (s *ClusterInstInfoApi) Update(ctx context.Context, in *edgeproto.ClusterInstInfo, rev int64) + type ClusterInstRefKeyV1 struct + ClusterKey edgeproto.ClusterKeyV1 + Organization string + type ClusterRefsApi struct + func NewClusterRefsApi(sync *regiondata.Sync, all *AllApis) *ClusterRefsApi + func (s *ClusterRefsApi) ShowClusterRefs(in *edgeproto.ClusterRefs, cb edgeproto.ClusterRefsApi_ShowClusterRefsServer) error + type ControllerApi struct + func NewControllerApi(sync *regiondata.Sync, all *AllApis) *ControllerApi + func (s *ControllerApi) RunJobs(ctx context.Context, ...) error + func (s *ControllerApi) ShowController(in *edgeproto.Controller, cb edgeproto.ControllerApi_ShowControllerServer) error + type ControllerMetricsReceiver struct + func NewControllerMetricsReceiver(metricsInflux *influxq.InfluxQ, edgeEventsInflux *influxq.InfluxQ) *ControllerMetricsReceiver + func (c *ControllerMetricsReceiver) RecvMetric(ctx context.Context, metric *edgeproto.Metric) + type DebugApi struct + func (s *DebugApi) DisableDebugLevels(req *edgeproto.DebugRequest, cb edgeproto.DebugApi_DisableDebugLevelsServer) error + func (s *DebugApi) EnableDebugLevels(req *edgeproto.DebugRequest, cb edgeproto.DebugApi_EnableDebugLevelsServer) error + func (s *DebugApi) RunDebug(req *edgeproto.DebugRequest, cb edgeproto.DebugApi_RunDebugServer) error + func (s *DebugApi) ShowDebugLevels(req *edgeproto.DebugRequest, cb edgeproto.DebugApi_ShowDebugLevelsServer) error + type DeviceApi struct + func NewDeviceApi(sync *regiondata.Sync, all *AllApis) *DeviceApi + func (s *DeviceApi) CreateDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error) + func (s *DeviceApi) Delete(ctx context.Context, in *edgeproto.Device, rev int64) + func (s *DeviceApi) EvictDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error) + func (s *DeviceApi) Flush(ctx context.Context, notifyId int64) + func (s *DeviceApi) HasDevice(key *edgeproto.DeviceKey) bool + func (s *DeviceApi) InjectDevice(ctx context.Context, in *edgeproto.Device) (*edgeproto.Result, error) + func (s *DeviceApi) Prune(ctx context.Context, keys map[edgeproto.DeviceKey]struct{}) + func (s *DeviceApi) ShowDevice(in *edgeproto.Device, cb edgeproto.DeviceApi_ShowDeviceServer) error + func (s *DeviceApi) ShowDeviceReport(in *edgeproto.DeviceReport, cb edgeproto.DeviceApi_ShowDeviceReportServer) error + func (s *DeviceApi) Update(ctx context.Context, in *edgeproto.Device, rev int64) + type DummyInfoResponder struct + AppInstCache *edgeproto.AppInstCache + AppInstInfoCache edgeproto.AppInstInfoCache + CloudletCache *edgeproto.CloudletCache + ClusterInstCache *edgeproto.ClusterInstCache + ClusterInstInfoCache edgeproto.ClusterInstInfoCache + RecvAppInstInfo notify.RecvAppInstInfoHandler + RecvClusterInstInfo notify.RecvClusterInstInfoHandler + RecvVMPoolInfo notify.RecvVMPoolInfoHandler + VMPoolCache *edgeproto.VMPoolCache + VMPoolInfoCache edgeproto.VMPoolInfoCache + func DefaultDummyInfoResponder(apis *AllApis) *DummyInfoResponder + func (d *DummyInfoResponder) InitDummyInfoResponder() + func (d *DummyInfoResponder) SetPause(enable bool) + func (d *DummyInfoResponder) SetSimulateAppCreateFailure(state bool) + func (d *DummyInfoResponder) SetSimulateAppDeleteFailure(state bool) + func (d *DummyInfoResponder) SetSimulateClusterCreateFailure(state bool) + func (d *DummyInfoResponder) SetSimulateClusterDeleteFailure(state bool) + func (d *DummyInfoResponder) SetSimulateVMPoolUpdateFailure(state bool) + type DummyStreamout struct + func (d *DummyStreamout) Context() context.Context + func (d *DummyStreamout) Send(res *edgeproto.Result) error + type ExecApi struct + func NewExecApi(all *AllApis) *ExecApi + func (s *ExecApi) AccessCloudlet(ctx context.Context, req *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error) + func (s *ExecApi) RecvExecRequest(ctx context.Context, msg *edgeproto.ExecRequest) + func (s *ExecApi) RunCommand(ctx context.Context, req *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error) + func (s *ExecApi) RunConsole(ctx context.Context, req *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error) + func (s *ExecApi) SendLocalRequest(ctx context.Context, req *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error) + func (s *ExecApi) ShowLogs(ctx context.Context, req *edgeproto.ExecRequest) (*edgeproto.ExecRequest, error) + type ExecReq struct + type FlavorApi struct + func NewFlavorApi(sync *regiondata.Sync, all *AllApis) *FlavorApi + func (s *FlavorApi) AddFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error) + func (s *FlavorApi) CreateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error) + func (s *FlavorApi) DeleteFlavor(ctx context.Context, in *edgeproto.Flavor) (res *edgeproto.Result, reterr error) + func (s *FlavorApi) HasFlavor(key *edgeproto.FlavorKey) bool + func (s *FlavorApi) RemoveFlavorRes(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error) + func (s *FlavorApi) ShowFlavor(in *edgeproto.Flavor, cb edgeproto.FlavorApi_ShowFlavorServer) error + func (s *FlavorApi) UpdateFlavor(ctx context.Context, in *edgeproto.Flavor) (*edgeproto.Result, error) + type FlowRateLimitSettingsApi struct + func NewFlowRateLimitSettingsApi(sync *regiondata.Sync, all *AllApis) *FlowRateLimitSettingsApi + func (r *FlowRateLimitSettingsApi) CreateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error) + func (r *FlowRateLimitSettingsApi) DeleteFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error) + func (r *FlowRateLimitSettingsApi) ShowFlowRateLimitSettings(in *edgeproto.FlowRateLimitSettings, ...) error + func (r *FlowRateLimitSettingsApi) ShowRateLimitSettings(in *edgeproto.RateLimitSettings, ...) error + func (r *FlowRateLimitSettingsApi) UpdateFlowRateLimitSettings(ctx context.Context, in *edgeproto.FlowRateLimitSettings) (*edgeproto.Result, error) + type GPUDriverApi struct + func NewGPUDriverApi(sync *regiondata.Sync, all *AllApis) *GPUDriverApi + func (s *GPUDriverApi) AddGPUDriverBuild(in *edgeproto.GPUDriverBuildMember, ...) (reterr error) + func (s *GPUDriverApi) CreateGPUDriver(in *edgeproto.GPUDriver, cb edgeproto.GPUDriverApi_CreateGPUDriverServer) (reterr error) + func (s *GPUDriverApi) DeleteGPUDriver(in *edgeproto.GPUDriver, cb edgeproto.GPUDriverApi_DeleteGPUDriverServer) error + func (s *GPUDriverApi) GetGPUDriverBuildURL(ctx context.Context, in *edgeproto.GPUDriverBuildMember) (*edgeproto.GPUDriverBuildURL, error) + func (s *GPUDriverApi) GetGPUDriverLicenseConfig(ctx context.Context, key *edgeproto.GPUDriverKey) (*edgeproto.Result, error) + func (s *GPUDriverApi) RemoveGPUDriverBuild(in *edgeproto.GPUDriverBuildMember, ...) error + func (s *GPUDriverApi) ShowGPUDriver(in *edgeproto.GPUDriver, cb edgeproto.GPUDriverApi_ShowGPUDriverServer) error + func (s *GPUDriverApi) UpdateGPUDriver(in *edgeproto.GPUDriver, cb edgeproto.GPUDriverApi_UpdateGPUDriverServer) (reterr error) + type GenerateResourceAlerts int + type GenericCb interface + Send func(*edgeproto.Result) error + type MaxReqsRateLimitSettingsApi struct + func NewMaxReqsRateLimitSettingsApi(sync *regiondata.Sync, all *AllApis) *MaxReqsRateLimitSettingsApi + func (r *MaxReqsRateLimitSettingsApi) CreateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error) + func (r *MaxReqsRateLimitSettingsApi) DeleteMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error) + func (r *MaxReqsRateLimitSettingsApi) ShowMaxReqsRateLimitSettings(in *edgeproto.MaxReqsRateLimitSettings, ...) error + func (r *MaxReqsRateLimitSettingsApi) UpdateMaxReqsRateLimitSettings(ctx context.Context, in *edgeproto.MaxReqsRateLimitSettings) (*edgeproto.Result, error) + type NameSanitizer interface + NameSanitize func(name string) (string, error) + type NetworkApi struct + func NewNetworkApi(sync *regiondata.Sync, all *AllApis) *NetworkApi + func (s *NetworkApi) CreateNetwork(in *edgeproto.Network, cb edgeproto.NetworkApi_CreateNetworkServer) error + func (s *NetworkApi) DeleteNetwork(in *edgeproto.Network, cb edgeproto.NetworkApi_DeleteNetworkServer) (reterr error) + func (s *NetworkApi) ShowNetwork(in *edgeproto.Network, cb edgeproto.NetworkApi_ShowNetworkServer) error + func (s *NetworkApi) UpdateNetwork(in *edgeproto.Network, cb edgeproto.NetworkApi_UpdateNetworkServer) error + func (s *NetworkApi) UsesCloudlet(in *edgeproto.CloudletKey) *edgeproto.NetworkKey + type NodeApi struct + func (s *NodeApi) ShowNode(in *edgeproto.Node, cb edgeproto.NodeApi_ShowNodeServer) error + type OperatorCodeApi struct + func NewOperatorCodeApi(sync *regiondata.Sync, all *AllApis) *OperatorCodeApi + func (s *OperatorCodeApi) CreateOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error) + func (s *OperatorCodeApi) DeleteOperatorCode(ctx context.Context, in *edgeproto.OperatorCode) (*edgeproto.Result, error) + func (s *OperatorCodeApi) ShowOperatorCode(in *edgeproto.OperatorCode, ...) error + type OrganizationApi struct + func NewOrganizationApi(sync *regiondata.Sync, all *AllApis) *OrganizationApi + func (s *OrganizationApi) OrganizationInUse(ctx context.Context, in *edgeproto.Organization) (*edgeproto.Result, error) + type PeriodicData struct + LastTime time.Time + type PeriodicReservableClusterInstCleanup struct + func (s *PeriodicReservableClusterInstCleanup) GetInterval() time.Duration + func (s *PeriodicReservableClusterInstCleanup) Run(ctx context.Context) + func (s *PeriodicReservableClusterInstCleanup) StartSpan() opentracing.Span + type PlatformFeaturesApi struct + func NewPlatformFeaturesApi(sync *regiondata.Sync, all *AllApis) *PlatformFeaturesApi + func (s *PlatformFeaturesApi) Delete(ctx context.Context, in *edgeproto.PlatformFeatures, rev int64) + func (s *PlatformFeaturesApi) DeletePlatformFeatures(ctx context.Context, in *edgeproto.PlatformFeatures) (res *edgeproto.Result, reterr error) + func (s *PlatformFeaturesApi) FeaturesByPlatform() map[string]edgeproto.PlatformFeatures + func (s *PlatformFeaturesApi) Flush(ctx context.Context, notifyId int64) + func (s *PlatformFeaturesApi) GetCloudletFeatures(ctx context.Context, platformType string) (*edgeproto.PlatformFeatures, error) + func (s *PlatformFeaturesApi) Prune(ctx context.Context, keys map[edgeproto.PlatformFeaturesKey]struct{}) + func (s *PlatformFeaturesApi) ShowPlatformFeatures(in *edgeproto.PlatformFeatures, ...) error + func (s *PlatformFeaturesApi) Update(ctx context.Context, in *edgeproto.PlatformFeatures, rev int64) + type RateLimitSettingsApi struct + type ResTagTableApi struct + func NewResTagTableApi(sync *regiondata.Sync, all *AllApis) *ResTagTableApi + func (s *ResTagTableApi) AddGpuResourceHintIfNeeded(ctx context.Context, stm concurrency.STM, spec *vmspec.VMCreationSpec, ...) string + func (s *ResTagTableApi) AddResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error) + func (s *ResTagTableApi) CreateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error) + func (s *ResTagTableApi) DeleteResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (res *edgeproto.Result, reterr error) + func (s *ResTagTableApi) GetCloudletResourceMap(ctx context.Context, stm concurrency.STM, key *edgeproto.ResTagTableKey) (*edgeproto.ResTagTable, error) + func (s *ResTagTableApi) GetResTablesForCloudlet(ctx context.Context, stm concurrency.STM, cl *edgeproto.Cloudlet) (tables map[string]*edgeproto.ResTagTable, err error) + func (s *ResTagTableApi) GetResTagTable(ctx context.Context, in *edgeproto.ResTagTableKey) (*edgeproto.ResTagTable, error) + func (s *ResTagTableApi) GetVMSpec(ctx context.Context, stm concurrency.STM, nodeflavor edgeproto.Flavor, ...) (*vmspec.VMCreationSpec, error) + func (s *ResTagTableApi) RemoveResTag(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error) + func (s *ResTagTableApi) ShowResTagTable(in *edgeproto.ResTagTable, cb edgeproto.ResTagTableApi_ShowResTagTableServer) error + func (s *ResTagTableApi) UpdateResTagTable(ctx context.Context, in *edgeproto.ResTagTable) (*edgeproto.Result, error) + func (s *ResTagTableApi) UsesGpu(ctx context.Context, stm concurrency.STM, flavor edgeproto.FlavorInfo, ...) bool + func (s *ResTagTableApi) ValidateOptResMapValues(resmap map[string]string) (bool, error) + func (s *ResTagTableApi) ValidateResName(ctx context.Context, in string) (error, bool) + type RunTimeStats struct + type Services struct + type SettingsApi struct + func NewSettingsApi(sync *regiondata.Sync, all *AllApis) *SettingsApi + func (s *SettingsApi) Get() *edgeproto.Settings + func (s *SettingsApi) ResetSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error) + func (s *SettingsApi) ShowSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Settings, error) + func (s *SettingsApi) UpdateSettings(ctx context.Context, in *edgeproto.Settings) (*edgeproto.Result, error) + type StreamObjApi struct + func NewStreamObjApi(sync *regiondata.Sync, all *AllApis) *StreamObjApi + func (s *StreamObjApi) StreamAppInst(key *edgeproto.AppInstKey, cb edgeproto.StreamObjApi_StreamAppInstServer) error + func (s *StreamObjApi) StreamCloudlet(key *edgeproto.CloudletKey, cb edgeproto.StreamObjApi_StreamCloudletServer) error + func (s *StreamObjApi) StreamClusterInst(key *edgeproto.ClusterKey, cb edgeproto.StreamObjApi_StreamClusterInstServer) error + func (s *StreamObjApi) StreamGPUDriver(key *edgeproto.GPUDriverKey, cb edgeproto.StreamObjApi_StreamGPUDriverServer) error + func (s *StreamObjApi) StreamMsgs(ctx context.Context, streamKey string, ...) error + func (s *StreamObjApi) UpdateStatus(ctx context.Context, obj interface{}, state *edgeproto.TrackedState, ...) + type StreamOp func(op *StreamOptions) + func WithNoResetStream() StreamOp + type StreamOptions struct + NoResetStream bool + type StreamoutCb struct + func (s *StreamoutCb) Context() context.Context + func (s *StreamoutCb) Send(res *edgeproto.Result) error + type SyncLeaseData struct + func NewSyncLeaseData(sy *regiondata.Sync, allApis *AllApis) *SyncLeaseData + func (s *SyncLeaseData) ControllerAliveLease() int64 + func (s *SyncLeaseData) LeaseID() int64 + func (s *SyncLeaseData) Start(ctx context.Context) + func (s *SyncLeaseData) Stop() + type TrustPolicyApi struct + func NewTrustPolicyApi(sync *regiondata.Sync, all *AllApis) *TrustPolicyApi + func (s *TrustPolicyApi) CreateTrustPolicy(in *edgeproto.TrustPolicy, cb edgeproto.TrustPolicyApi_CreateTrustPolicyServer) error + func (s *TrustPolicyApi) DeleteTrustPolicy(in *edgeproto.TrustPolicy, cb edgeproto.TrustPolicyApi_DeleteTrustPolicyServer) (reterr error) + func (s *TrustPolicyApi) GetTrustPolicies(policies map[edgeproto.PolicyKey]*edgeproto.TrustPolicy) + func (s *TrustPolicyApi) ShowTrustPolicy(in *edgeproto.TrustPolicy, cb edgeproto.TrustPolicyApi_ShowTrustPolicyServer) error + func (s *TrustPolicyApi) UpdateTrustPolicy(in *edgeproto.TrustPolicy, cb edgeproto.TrustPolicyApi_UpdateTrustPolicyServer) error + type TrustPolicyExceptionApi struct + func NewTrustPolicyExceptionApi(sync *regiondata.Sync, all *AllApis) *TrustPolicyExceptionApi + func (s *TrustPolicyExceptionApi) CreateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error) + func (s *TrustPolicyExceptionApi) DeleteTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (*edgeproto.Result, error) + func (s *TrustPolicyExceptionApi) GetTrustPolicyExceptionForAppKey(appKey *edgeproto.AppKey) *edgeproto.TrustPolicyException + func (s *TrustPolicyExceptionApi) GetTrustPolicyExceptionForCloudletPoolKey(cKey *edgeproto.CloudletPoolKey) *edgeproto.TrustPolicyException + func (s *TrustPolicyExceptionApi) GetTrustPolicyExceptionRules(ckey *edgeproto.CloudletPoolKey, appKey *edgeproto.AppKey) []*edgeproto.SecurityRule + func (s *TrustPolicyExceptionApi) ShowTrustPolicyException(in *edgeproto.TrustPolicyException, ...) error + func (s *TrustPolicyExceptionApi) TrustPolicyExceptionForAppKeyExists(appKey *edgeproto.AppKey) *edgeproto.TrustPolicyExceptionKey + func (s *TrustPolicyExceptionApi) TrustPolicyExceptionForCloudletPoolKeyExists(cKey *edgeproto.CloudletPoolKey) *edgeproto.TrustPolicyExceptionKey + func (s *TrustPolicyExceptionApi) UpdateTrustPolicyException(ctx context.Context, in *edgeproto.TrustPolicyException) (res *edgeproto.Result, reterr error) + type UpgradeSupport struct + type VMPoolApi struct + func NewVMPoolApi(sync *regiondata.Sync, all *AllApis) *VMPoolApi + func (s *VMPoolApi) AddVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error) + func (s *VMPoolApi) CreateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error) + func (s *VMPoolApi) DeleteVMPool(ctx context.Context, in *edgeproto.VMPool) (res *edgeproto.Result, reterr error) + func (s *VMPoolApi) RemoveVMPoolMember(ctx context.Context, in *edgeproto.VMPoolMember) (*edgeproto.Result, error) + func (s *VMPoolApi) ShowVMPool(in *edgeproto.VMPool, cb edgeproto.VMPoolApi_ShowVMPoolServer) error + func (s *VMPoolApi) UpdateFromInfo(ctx context.Context, in *edgeproto.VMPoolInfo) + func (s *VMPoolApi) UpdateVMPool(ctx context.Context, in *edgeproto.VMPool) (*edgeproto.Result, error) + type VMPoolInfoApi struct + func NewVMPoolInfoApi(sync *regiondata.Sync, all *AllApis) *VMPoolInfoApi + func (s *VMPoolInfoApi) Delete(ctx context.Context, in *edgeproto.VMPoolInfo, rev int64) + func (s *VMPoolInfoApi) Flush(ctx context.Context, notifyId int64) + func (s *VMPoolInfoApi) Prune(ctx context.Context, keys map[edgeproto.VMPoolKey]struct{}) + func (s *VMPoolInfoApi) Update(ctx context.Context, in *edgeproto.VMPoolInfo, rev int64) + type VaultRoles struct + CRMRoleID string + CRMSecretID string + CtrlRoleID string + CtrlSecretID string + DmeRoleID string + DmeSecretID string + type VersionUpgrade struct + type VersionUpgradeFunc func(context.Context, objstore.KVStore, *AllApis, *UpgradeSupport, int32) error
Go to main page