cache

Documentation

Index

• func CheckCacheSentinelLocation() error
• func InitSelfTestDir() error
• func LaunchDirectorTestFileCleanup(ctx context.Context)
• func LaunchRequestListener(ctx context.Context, egrp *errgroup.Group) error
• func PeriodicCacheSelfTest(ctx context.Context, ergp *errgroup.Group)
• func RegisterCacheAPI(router *gin.Engine, ctx context.Context, egrp *errgroup.Group)
• type CacheServer
  • func (server *CacheServer) CreateAdvertisement(name, originUrl, originWebUrl string) (*server_structs.OriginAdvertiseV2, error)
  • func (server *CacheServer) GetNamespaceAdsFromDirector() error
  • func (server *CacheServer) GetPids() (pids []int)
  • func (server *CacheServer) GetServerType() server_structs.ServerType
  • func (server *CacheServer) SetFilters()
  • func (server *CacheServer) SetPids(pids []int)

Functions

func CheckCacheSentinelLocation

func CheckCacheSentinelLocation() error

Check for the sentinel file

func InitSelfTestDir

func InitSelfTestDir() error

Add self-test directories to xrootd data location of the cache

func LaunchDirectorTestFileCleanup

func LaunchDirectorTestFileCleanup(ctx context.Context)

Periodically scan the ${Cache.StorageLocation}/pelican/monitoring directory to clean up test files TODO: Director test files should be under /pelican/monitoring/directorTest and the file names should have director-test- as the prefix

func LaunchRequestListener

func LaunchRequestListener(ctx context.Context, egrp *errgroup.Group) error

Launch a goroutine that listens for socket reversal requests from the XRootD daemon

func PeriodicCacheSelfTest

func PeriodicCacheSelfTest(ctx context.Context, ergp *errgroup.Group)

func RegisterCacheAPI

func RegisterCacheAPI(router *gin.Engine, ctx context.Context, egrp *errgroup.Group)

Types

type CacheServer

type CacheServer struct {
	server_structs.NamespaceHolder
	// contains filtered or unexported fields
}

func (*CacheServer) CreateAdvertisement

func (server *CacheServer) CreateAdvertisement(name, originUrl, originWebUrl string) (*server_structs.OriginAdvertiseV2, error)

func (*CacheServer) GetNamespaceAdsFromDirector

func (server *CacheServer) GetNamespaceAdsFromDirector() error

func (*CacheServer) GetPids

func (server *CacheServer) GetPids() (pids []int)

func (*CacheServer) GetServerType

func (server *CacheServer) GetServerType() server_structs.ServerType

func (*CacheServer) SetFilters

func (server *CacheServer) SetFilters()

func (*CacheServer) SetPids

func (server *CacheServer) SetPids(pids []int)