director

package

Go to main page

Versions in this module

v1

v1.0.5

Dec 28, 2023

retracted

v1.0.4

Dec 28, 2023

retracted

Changes in this version

+ func ConfigTTLCache(ctx context.Context, wg *sync.WaitGroup)

+ func CreateDirectorSDToken() (string, error)

+ func CreateDirectorScrapeToken() (string, error)

+ func CreateDirectorTestReportToken(originWebUrl string) (string, error)

+ func DiscoverOrigins(ctx *gin.Context)

+ func GetRegistryIssuerURL(prefix string) (string, error)

+ func ListNamespaces(ctx *gin.Context)

+ func PeriodicDirectorTest(ctx context.Context, originAd ServerAd)

+ func RegisterCache(ctx *gin.Context)

+ func RegisterDirectorAuth(router *gin.RouterGroup)

+ func RegisterDirectorWebAPI(router *gin.RouterGroup)

+ func VerifyDirectorSDToken(strToken string) (bool, error)

+ func VerifyDirectorTestReportToken(strToken string) (bool, error)

+ type DirectorTest struct

+ Message string

+ Status string

+ Timestamp int64

+ type DiscoveryResponse struct

+ Issuer string

+ JwksUri string

type NamespaceAd

+ DirlistHost string

+ func ListNamespacesFromOrigins() []NamespaceAd

+ type NamespaceCache interface

+ Get func(ctx context.Context, u string) (jwk.Set, error)

+ Register func(u string, options ...jwk.RegisterOption) error

type OriginAdvertise

+ WebURL string

+ type PromDiscoveryItem struct

+ Labels map[string]string

+ Targets []string

type ServerAd

+ WebURL url.URL

+ func ListServerAds(serverTypes []ServerType) []ServerAd

v1.0.3

Sep 7, 2023

retracted

v1.0.0

Sep 7, 2023

retracted

Changes in this version

+ func AdvertiseOSDF() error

+ func CreateAdvertiseToken(namespace string) (string, error)

+ func DownloadDB(localFile string) error

+ func GetAdsForPath(reqPath string) (originNamespace NamespaceAd, originAds []ServerAd, cacheAds []ServerAd)

+ func GetIssuerURL(prefix string) (string, error)

+ func GetLatLong(addr netip.Addr) (lat float64, long float64, err error)

+ func InitializeDB()

+ func PeriodicCacheReload()

+ func PeriodicMaxMindReload()

+ func RecordAd(ad ServerAd, namespaceAds *[]NamespaceAd)

+ func RedirectToCache(ginCtx *gin.Context)

+ func RedirectToOrigin(ginCtx *gin.Context)

+ func RegisterDirector(router *gin.RouterGroup)

+ func RegisterOrigin(ctx *gin.Context)

+ func ShortcutMiddleware(defaultResponse string) gin.HandlerFunc

+ func UpdateLatLong(ad *ServerAd) error

+ func VerifyAdvertiseToken(token, namespace string) (bool, error)

+ type CredentialGeneration struct

+ BasePath string

+ Issuer string

+ MaxScopeDepth int

+ Strategy string

+ VaultIssuer string

+ VaultServer string

+ type Namespace struct

+ Caches []Server

+ CredentialGeneration CredentialGeneration

+ DirlistHost string

+ Origins []Server

+ Path string

+ ReadHTTPS bool

+ UseTokenOnRead bool

+ WritebackHost string

+ type NamespaceAd struct

+ BasePath string

+ Issuer url.URL

+ MaxScopeDepth uint

+ Path string

+ RequireToken bool

+ Strategy StrategyType

+ VaultServer string

+ type NamespaceJSON struct

+ Caches []Server

+ Namespaces []Namespace

+ type OriginAdvertise struct

+ Name string

+ Namespaces []NamespaceAd

+ URL string

+ type Server struct

+ AuthEndpoint string

+ Endpoint string

+ Resource string

+ type ServerAd struct

+ AuthURL url.URL

+ Latitude float64

+ Longitude float64

+ Name string

+ Type ServerType

+ URL url.URL

+ func SortServers(addr netip.Addr, ads []ServerAd) ([]ServerAd, error)

+ type ServerType string

+ const CacheType

+ const OriginType

+ type StrategyType string

+ const OAuthStrategy

+ const VaultStrategy

+ type SwapMap struct

+ Distance float64

+ Index int

+ type SwapMaps []SwapMap

+ func (me SwapMaps) Len() int

+ func (me SwapMaps) Less(left, right int) bool

+ func (me SwapMaps) Swap(left, right int)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL