locator

Documentation

Index

• type DNSServer
  • func NewDNSServer(config *config.LocatorCfg, locator api.Locator, reg region.Region) *DNSServer
  • func (ds *DNSServer) DeleteTXTRecord(domain string) error
  • func (ds *DNSServer) SetTXTRecord(domain string, value string) error
• type EtcdClient
  • func NewEtcdClient(addresses []string) (*EtcdClient, error)
  • func (ec *EtcdClient) GetAllSchedulerConfigs() []*types.SchedulerCfg
  • func (ec *EtcdClient) GetSchedulerConfigs(areaID string) ([]*types.SchedulerCfg, error)
• type Locator
  • func (l *Locator) CandidateDownloadInfos(ctx context.Context, cid string) ([]*types.CandidateDownloadInfo, error)
  • func (l *Locator) EdgeDownloadInfos(ctx context.Context, cid string) ([]*types.EdgeDownloadInfoList, error)
  • func (l *Locator) GetAccessPoints(ctx context.Context, nodeID, areaID string) ([]string, error)
  • func (l *Locator) GetAssetSourceDownloadInfos(ctx context.Context, cid string) ([]*types.AssetSourceDownloadInfoRsp, error)
  • func (l *Locator) GetCandidateIP(ctx context.Context, nodeID string) (string, error)
  • func (l *Locator) GetSchedulerWithAPIKey(ctx context.Context, apiKey string) (string, error)
  • func (l *Locator) GetSchedulerWithNode(ctx context.Context, nodeID string) (string, error)
  • func (l *Locator) GetUserAccessPoint(ctx context.Context, userIP string) (*api.AccessPoint, error)
• type SafeMap
  • func NewSafeMap() *SafeMap
  • func (sm *SafeMap) Delete(key interface{})
  • func (sm *SafeMap) Get(key interface{}) (interface{}, bool)
  • func (sm *SafeMap) Len() int
  • func (sm *SafeMap) Range(callback func(key interface{}, value interface{}))
  • func (sm *SafeMap) Set(key interface{}, value interface{})
• type SchedulerAPI
• type SchedulerAPIMap
• type Storage
• type TXTRecord

Types

type DNSServer

type DNSServer struct {
	*config.LocatorCfg
	api.Locator
	// contains filtered or unexported fields
}

func NewDNSServer

func NewDNSServer(config *config.LocatorCfg, locator api.Locator, reg region.Region) *DNSServer

func (*DNSServer) DeleteTXTRecord

func (ds *DNSServer) DeleteTXTRecord(domain string) error

func (*DNSServer) SetTXTRecord

func (ds *DNSServer) SetTXTRecord(domain string, value string) error

type EtcdClient

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

func NewEtcdClient

func NewEtcdClient(addresses []string) (*EtcdClient, error)

func (*EtcdClient) GetAllSchedulerConfigs

func (ec *EtcdClient) GetAllSchedulerConfigs() []*types.SchedulerCfg

func (*EtcdClient) GetSchedulerConfigs

func (ec *EtcdClient) GetSchedulerConfigs(areaID string) ([]*types.SchedulerCfg, error)

type Locator

type Locator struct {
	fx.In

	*common.CommonAPI
	region.Region
	Storage
	*config.LocatorCfg
	*DNSServer
	Rand          *rand.Rand
	ScheduelrAPIs SchedulerAPIMap
}

func (*Locator) CandidateDownloadInfos

func (l *Locator) CandidateDownloadInfos(ctx context.Context, cid string) ([]*types.CandidateDownloadInfo, error)

func (*Locator) EdgeDownloadInfos

func (l *Locator) EdgeDownloadInfos(ctx context.Context, cid string) ([]*types.EdgeDownloadInfoList, error)

func (*Locator) GetAccessPoints

func (l *Locator) GetAccessPoints(ctx context.Context, nodeID, areaID string) ([]string, error)

GetAccessPoints get schedulers urls with special areaID, and those schedulers have the node

func (*Locator) GetAssetSourceDownloadInfos

func (l *Locator) GetAssetSourceDownloadInfos(ctx context.Context, cid string) ([]*types.AssetSourceDownloadInfoRsp, error)

GetAssetSourceDownloadInfo

func (*Locator) GetCandidateIP

func (l *Locator) GetCandidateIP(ctx context.Context, nodeID string) (string, error)

GetCandidateIP retrieves ip of candidate

func (*Locator) GetSchedulerWithAPIKey

func (l *Locator) GetSchedulerWithAPIKey(ctx context.Context, apiKey string) (string, error)

func (*Locator) GetSchedulerWithNode

func (l *Locator) GetSchedulerWithNode(ctx context.Context, nodeID string) (string, error)

GetSchedulerWithNode get the scheduler that the node is already connected to

func (*Locator) GetUserAccessPoint

func (l *Locator) GetUserAccessPoint(ctx context.Context, userIP string) (*api.AccessPoint, error)

GetUserAccessPoint get user access point for special user ip

type SafeMap

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

It differs from sync.map by the addition of the len() function sync.map can not delete item on range

func NewSafeMap

func NewSafeMap() *SafeMap

func (*SafeMap) Delete

func (sm *SafeMap) Delete(key interface{})

func (*SafeMap) Get

func (sm *SafeMap) Get(key interface{}) (interface{}, bool)

func (*SafeMap) Len

func (sm *SafeMap) Len() int

func (*SafeMap) Range

func (sm *SafeMap) Range(callback func(key interface{}, value interface{}))

can not call any SafeMap func in callback, it will block anything

func (*SafeMap) Set

func (sm *SafeMap) Set(key interface{}, value interface{})

type SchedulerAPI

type SchedulerAPI struct {
	api.Scheduler
	// contains filtered or unexported fields
}

type SchedulerAPIMap

type SchedulerAPIMap map[string]*SchedulerAPI

type Storage

type Storage interface {
	GetSchedulerConfigs(areaID string) ([]*types.SchedulerCfg, error)
	GetAllSchedulerConfigs() []*types.SchedulerCfg
}

type TXTRecord

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