Versions in this module Expand all Collapse all v1 v1.2.5 Sep 23, 2024 Changes in this version + const AccessKeyData + const AccessKeySig + const AlertAnnotationDescription + const AlertAnnotationErrorString + const AlertAnnotationTitle + const AlertAppInstDown + const AlertAutoScaleDown + const AlertAutoScaleUp + const AlertAutoUndeploy + const AlertCloudletDown + const AlertCloudletDownDescription + const AlertCloudletResourceUsage + const AlertClusterAutoScale + const AlertClusterSvcAppInstFailure + const AlertClusterSvcAppInstFailureDescription + const AlertScopeApp + const AlertScopeCloudlet + const AlertScopePlatform + const AlertScopeTypeTag + const AlertSeverityError + const AlertSeverityInfo + const AlertSeverityLabel + const AlertSeverityWarn + const AlertTypeLabel + const AlertTypeUserDefined + const AllOrgs + const AlreadyUnderDeletionMsg + const AnnotationBadUpgrade55Name + const AnnotationCloudletScopedName + const AnnotationPreviousDNSName + const ApiKeyAuth + const AppFederatedIdMaxLen + const AppInstCompatibilityInitial + const AppInstCompatibilityRegionScopeName + const AppInstCompatibilityUniqueNameKey + const AppInstCompatibilityUniqueNameKeyConfig + const AuthRespAccessToken + const AuthRespToken + const AutoProvPolicyName + const AutoProvPrefix + const AutoProvReason + const AutoProvReasonDemand + const AutoProvReasonMinMax + const AutoProvReasonOrphaned + const BasicAuth + const CRMCompatibilityAutoReservableCluster + const CRMCompatibilityNewAppInstKey + const CRMCompatibilitySharedRootLBFQDN + const CallerAutoProv + const CertName + const ClusterInstCompatibilityInitial + const ClusterInstCompatibilityRegionScopeName + const DefaultClust + const DefaultMultiTenantCluster + const DnsCloudletLabelMaxLen + const DnsCloudletObjectLabelMaxLen + const DnsDomainLabelMaxLen + const DnsRegionLabelMaxLen + const DockerHub + const DockerHubRegistry + const E2ETEST_IMAGE_CHECKSUM + const FreeClusterEvent + const GetCloudletManifest + const GetRestrictedCloudletStatus + const IdAlphabet + const IdAlphabetLC + const MaxClusterNameLength + const MaxOvfVmVersion + const MetricTagDataNetworkType + const MetricTagDeployment + const MetricTagDeviceCarrier + const MetricTagDeviceModel + const MetricTagDeviceOS + const MetricTagDisk + const MetricTagDmeCloudlet + const MetricTagDmeCloudletOrg + const MetricTagDmeId + const MetricTagDuration + const MetricTagEnd + const MetricTagEndTime + const MetricTagEvent + const MetricTagFlavor + const MetricTagFoundCloudlet + const MetricTagFoundOperator + const MetricTagIpAccess + const MetricTagLocationTile + const MetricTagMethod + const MetricTagNodeCount + const MetricTagNote + const MetricTagNumNodes + const MetricTagOrg + const MetricTagOther + const MetricTagPort + const MetricTagRAM + const MetricTagRegion + const MetricTagStart + const MetricTagStartTime + const MetricTagStatName + const MetricTagStatus + const MetricTagUptime + const MetricTagVCPU + const NoAuth + const RedactedSecret + const ReservableClusterPrefix + const ReserveClusterEvent + const StreamActionAlreadyInProgressMsg + const TagIpUserEquipment + const TagPrioritySessionId + const TagQosProfileName + const TokenAuth + const UnknownOwner + const ValidAlertSeverityString + const VaultKeySig + var AlertHealthCheckStatus = "status" + var AlertKeyLowCpuNodeCount = "lowcpunodecount" + var AlertKeyMinNodes = "minnodes" + var AlertKeyNodeCount = "nodecount" + var AlertSeverityTypes = map[string]struct + var AlertSeverityValues = map[string]string + var AllocatedIpDynamic = "dynamic" + var AppInstCheckpoints = "appinst-checkpoints" + var AppInstEvent = "appinst" + var AppInstEventSelectors = []string + var AutoProvMeasurement = "auto-prov-counts" + var AutoProvMinAlreadyMetError = fmt.Errorf("Create to satisfy min already met, ignoring") + var ClientTypeClusterVM string = "clustervm" + var ClientTypeRootLB string = "rootlb" + var CloudletEvent = "cloudlet" + var CloudletFlavorUsageMeasurement = "cloudlet-flavor-usage" + var CloudletKindAws = "aws" + var CloudletKindAzure = "azure" + var CloudletKindDIND = "dind" + var CloudletKindFake = "fake" + var CloudletKindGCP = "gcp" + var CloudletKindOpenStack = "openstack" + var CloudletResourceUsageDbName = "cloudlet_resource_usage" + var ClusterInstCheckpoints = "clusterinst-checkpoints" + var ClusterInstEvent = "clusterinst" + var ClusterInstEventSelectors = []string + var CommonCloudletResources = map[string]string + var CommonResourceQuotaProps = GetCommonResourceQuotaProps() + var CustomMetric = "custom-metric" + var DefaultPlatformFlavorKey = edgeproto.FlavorKey + var DeploymentTypeDocker = "docker" + var DeploymentTypeHelm = "helm" + var DeploymentTypeKubernetes = "kubernetes" + var DeploymentTypeVM = "vm" + var DeveloperMetricsDbName = "metrics" + var DeviceMetric = "device-metric" + var DindScriptName = "dind-cluster-v1.14.sh" + var DmeApiMeasurement = "dme-api" + var Download = "download" + var DownsampledMetricsDbName = "downsampled_metrics" + var EdgeEventsMetrics = map[string]struct + var EdgeEventsMetricsDbName = "edgeevents_metrics" + var EventsDbName = "events" + var GPUResourceLimitName = "nvidia.com/gpu" + var GRPCClientKeepaliveParams = keepalive.ClientParameters + var GRPCServerKeepaliveEnforcement = keepalive.EnforcementPolicy + var GRPCServerKeepaliveParams = keepalive.ServerParameters + var IPAddrAllInterfaces = "0.0.0.0" + var IPAddrLocalHost = "127.0.0.1" + var IPV6AddrAllInterfaces = "::" + var InstanceDown = "DOWN" + var InstanceUp = "UP" + var InternalDockerRegistry = "internal-docker-registry" + var InternalVMRegistry = "internal-vm-registry" + var LatencyMetric = "latency-metric" + var MEXPrometheusAppName = "MEXPrometheusAppName" + var MexAppInstNameLabel = "mexAppInstName" + var MexAppInstOrgLabel = "mexAppInstOrg" + var MexAppNameLabel = "mexAppName" + var MexAppVersionLabel = "mexAppVersion" + var MexMetricEndpoint = "mexMetricsEndpoint" + var MexNodePrefix = "mex-k8s-node-" + var MonthlyInterval = "MONTH" + var NFSAutoProvisionAppName = "NFSAutoProvision" + var NetworkSchemePrivateIP = "privateip" + var NetworkSchemePublicIP = "publicip" + var NoCreds = "" + var NoDownload = "nodownload" + var OperatingSystemLinux = "linux" + var OperatingSystemMac = "mac" + var OperatorAWS = "aws" + var OperatorAzure = "azure" + var OperatorGCP = "gcp" + var PlatosEnablingLayer = "PlatosEnablingLayer" + var PrometheusPort = int32(9090) + var ProxyMetricsDefaultListenIP = "127.0.0.1" + var ProxyMetricsListenUDS = "MetricsUDS" + var ProxyMetricsPort = int32(65121) + var RemoteServerNone = "" + var ResourceDiskGb = "Disk" + var ResourceDiskUnits = "GB" + var ResourceExternalIPs = "External IPs" + var ResourceFloatingIPs = "Floating IPs" + var ResourceGpus = "GPUs" + var ResourceInstances = "Instances" + var ResourceK8sClusters = "K8s Clusters" + var ResourceMaxK8sNodesPerCluster = "Maximum K8s Nodes Per Cluster" + var ResourceMetricDisk = "diskUsed" + var ResourceMetricExternalIPs = "externalIpsUsed" + var ResourceMetricFloatingIPs = "floatingIpsUsed" + var ResourceMetricGpus = "gpusUsed" + var ResourceMetricInstances = "instancesUsed" + var ResourceMetricK8sClusters = "k8sClustersUsed" + var ResourceMetricMaxK8sNodesPerCluster = "maxK8sNodesPerClusterUsed" + var ResourceMetricNetworkLBs = "networkLBsUsed" + var ResourceMetricRamMB = "ramUsed" + var ResourceMetricTotalK8sNodes = "totalK8sNodesUsed" + var ResourceMetricVcpus = "vcpusUsed" + var ResourceMetricsDesc = map[string]string + var ResourceNetworkLBs = "Network Load Balancers" + var ResourceQuotaDesc = map[string]string + var ResourceRamMb = "RAM" + var ResourceRamUnits = "MB" + var ResourceTotalK8sNodes = "Total Number Of K8s Nodes" + var ResourceTypeK8sLBSvc = "k8s-lb-svc" + var ResourceVcpus = "vCPUs" + var RootLBHostname = "shared" + var ValidAppDeployments = []string + var ValidCloudletDeployments = []string + var VmRegHeaderMD5 = "X-Checksum-Md5" + var VmRegPath = "/storage/v1/artifacts" + var VmRegPullPath = "/storage/v1/pull" + func AppInstBeingDeleted(inst *edgeproto.AppInst) bool + func AppInstToClusterDeployment(deployment string) string + func AuditStreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error + func AuditUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error) + func AutoProvAppInstGoingOnline(appInst *edgeproto.AppInst, cloudletInfo *edgeproto.CloudletInfo, ...) bool + func AutoProvAppInstOnline(appInst *edgeproto.AppInst, cloudletInfo *edgeproto.CloudletInfo, ...) bool + func AutoProvCloudletInfoOnline(cloudletInfo *edgeproto.CloudletInfo) bool + func AutoProvCloudletOnline(cloudlet *edgeproto.Cloudlet) bool + func BuildReservableClusterName(id int, cloudletKey *edgeproto.CloudletKey) string + func CheckFQDNLengths(prefix, uri string) error + func CidrContainsCidr(n1, n2 *net.IPNet) bool + func CloudletResourceUsageAlerts(ctx context.Context, key *edgeproto.CloudletKey, warnings []string) []edgeproto.Alert + func DecodeDockerComposeYaml(manifest string) (map[string]DockerContainer, error) + func DecodeK8SYaml(manifest string) ([]runtime.Object, []*schema.GroupVersionKind, error) + func DeleteAppSecretVars(ctx context.Context, region string, appKey *edgeproto.AppKey, ...) error + func DeleteFile(filePath string) error + func DeleteSecretVars(ctx context.Context, path string, vaultConfig *vault.Config) error + func DownloadFile(ctx context.Context, authApi RegistryAuthApi, ...) (reterr error) + func FormatDuration(dur time.Duration, digIdx int) string + func FqdnPrefix(svcName string) string + func GRPCErrorUnwrap(err error) error + func GenerateManifest(app *edgeproto.App) (string, error) + func GetAppClientType(app *edgeproto.App) string + func GetAppDeploymentManifest(ctx context.Context, authApi RegistryAuthApi, app *edgeproto.App) (string, error) + func GetAppInstCloudletScopedName(appInst *edgeproto.AppInst) string + func GetAppInstCompatibilityVersion() uint32 + func GetAppSecretVars(ctx context.Context, region string, appKey *edgeproto.AppKey, ...) (map[string]string, error) + func GetArtifactOrgPath(org, path string) string + func GetArtifactPullPath(addr, org, path string) string + func GetArtifactStoragePath(addr, org, path string) string + func GetAuthToken(ctx context.Context, host string, authApi RegistryAuthApi, userName string) (string, error) + func GetAutoProvAppInstKey(appKey *edgeproto.AppKey, cloudletKey *edgeproto.CloudletKey) edgeproto.AppInstKey + func GetAvailablePort(ipaddr string) (string, error) + func GetCRMCompatibilityVersion() uint32 + func GetCertsDirAndFiles(pwd string) (string, string, string) + func GetCloudletE2EPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error) + func GetCloudletKeyHash(key *edgeproto.CloudletKey) string + func GetCloudletResourceUsageMeasurement(pfType string) string + func GetClusterInstCloudletScopedName(clusterInst *edgeproto.ClusterInst) string + func GetClusterInstCompatibilityVersion() uint32 + func GetClusterInstVMRequirements(ctx context.Context, clusterInst *edgeproto.ClusterInst, ...) ([]edgeproto.VMResource, error) + func GetCommonResourceQuotaProps(additionalResources ...string) []edgeproto.InfraResource + func GetDefaultClustKey(cloudletKey edgeproto.CloudletKey, ownerOrg string) *edgeproto.ClusterKey + func GetDefaultDeploymentType(imageType edgeproto.ImageType) (string, error) + func GetDefaultMTClustKey(cloudletKey edgeproto.CloudletKey) *edgeproto.ClusterKey + func GetDeploymentManifest(ctx context.Context, authApi RegistryAuthApi, manifest string) (string, error) + func GetDockerBaseImageVersion() (string, error) + func GetDockerDeployType(manifest string) string + func GetDockerImageChecksum(ctx context.Context, imagePath string, auth *RegistryAuth) (string, error) + func GetFileName(fileUrlPath string) (string, error) + func GetFileNameWithExt(fileUrlPath string) (string, error) + func GetGPUDriverBuildStoragePath(key *edgeproto.GPUDriverKey, region, buildName, ext string) (string, error) + func GetGPUDriverLicenseCloudletStoragePath(key *edgeproto.GPUDriverKey, region string, cloudletKey *edgeproto.CloudletKey) (string, error) + func GetGPUDriverLicenseStoragePath(key *edgeproto.GPUDriverKey, region string) (string, error) + func GetGPUDriverStoragePath(key *edgeproto.GPUDriverKey, region string) (string, error) + func GetImageTypeForDeployment(deployment string) (edgeproto.ImageType, error) + func GetInfluxSelectFields(selectors []string) string + func GetK8sAppRequirements(ctx context.Context, app *edgeproto.App) ([]edgeproto.VMResource, error) + func GetMappedAccessType(accessType edgeproto.AccessType, deployment, deploymentManifest string) (edgeproto.AccessType, error) + func GetQueryArgsFromObj(obj interface{}) (string, error) + func GetRegistryAuthToken(ctx context.Context, host string, authApi RegistryAuthApi) (string, error) + func GetRemoteManifest(ctx context.Context, authApi RegistryAuthApi, target string) (string, error) + func GetRemoteManifestToFile(ctx context.Context, authApi RegistryAuthApi, target string, filename string) error + func GetRemoteZipDockerManifests(ctx context.Context, authApi RegistryAuthApi, ...) ([]map[string]DockerContainer, error) + func GetRootLBFQDNOld(key *edgeproto.CloudletKey, domain string) string + func GetRootLBFQDNWildcard(cloudlet *edgeproto.Cloudlet) string + func GetSecretVars(ctx context.Context, path string, vaultConfig *vault.Config) (map[string]string, error) + func GetSeverityForAlert(alertname string) string + func GetSideCarAppFilter() *edgeproto.App + func GetTimeout(cLen int) time.Duration + func GetVMAppRequirements(ctx context.Context, app *edgeproto.App, appInst *edgeproto.AppInst, ...) ([]edgeproto.VMResource, error) + func GetValidAlertSeverityString() string + func GrpcCreds(cfg *ctls.Config) grpc.ServerOption + func GrpcGateway(cfg *GrpcGWConfig) (http.Handler, error) + func GrpcGatewayServe(server *http.Server, tlsCertFile string) + func Hostname() string + func IsAlertSeverityValid(severity string) bool + func IsAppInstBeingCreatedError(err error) bool + func IsAppInstBeingDeletedError(err error) bool + func IsClusterInstReqd(app *edgeproto.App) bool + func IsDefaultClustKey(clusterKey edgeproto.ClusterKey, cloudletKey edgeproto.CloudletKey) bool + func IsGPUFlavor(flavor *edgeproto.Flavor) (bool, int) + func IsInternalAlert(labels map[string]string) bool + func IsLBNode(nodeTypeStr string) bool + func IsLabelInternal(label string) bool + func IsMonitoredAlert(labels map[string]string) bool + func IsPlatformApp(devname string, appname string) bool + func IsPlatformNode(nodeTypeStr string) bool + func IsSideCarApp(app *edgeproto.App) bool + func IsValidDeploymentForImage(imageType edgeproto.ImageType, deployment string) bool + func IsValidDeploymentManifest(deploymentType, command, manifest string, ports []dme.AppPort, ...) error + func IsValidDeploymentManifestForFlavor(deploymentType, manifest string, flavor *edgeproto.Flavor) error + func IsValidDeploymentType(DeploymentType string, validDeployments []string) bool + func LookupDNS(name string) (string, error) + func Md5SumFile(filePath string) (string, error) + func Md5SumStr(data string) string + func ParseGPUResource(resStr string) (string, string, int, error) + func ParseGrpcMethod(method string) (path string, cmd string) + func ParseHost(hostOrURL string) (string, string, error) + func ParseMyCloudletKey(standalone bool, keystr *string, mykey *edgeproto.CloudletKey) + func ParseReservableClusterName(name string) (int, string, error) + func RedactSecretVars(vars map[string]string) map[string]string + func SaveAppSecretVars(ctx context.Context, region string, appKey *edgeproto.AppKey, ...) error + func SaveSecretVars(ctx context.Context, path string, vaultConfig *vault.Config, ...) error + func SendHTTPReq(ctx context.Context, method, regUrl string, authApi RegistryAuthApi, ...) (*http.Response, error) + func SendHTTPReqAuth(ctx context.Context, method, regUrl string, auth *RegistryAuth, ...) (*http.Response, error) + func ServiceFQDN(svcName, baseFQDN string) string + func StreamRecvWithStatus[Object StatusObj](ctx context.Context, stream GRPCStreamRecv[Object], ...) error + func StreamRecv[Object any](ctx context.Context, stream GRPCStreamRecv[Object], cb func(obj Object) error) error + func UpdateAppSecretVars(ctx context.Context, region string, appKey *edgeproto.AppKey, ...) (map[string]string, error) + func UpdateSecretVars(ctx context.Context, path string, vaultConfig *vault.Config, ...) (map[string]string, error) + func ValidateCloudletResourceQuotas(ctx context.Context, quotaProps []edgeproto.InfraResource, ...) error + func ValidateDockerRegistryPath(ctx context.Context, regUrl string, authApi RegistryAuthApi) error + func ValidateOvfRegistryPath(ctx context.Context, imgUrl string, authApi RegistryAuthApi) error + func ValidateVMRegistryPath(ctx context.Context, imgUrl string, authApi RegistryAuthApi) error + func WrapStream(stream grpc.ServerStream, ctx context.Context) grpc.ServerStream + type Action int + const Create + const Delete + const Update + func (a Action) String() string + type AppInstLabels struct + AppInstNameLabel string + AppInstOrgLabel string + func GetAppInstLabels(appInst *edgeproto.AppInst) AppInstLabels + func (s *AppInstLabels) FromMap(labels map[string]string) + func (s *AppInstLabels) Map() map[string]string + type AppInstLabelsOld struct + AppNameLabel string + AppVersionLabel string + func GetAppInstLabelsOld(appInst *edgeproto.AppInst) AppInstLabelsOld + func (s *AppInstLabelsOld) FromMap(labels map[string]string) + func (s *AppInstLabelsOld) Map() map[string]string + type AuditRecvOne struct + func NewAuditRecvOne(stream grpc.ServerStream, ctx context.Context) *AuditRecvOne + func (s *AuditRecvOne) Context() context.Context + func (s *AuditRecvOne) RecvMsg(m interface{}) error + type AuthTokenResp struct + AccessToken string + ExpiresIn int + Scope string + type DockerContainer struct + Image string + type DockerManifest struct + DockerComposeFiles []string + type DummyRegistryAuthApi struct + DummyAuth RegistryAuth + func (s *DummyRegistryAuthApi) GetRegistryAuth(ctx context.Context, imgUrl string) (*RegistryAuth, error) + type EmailAccount struct + Email string + Pass string + Smtp string + SmtpPort string + SmtpTLS bool + User string + func GetNoreply(vaultConfig *vault.Config) (*EmailAccount, error) + type ExecReqInfo struct + Cookies []*http.Cookie + InitURL *url.URL + Type ExecReqType + type ExecReqType int + const ExecReqConsole + const ExecReqShell + type GRPCConnCache struct + func NewGRPCConnCache(addrsByKey map[string]string) *GRPCConnCache + func (s *GRPCConnCache) GetConn(ctx context.Context, key string) (*grpc.ClientConn, error) + func (s *GRPCConnCache) GetInterval() time.Duration + func (s *GRPCConnCache) Run(ctx context.Context) + func (s *GRPCConnCache) SetConn(key string, conn *grpc.ClientConn) + func (s *GRPCConnCache) Start() + func (s *GRPCConnCache) StartSpan() opentracing.Span + func (s *GRPCConnCache) Stop() + type GRPCStreamRecv interface + Recv func() (Object, error) + type GetPublicCertApi interface + GetPublicCert func(ctx context.Context, commonName string) (*vault.PublicCert, error) + type GrpcGWConfig struct + ApiAddr string + ApiHandles []func(context.Context, *gwruntime.ServeMux, *grpc.ClientConn) error + GetCertificate func(*ctls.CertificateRequestInfo) (*ctls.Certificate, error) + TlsCertFile string + type InfluxCreds struct + Pass string + User string + func GetInfluxDataAuth(vaultConfig *vault.Config, region string) (*InfluxCreds, error) + type InstanceEvent string + const CREATED + const DELETED + const DELETE_ERROR + const HEALTH_CHECK_FAIL + const HEALTH_CHECK_OK + const RESERVED + const UNRESERVED + const UPDATE_COMPLETE + const UPDATE_ERROR + const UPDATE_START + type NodeRole string + const NodeRoleBase + const NodeRoleDockerCrm + const NodeRoleDockerShepherdLB + const NodeRoleK8sCrm + const NodeRoleK8sCrmWorker + func (s NodeRole) String() string + type NodeType int + const NodeTypeAppVM + const NodeTypeDedicatedRootLB + const NodeTypeDockerClusterNode + const NodeTypeK8sClusterMaster + const NodeTypeK8sClusterNode + const NodeTypePlatformHost + const NodeTypePlatformK8sClusterMaster + const NodeTypePlatformK8sClusterPrimaryNode + const NodeTypePlatformK8sClusterSecondaryNode + const NodeTypePlatformVM + const NodeTypeSharedRootLB + func (n NodeType) String() string + type OauthTokenResp struct + AccessToken string + TokenType string + type ProtoCodec struct + func (s *ProtoCodec) Marshal(v interface{}) ([]byte, error) + func (s *ProtoCodec) Name() string + func (s *ProtoCodec) Unmarshal(data []byte, v interface{}) error + type RegistryAuth struct + ApiKey string + AuthType string + Hostname string + Password string + Port string + Token string + Username string + func GetAccountAuth(ctx context.Context, name string, vaultConfig *vault.Config) (*RegistryAuth, error) + type RegistryAuthApi interface + GetRegistryAuth func(ctx context.Context, imgUrl string) (*RegistryAuth, error) + type RegistryAuthMgr struct + func NewRegistryAuthMgr(vaultConfig *vault.Config, validDomains string) *RegistryAuthMgr + func (s *RegistryAuthMgr) DeleteRegistryAuth(ctx context.Context, host, org string) error + func (s *RegistryAuthMgr) GetRegistryImageAuth(ctx context.Context, imgUrl string) (*RegistryAuth, error) + func (s *RegistryAuthMgr) GetRegistryOrgAuth(ctx context.Context, hostOrURL, org string) (*RegistryAuth, error) + func (s *RegistryAuthMgr) PutRegistryAuth(ctx context.Context, host, org string, auth *RegistryAuth, checkAndSet int) error + func (s *RegistryAuthMgr) UpgradeRegistryAuth(ctx context.Context, internalRegistry, org string) error + type RegistryTags struct + Name string + Tags []string + type RequestConfig struct + Headers map[string]string + ResponseHeaderTimeout time.Duration + Timeout time.Duration + type SessionInfo struct + Token string + type SkopeoInspect struct + Architecture string + Created time.Time + Digest string + DockerVersion string + Env []string + Labels map[string]string + Layers []string + LayersData []SkopeoInspectLayer + Name string + Os string + RepoTags []string + type SkopeoInspectLayer struct + Digest string + MIMEType string + Size string + type StatusObj interface + GetStatus func() *edgeproto.StatusInfo + type StoragePath struct + func (s *StoragePath) AppendPaths(paths ...string) error + func (s *StoragePath) String() string + func (s *StoragePath) Validate() error + type StreamObj struct + func (sm *StreamObj) Add(in interface{}, streamer *Streamer) + func (sm *StreamObj) Get(in interface{}) *Streamer + func (sm *StreamObj) Remove(in interface{}, streamer *Streamer) + func (sm *StreamObj) SetupCleanupTimer() + type Streamer struct + State edgeproto.StreamState + func NewStreamer() *Streamer + func (s *Streamer) Publish(msg interface{}) + func (s *Streamer) Stop() + func (s *Streamer) Subscribe() chan interface{} + func (s *Streamer) Unsubscribe(msgCh chan interface{}) + type Streams map[interface{}]*Streamer + type TestPublicCertApi struct + GetCount int + func (s *TestPublicCertApi) GetPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error) + type TrustPolicyExceptionKeyClusterKey struct + ClusterKey edgeproto.ClusterKey + TpeKey edgeproto.TrustPolicyExceptionKey + type VaultPublicCertApi struct + VaultConfig *vault.Config + func (s *VaultPublicCertApi) GetPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error) + type VaultRegistryAuthApi struct + RegAuthMgr *RegistryAuthMgr + func (s *VaultRegistryAuthApi) GetRegistryAuth(ctx context.Context, imgUrl string) (*RegistryAuth, error)
Go to main page