Documentation
¶
Index ¶
- func ConfigureXrootdMonitoringDir() error
- func LaunchBrokerListener(ctx context.Context, egrp *errgroup.Group) (err error)
- func LaunchOriginFileTestMaintenance(ctx context.Context)
- func PeriodicSelfTest(ctx context.Context) error
- func RegisterOriginAPI(router *gin.Engine, ctx context.Context, egrp *errgroup.Group) error
- func RegisterOriginWebAPI(engine *gin.Engine)
- type OriginServer
- func (server *OriginServer) CreateAdvertisement(name string, originUrlStr string, originWebUrl string) (*server_structs.OriginAdvertiseV2, error)
- func (server *OriginServer) GetAuthorizedPrefixes() ([]string, error)
- func (server *OriginServer) GetNamespaceAdsFromDirector() error
- func (server *OriginServer) GetPids() (pids []int)
- func (server *OriginServer) GetServerType() config.ServerType
- func (server *OriginServer) SetPids(pids []int)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigureXrootdMonitoringDir ¶
func ConfigureXrootdMonitoringDir() error
Configure XrootD directory for both self-based and director-based file transfer tests
func LaunchBrokerListener ¶
Launch goroutines that continuously poll the broker
func LaunchOriginFileTestMaintenance ¶
Remove tmp files under ${Origin_RunLocation}/export/pelican/monitoring from diector-based/self tests. There could be dangling files due to error in testing
func PeriodicSelfTest ¶
Start self-test monitoring of the origin. This will upload, download, and delete a generated filename every 15 seconds to the local origin. On failure, it will set the xrootd component's status to critical.
func RegisterOriginAPI ¶
Configure API endpoints for origin that are not tied to UI
func RegisterOriginWebAPI ¶
Types ¶
type OriginServer ¶
type OriginServer struct {
server_structs.NamespaceHolder
// contains filtered or unexported fields
}
func (*OriginServer) CreateAdvertisement ¶
func (server *OriginServer) CreateAdvertisement(name string, originUrlStr string, originWebUrl string) (*server_structs.OriginAdvertiseV2, error)
func (*OriginServer) GetAuthorizedPrefixes ¶
func (server *OriginServer) GetAuthorizedPrefixes() ([]string, error)
Return a list of paths where the origin's issuer is authoritative.
Used to calculate the base_paths in the scitokens.cfg, for eaxmple
func (*OriginServer) GetNamespaceAdsFromDirector ¶
func (server *OriginServer) GetNamespaceAdsFromDirector() error
func (*OriginServer) GetPids ¶
func (server *OriginServer) GetPids() (pids []int)
func (*OriginServer) GetServerType ¶
func (server *OriginServer) GetServerType() config.ServerType
func (*OriginServer) SetPids ¶
func (server *OriginServer) SetPids(pids []int)
Source Files
Click to show internal directories.
Click to hide internal directories.