Versions in this module Expand all Collapse all v1 v1.2.5 Sep 23, 2024 Changes in this version + type CloudletNodeHandler interface + CreateCloudletNodeReq func(ctx context.Context, node *edgeproto.CloudletNode) (string, error) + DeleteCloudletNodeReq func(ctx context.Context, key *edgeproto.CloudletNodeKey) error + type ControllerHandler struct + func NewControllerHandler(cloudletVerified *edgeproto.Cloudlet, vaultClient *VaultClient) *ControllerHandler + func (s *ControllerHandler) GetAccessData(ctx context.Context, req *edgeproto.AccessDataRequest) (*edgeproto.AccessDataReply, error) + type TestHandler struct + AccessVars map[string]string + RegistryAuth cloudcommon.RegistryAuth + func (s *TestHandler) CreateCloudletNode(ctx context.Context, node *edgeproto.CloudletNode) (string, error) + func (s *TestHandler) CreateOrUpdateDNSRecord(ctx context.Context, name, rtype, content string, ttl int, proxy bool) error + func (s *TestHandler) DeleteCloudletNode(ctx context.Context, nodeKey *edgeproto.CloudletNodeKey) error + func (s *TestHandler) DeleteDNSRecord(ctx context.Context, recordID string) error + func (s *TestHandler) GetAppSecretVars(ctx context.Context, appKey *edgeproto.AppKey) (map[string]string, error) + func (s *TestHandler) GetChefAuthKey(ctx context.Context) (*chefauth.ChefAuthKey, error) + func (s *TestHandler) GetCloudletAccessVars(ctx context.Context) (map[string]string, error) + func (s *TestHandler) GetDNSRecords(ctx context.Context, fqdn string) ([]dnsapi.Record, error) + func (s *TestHandler) GetFederationAPIKey(ctx context.Context, fedKey *federationmgmt.FedKey) (*federationmgmt.ApiKey, error) + func (s *TestHandler) GetKafkaCreds(ctx context.Context) (*node.KafkaCreds, error) + func (s *TestHandler) GetOldSSHKey(ctx context.Context) (*vault.MEXKey, error) + func (s *TestHandler) GetPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error) + func (s *TestHandler) GetRegistryAuth(ctx context.Context, imgUrl string) (*cloudcommon.RegistryAuth, error) + func (s *TestHandler) GetRegistryImageAuth(ctx context.Context, imgUrl string) (*cloudcommon.RegistryAuth, error) + func (s *TestHandler) GetSSHPublicKey(ctx context.Context) (string, error) + func (s *TestHandler) GetSessionTokens(ctx context.Context, secretName string) (string, error) + func (s *TestHandler) SignSSHKey(ctx context.Context, publicKey string) (string, error) + type VaultClient struct + func NewVaultClient(ctx context.Context, vaultConfig *vault.Config, ...) *VaultClient + func (s *VaultClient) CloudletContext(cloudlet *edgeproto.Cloudlet) *VaultClient + func (s *VaultClient) CreateCloudletNode(ctx context.Context, node *edgeproto.CloudletNode) (string, error) + func (s *VaultClient) CreateOrUpdateDNSRecord(ctx context.Context, name, rtype, content string, ttl int, proxy bool) error + func (s *VaultClient) DeleteCloudletNode(ctx context.Context, nodeKey *edgeproto.CloudletNodeKey) error + func (s *VaultClient) DeleteDNSRecord(ctx context.Context, recordID string) error + func (s *VaultClient) GetAppSecretVars(ctx context.Context, appKey *edgeproto.AppKey) (map[string]string, error) + func (s *VaultClient) GetChefAuthKey(ctx context.Context) (*chefauth.ChefAuthKey, error) + func (s *VaultClient) GetCloudletAccessVars(ctx context.Context) (map[string]string, error) + func (s *VaultClient) GetDNSRecords(ctx context.Context, fqdn string) ([]dnsapi.Record, error) + func (s *VaultClient) GetFederationAPIKey(ctx context.Context, fedKey *federationmgmt.FedKey) (*federationmgmt.ApiKey, error) + func (s *VaultClient) GetKafkaCreds(ctx context.Context) (*node.KafkaCreds, error) + func (s *VaultClient) GetOldSSHKey(ctx context.Context) (*vault.MEXKey, error) + func (s *VaultClient) GetPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error) + func (s *VaultClient) GetRegistryAuth(ctx context.Context, hostOrURL string) (*cloudcommon.RegistryAuth, error) + func (s *VaultClient) GetRegistryImageAuth(ctx context.Context, imgUrl string) (*cloudcommon.RegistryAuth, error) + func (s *VaultClient) GetSSHPublicKey(ctx context.Context) (string, error) + func (s *VaultClient) GetSessionTokens(ctx context.Context, secretName string) (string, error) + func (s *VaultClient) SignSSHKey(ctx context.Context, publicKey string) (string, error)