def register()

in elastic/logs/track.py [0:0]

• 33 lines of code
• 1 McCabe index (conditional complexity)

def register(registry):
    registry.register_param_source("initial-indices-source", InitialIndicesParamSource)
    registry.register_param_source("add-track-path", parameter_sources.add_track_path)

    registry.register_param_source("component-template-source", ComponentTemplateParamSource)
    registry.register_param_source("composable-template-source", ComposableTemplateParamSource)

    registry.register_param_source("datastream-source", DataStreamParamSource)
    registry.register_param_source("create-datastream-source", CreateDataStreamParamSource)
    registry.register_runner("create-datastream", datastream.create, async_runner=True)
    registry.register_runner("compression-statistics", datastream.compression_stats, async_runner=True)
    registry.register_runner("check-datastream", datastream.check_health, async_runner=True)
    registry.register_runner("rollover-datastream", datastream.rollover, async_runner=True)
    registry.register_runner("set-shards-datastream", datastream.shards, async_runner=True)
    registry.register_runner("delete-remote-datastream", datastream.DeleteRemoteDataStream(), async_runner=True)
    registry.register_runner("update-custom-templates", update_custom_templates, async_runner=True)
    registry.register_runner("validate-package-assets", validate_package_assets, async_runner=True)

    registry.register_param_source("processed-source", ProcessedCorpusParamSource)

    registry.register_runner("create-ilm", create_ilm, async_runner=True)
    registry.register_runner("create-slm", create_slm, async_runner=True)

    registry.register_runner("create-pipeline", create_pipeline, async_runner=True)

    registry.register_runner("raw-bulk", RawBulkIndex(), async_runner=True)

    registry.register_runner("mount-searchable-snapshot", snapshot.mount, async_runner=True)

    registry.register_scheduler("workflow-scheduler", WorkflowScheduler)
    registry.register_scheduler("timestamp-throttler", TimestampThrottler)

    registry.register_param_source("workflow-selector", WorkflowSelectorParamSource)

    registry.register_param_source("track-params-source", TrackParamSource)

    registry.register_track_processor(TrackIdGenerator())
    registry.register_track_processor(data_generator.DataGenerator())

    registry.register_runner("configure-remote-clusters", ConfigureRemoteClusters(), async_runner=True)
    registry.register_runner("configure-ccr", ConfigureCrossClusterReplication(), async_runner=True)
    registry.register_runner("multi-cluster-wrapper", MultiClusterWrapper(), async_runner=True)

    registry.register_runner("setup-local-remote", setup_local_remote, async_runner=True)

    registry.register_runner("start-reindex-data-stream", StartReindexDataStream(), async_runner=True)
    registry.register_runner("wait-for-reindex-data-stream", WaitForReindexDataStream(), async_runner=True)