cache

package
v0.0.0-...-c116fac Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 /<runLocation>/pelican/monitoring directory to clean up test files

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 string, originUrl string, 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() config.ServerType

func (*CacheServer) SetFilters

func (server *CacheServer) SetFilters()

func (*CacheServer) SetPids

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

Jump to

Keyboard shortcuts

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