accessapi

Documentation

Index

• type ControllerClient
  • func NewControllerClient(client edgeproto.CloudletAccessApiClient) *ControllerClient
  • func (s *ControllerClient) CreateCloudletNode(ctx context.Context, cloudletNode *edgeproto.CloudletNode) (string, error)
  • func (s *ControllerClient) CreateOrUpdateDNSRecord(ctx context.Context, name, rtype, content string, ttl int, proxy bool) error
  • func (s *ControllerClient) DeleteCloudletNode(ctx context.Context, key *edgeproto.CloudletNodeKey) error
  • func (s *ControllerClient) DeleteDNSRecord(ctx context.Context, name string) error
  • func (s *ControllerClient) GetAppSecretVars(ctx context.Context, appKey *edgeproto.AppKey) (map[string]string, error)
  • func (s *ControllerClient) GetCloudletAccessVars(ctx context.Context) (map[string]string, error)
  • func (s *ControllerClient) GetDNSRecords(ctx context.Context, fqdn string) ([]dnsapi.Record, error)
  • func (s *ControllerClient) GetFederationAPIKey(ctx context.Context, fedKey *federationmgmt.FedKey) (*federationmgmt.ApiKey, error)
  • func (s *ControllerClient) GetKafkaCreds(ctx context.Context) (*node.KafkaCreds, error)
  • func (s *ControllerClient) GetOldSSHKey(ctx context.Context) (*vault.MEXKey, error)
  • func (s *ControllerClient) GetPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error)
  • func (s *ControllerClient) GetRegistryAuth(ctx context.Context, imgUrl string) (*cloudcommon.RegistryAuth, error)
  • func (s *ControllerClient) GetSSHPublicKey(ctx context.Context) (string, error)
  • func (s *ControllerClient) GetSessionTokens(ctx context.Context, secretName string) (string, error)
  • func (s *ControllerClient) SignSSHKey(ctx context.Context, publicKey string) (string, error)

Types

type ControllerClient

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

ControllerClient implements platform.AccessApi for cloudlet services by connecting to the Controller. To avoid having to change the Controller's API if we need to add new functions to the platform.AccessApi interface, all requests to the Controller go through a generic single API. Data is marshaled here. Unmarshaling is done in ControllerHandler.

func NewControllerClient

func NewControllerClient(client edgeproto.CloudletAccessApiClient) *ControllerClient

func (*ControllerClient) CreateCloudletNode

func (s *ControllerClient) CreateCloudletNode(ctx context.Context, cloudletNode *edgeproto.CloudletNode) (string, error)

func (*ControllerClient) CreateOrUpdateDNSRecord

func (s *ControllerClient) CreateOrUpdateDNSRecord(ctx context.Context, name, rtype, content string, ttl int, proxy bool) error

func (*ControllerClient) DeleteCloudletNode

func (s *ControllerClient) DeleteCloudletNode(ctx context.Context, key *edgeproto.CloudletNodeKey) error

func (*ControllerClient) DeleteDNSRecord

func (s *ControllerClient) DeleteDNSRecord(ctx context.Context, name string) error

func (*ControllerClient) GetAppSecretVars

func (s *ControllerClient) GetAppSecretVars(ctx context.Context, appKey *edgeproto.AppKey) (map[string]string, error)

func (*ControllerClient) GetCloudletAccessVars

func (s *ControllerClient) GetCloudletAccessVars(ctx context.Context) (map[string]string, error)

func (*ControllerClient) GetDNSRecords

func (s *ControllerClient) GetDNSRecords(ctx context.Context, fqdn string) ([]dnsapi.Record, error)

func (*ControllerClient) GetFederationAPIKey

func (s *ControllerClient) GetFederationAPIKey(ctx context.Context, fedKey *federationmgmt.FedKey) (*federationmgmt.ApiKey, error)

func (*ControllerClient) GetKafkaCreds

func (s *ControllerClient) GetKafkaCreds(ctx context.Context) (*node.KafkaCreds, error)

func (*ControllerClient) GetOldSSHKey

func (s *ControllerClient) GetOldSSHKey(ctx context.Context) (*vault.MEXKey, error)

func (*ControllerClient) GetPublicCert

func (s *ControllerClient) GetPublicCert(ctx context.Context, commonName string) (*vault.PublicCert, error)

func (*ControllerClient) GetRegistryAuth

func (s *ControllerClient) GetRegistryAuth(ctx context.Context, imgUrl string) (*cloudcommon.RegistryAuth, error)

func (*ControllerClient) GetSSHPublicKey

func (s *ControllerClient) GetSSHPublicKey(ctx context.Context) (string, error)

func (*ControllerClient) GetSessionTokens

func (s *ControllerClient) GetSessionTokens(ctx context.Context, secretName string) (string, error)

func (*ControllerClient) SignSSHKey

func (s *ControllerClient) SignSSHKey(ctx context.Context, publicKey string) (string, error)