Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
ScicatUrl string `yaml:"scicatUrl"`
Facilities []FacilityConfig `yaml:"facilities"`
Port uint `yaml:"port"`
Task TaskConfig `yaml:"task,omitempty"`
}
func ReadConfigFromBytes ¶
func (*Config) GetGlobusScopes ¶
Get a list of all globus scopes for all facilities
type FacilityConfig ¶
type FacilityConfig struct {
Name string `yaml:"name"`
Collection string `yaml:"collection"`
Scopes []string `yaml:"scopes,omitempty"`
AccessPath string `yaml:"accessPath,omitempty"`
AccessValue string `yaml:"accessValue,omitempty"`
Direction FacilityDirection `yaml:"direction,omitempty"`
SourcePath string `yaml:"sourcePath,omitempty"`
DestinationPath string `yaml:"destinationPath,omitempty"`
}
func NewFacilityConfig ¶
func NewFacilityConfig() *FacilityConfig
Construct a FacilityConfig with default values
func (*FacilityConfig) Merge ¶
func (base *FacilityConfig) Merge(overrides *FacilityConfig) *FacilityConfig
Modify a config by overridding any non-zero fields specified in the argument
type FacilityDirection ¶
type FacilityDirection string
const ( DirectionSource FacilityDirection = "SRC" DirectionDestination FacilityDirection = "DST" DirectionBoth FacilityDirection = "BOTH" )
type TaskConfig ¶
type TaskConfig struct {
MaxConcurrency int `yaml:"maxConcurrency,omitempty"`
QueueSize int `yaml:"queueSize,omitempty"`
PollInterval uint `yaml:"pollInterval,omitempty"`
}
func (*TaskConfig) Merge ¶
func (conf *TaskConfig) Merge(overrides *TaskConfig) *TaskConfig
Modify a TaskConfig by overridding any non-zero fields specified in the argument
Click to show internal directories.
Click to hide internal directories.