Index

_

__default_args__() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.config.CmdLineParameters method) __eq__() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.config.ClientConfig method) (ska_dlm_client.config.CmdLineParameters method) (ska_dlm_client.registration_processor.Item method) __exit__() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.config.CmdLineParameters method) __format__() (ska_dlm_client.common_types.ItemType method) (ska_dlm_client.common_types.LocationCountry method) (ska_dlm_client.common_types.LocationName method) (ska_dlm_client.common_types.LocationType method) (ska_dlm_client.common_types.StorageInterface method) (ska_dlm_client.common_types.StorageType method) __hash__ (ska_dlm_client.CmdLineParameters attribute) (ska_dlm_client.config.ClientConfig attribute) (ska_dlm_client.config.CmdLineParameters attribute) (ska_dlm_client.registration_processor.Item attribute) __init__() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.config.ClientConfig method) (ska_dlm_client.config.CmdLineParameters method) (ska_dlm_client.registration_processor.Item method) (ska_dlm_client.registration_processor.RegistrationProcessor method) (ska_dlm_client.startup_verification.main.StartupVerification method) __new__() (ska_dlm_client.common_types.ItemType method) (ska_dlm_client.common_types.LocationCountry method) (ska_dlm_client.common_types.LocationName method) (ska_dlm_client.common_types.LocationType method) (ska_dlm_client.common_types.StorageInterface method) (ska_dlm_client.common_types.StorageType method)

__repr__() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.common_types.ItemType method) (ska_dlm_client.common_types.LocationCountry method) (ska_dlm_client.common_types.LocationName method) (ska_dlm_client.common_types.LocationType method) (ska_dlm_client.common_types.StorageInterface method) (ska_dlm_client.common_types.StorageType method) (ska_dlm_client.config.ClientConfig method) (ska_dlm_client.config.CmdLineParameters method) (ska_dlm_client.registration_processor.Item method) __str__() (ska_dlm_client.common_types.ItemType method) (ska_dlm_client.common_types.LocationCountry method) (ska_dlm_client.common_types.LocationName method) (ska_dlm_client.common_types.LocationType method) (ska_dlm_client.common_types.StorageInterface method) (ska_dlm_client.common_types.StorageType method) __weakref__ (ska_dlm_client.CmdLineParameters attribute) (ska_dlm_client.config.ClientConfig attribute) (ska_dlm_client.config.CmdLineParameters attribute) (ska_dlm_client.registration_processor.Item attribute) (ska_dlm_client.registration_processor.RegistrationProcessor attribute) (ska_dlm_client.startup_verification.main.StartupVerification attribute)

A

add() (ska_dlm_client.directory_watcher.directory_watcher_entries.DirectoryWatcherEntries method)

add_path() (ska_dlm_client.registration_processor.RegistrationProcessor method) amain() (in module ska_dlm_client.directory_watcher.main)

C

ClientConfig (class in ska_dlm_client.config) CmdLineParameters (class in ska_dlm_client) (class in ska_dlm_client.config)

Config (in module ska_dlm_client.config) create_directory_watcher() (in module ska_dlm_client.directory_watcher.main) create_parser() (in module ska_dlm_client.register_storage_location.main) create_sdp_migration_dependency() (in module ska_dlm_client.configdb_watcher.configdb_utils)

D

DataclassJSONEncoder (class in ska_dlm_client.directory_watcher.directory_watcher_entries) DataProductStatusWatcher (class in ska_dlm_client.configdb_watcher.configdb_watcher) default() (ska_dlm_client.directory_watcher.directory_watcher_entries.DataclassJSONEncoder method)

directory_contains_metadata_file() (in module ska_dlm_client.registration_processor) DirectoryWatcher (class in ska_dlm_client.directory_watcher.directory_watcher) DirectoryWatcherEntries (class in ska_dlm_client.directory_watcher.directory_watcher_entries) DirectoryWatcherEntry (class in ska_dlm_client.directory_watcher.directory_watcher_entries)

G

get_config() (ska_dlm_client.registration_processor.RegistrationProcessor method) get_or_init_location() (in module ska_dlm_client.register_storage_location.main)

get_or_init_storage() (in module ska_dlm_client.register_storage_location.main) get_pvc_subpath() (in module ska_dlm_client.configdb_watcher.configdb_utils)

I

INotifyDirectoryWatcher (class in ska_dlm_client.directory_watcher.directory_watcher) install_ssh_key() (in module ska_dlm_client.register_storage_location.main)

Item (class in ska_dlm_client.registration_processor) ItemType (class in ska_dlm_client.common_types)

L

LocationCountry (class in ska_dlm_client.common_types) LocationName (class in ska_dlm_client.common_types) LocationType (class in ska_dlm_client.common_types)

log_changes_with_diff() (in module ska_dlm_client.directory_watcher.directory_utils) log_configdb_backend_details() (in module ska_dlm_client.configdb_watcher.configdb_utils) log_flow_dependencies() (in module ska_dlm_client.configdb_watcher.configdb_utils) LStatPollingEmitter (class in ska_dlm_client.directory_watcher.directory_watcher)

M

main() (in module ska_dlm_client.configdb_watcher.main) (in module ska_dlm_client.directory_watcher.main) (in module ska_dlm_client.register_storage_location.main) (in module ska_dlm_client.startup_verification.main) minimal_metadata_generator() (in module ska_dlm_client.minimal_metadata_generator) module ska_dlm_client ska_dlm_client.common_types ska_dlm_client.config ska_dlm_client.configdb_watcher.configdb_utils ska_dlm_client.configdb_watcher.configdb_watcher ska_dlm_client.configdb_watcher.main ska_dlm_client.directory_watcher.config ska_dlm_client.directory_watcher.directory_utils ska_dlm_client.directory_watcher.directory_watcher ska_dlm_client.directory_watcher.directory_watcher_entries ska_dlm_client.directory_watcher.main ska_dlm_client.directory_watcher.watcher_event_handler ska_dlm_client.minimal_metadata_generator ska_dlm_client.register_storage_location.main ska_dlm_client.registration_processor ska_dlm_client.startup_verification.main

monitor_directory_with_watchdog() (in module ska_dlm_client.directory_watcher.directory_utils)

O

on_closed() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method) on_closed_no_write() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method) on_created() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method)

on_deleted() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method) on_modified() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method) on_moved() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method) on_opened() (ska_dlm_client.directory_watcher.watcher_event_handler.WatcherEventHandler method)

P

parse_arguments() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.config.CmdLineParameters method)

PollingDirectoryWatcher (class in ska_dlm_client.directory_watcher.directory_watcher) process_args() (in module ska_dlm_client.configdb_watcher.main) (in module ska_dlm_client.directory_watcher.main)

R

read_from_file() (ska_dlm_client.directory_watcher.directory_watcher_entries.DirectoryWatcherEntries method)

register_data_products_from_watch_directory() (ska_dlm_client.registration_processor.RegistrationProcessor method) RegistrationProcessor (class in ska_dlm_client.registration_processor)

S

save_to_file() (ska_dlm_client.directory_watcher.directory_watcher_entries.DirectoryWatcherEntries method) sdp_to_dlm_ingest_and_migrate() (in module ska_dlm_client.configdb_watcher.main) set_application_ready() (ska_dlm_client.CmdLineParameters method) (ska_dlm_client.config.CmdLineParameters method) set_config() (ska_dlm_client.registration_processor.RegistrationProcessor method) setup_testing() (in module ska_dlm_client.register_storage_location.main) setup_volume() (in module ska_dlm_client.register_storage_location.main) ska_dlm_client module ska_dlm_client.common_types module ska_dlm_client.config module ska_dlm_client.configdb_watcher.configdb_utils module ska_dlm_client.configdb_watcher.configdb_watcher module ska_dlm_client.configdb_watcher.main module ska_dlm_client.directory_watcher.config module

ska_dlm_client.directory_watcher.directory_utils module ska_dlm_client.directory_watcher.directory_watcher module ska_dlm_client.directory_watcher.directory_watcher_entries module ska_dlm_client.directory_watcher.main module ska_dlm_client.directory_watcher.watcher_event_handler module ska_dlm_client.minimal_metadata_generator module ska_dlm_client.register_storage_location.main module ska_dlm_client.registration_processor module ska_dlm_client.startup_verification.main module StartupVerification (class in ska_dlm_client.startup_verification.main) stop() (ska_dlm_client.directory_watcher.directory_watcher.DirectoryWatcher method) StorageInterface (class in ska_dlm_client.common_types) StorageType (class in ska_dlm_client.common_types)

U

update_dependency_state() (in module ska_dlm_client.configdb_watcher.configdb_utils)

V

verify_registration() (ska_dlm_client.startup_verification.main.StartupVerification method)

W

watch() (ska_dlm_client.directory_watcher.directory_watcher.DirectoryWatcher method) (ska_dlm_client.directory_watcher.directory_watcher.INotifyDirectoryWatcher method) (ska_dlm_client.directory_watcher.directory_watcher.PollingDirectoryWatcher method)

watch_dataproduct_status() (in module ska_dlm_client.configdb_watcher.configdb_watcher) WatcherArgs (class in ska_dlm_client.directory_watcher.config) WatcherConfig (class in ska_dlm_client.directory_watcher.config) WatcherEventHandler (class in ska_dlm_client.directory_watcher.watcher_event_handler)