GetDefaultRoleFileTemplateValueFromExtras retrieves the default role file template value from the worker.Config, and asserts that it is a string.

GetFERRYUIDData queries FERRY for user information.

GetFileCopierOptionsFromExtras retrieves the file copier options value from the worker.Config, and asserts that it is a string.

GetKerberosTicketsWorker is a worker that listens on chans.GetServiceConfigChan(), and for the received worker.Config objects, obtains kerberos tickets from the configured kerberos principals.

GetPingOptionsFromExtras retrieves the ping options slice from the worker.Config, and asserts that it is a []string.

GetSSHOptionsFromExtras retrieves the SSH options slice from the worker.Config, and asserts that it is a []string.

GetVaultTokenStoreHoldoff returns the value from the Config for the Extras VaultTokenStoreHoldoff key.

NewChannelsForWorkers returns a ChannelsForWorkers that is initialized and ready to pass to workers and listen on.

NewConfig takes the config information from the global file and creates an *Config object To create functional options, simply define functions that operate on an *Config.

PingAggregatorWorker is a worker that listens on chans.GetServiceConfigChan(), and for the received worker.Config objects, concurrently pings all of the Config's destination nodes.

PushTokenWorker is a worker that listens on chans.GetServiceConfigChan(), and for the received worker.Config objects, pushes vault tokens to all the configured destination nodes.

SetCommandEnvironment is a helper func that takes a variadic of func(*environment.CommandEnvironment) and returns a func(*Config) that sets the Config's embedded CommandEnvironment by running the funcs passed in the variadic.

SetSupportedExtrasKeyValue returns a func(*Config) that sets the value for the given supportedExtraskey in the Extras map.

SetVaultTokenStoreHoldoff returns a func(*Config) that sets the VaultTokenStoreHoldoff Extras key of the *Config to true.

SetWorkerRetryValue is a function that sets the retry value for a specific worker type.

StoreAndGetTokenInteractiveWorker is a worker that listens on chans.GetServiceConfigChan(), and for the received worker.Config objects, stores a refresh token in the configured vault and obtains vault and bearer tokens.

StoreAndGetTokensForSchedds will store a refresh token on the condor-configured vault server, obtain vault and bearer tokens for a service using HTCondor executables, and store the vault token in the condor_credd that resides on each schedd that is passed in with the schedds slice.

StoreAndGetTokenWorker is a worker that listens on chans.GetServiceConfigChan(), and for the received worker.Config objects, stores a refresh token in the configured vault and obtains vault and bearer tokens.

DefaultRoleFileTemplate is a key to store the value of the default role file template in the Config.Extras map.

Config is a mega struct containing all the information the workers need to have or pass onto lower level funcs.

UIDEntryFromFerry is an entry that represents data returned from the FERRY getUserInfo API.

SuccessReporter is an interface to objects that report success or failures from various workers.

ConfigOption is a functional option that should be used as an argument to NewConfig to set various fields of the Config For example: f := func(c *Config) error { c.Account = "myaccount" return nil } g := func(c *Config) error { c.DesiredUID = 42 return nil } config := NewConfig("myservice", f, g).

Worker is a function, controlled by a context, that performs some operations based on the values passed through the channelGroup.GetServiceConfigChan() channel.

WorkerType is a type that represents the kind of worker being referenced.