locator

Documentation

Index

• type EtcdClient
  • func NewEtcdClient(addresses []string) (*EtcdClient, error)
  • func (ec *EtcdClient) GetSchedulerConfigs(areaID string) ([]*types.SchedulerCfg, error)
• type Locator
  • 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) GetUserAccessPoint(ctx context.Context, userIP string) (*api.AccessPoint, error)
• type Storage

Types

type EtcdClient

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

func NewEtcdClient

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

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
}

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) GetUserAccessPoint

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

GetUserAccessPoint get user access point for special user ip

type Storage

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