locator

package

v0.1.10 Latest Latest Go to latest Published: Jun 28, 2023 License: MIT Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DNSServer struct {
	*config.LocatorCfg
	api.Locator
}

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

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

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

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

type Locator struct {
	fx.In

	*common.CommonAPI
	region.Region
	Storage
	*config.LocatorCfg
	*DNSServer
}

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)

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

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

GetUserAccessPoint get user access point for special user ip

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