Index

_

__aenter__() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) __aexit__() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) __aiter__() (kelvin.application.scheduler.Scheduler method) (kelvin.application.timer.Timer method) __call__() (kelvin.application.client.CallbackSlot method) __init__() (kelvin.application.KelvinStream method) (kelvin.application.stream.KelvinStream method) (kelvin.message.Message method) (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.ConstantWave method) (kelvin.testing.CSVSource method) (kelvin.testing.DataFrameSource method) (kelvin.testing.DataSource method) (kelvin.testing.in_memory_stream.InMemoryStream method) (kelvin.testing.KelvinAppTest method) (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) (kelvin.testing.NoiseWave method) (kelvin.testing.RampWave method) (kelvin.testing.RandomSource method) (kelvin.testing.SineWave method) (kelvin.testing.sources.base.DataSource method) (kelvin.testing.sources.csv_source.CSVSource method) (kelvin.testing.sources.CSVSource method) (kelvin.testing.sources.dataframe_source.DataFrameSource method) (kelvin.testing.sources.DataFrameSource method) (kelvin.testing.sources.DataSource method) (kelvin.testing.sources.random_source.RandomSource method) (kelvin.testing.sources.RandomSource method) (kelvin.testing.sources.synthetic.ConstantWave method) (kelvin.testing.sources.synthetic.NoiseWave method) (kelvin.testing.sources.synthetic.RampWave method) (kelvin.testing.sources.synthetic.SineWave method) (kelvin.testing.sources.synthetic.SquareWave method) (kelvin.testing.sources.synthetic.SyntheticSource method) (kelvin.testing.sources.SyntheticSource method) (kelvin.testing.sources.TabularSource method) (kelvin.testing.SquareWave method) (kelvin.testing.SyntheticSource method) (kelvin.testing.TabularSource method)

__new__() (kelvin.message.Message static method) __repr__() (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) _config (kelvin.application.KelvinStream attribute) (kelvin.application.stream.KelvinStream attribute) _reader (kelvin.application.KelvinStream attribute) (kelvin.application.stream.KelvinStream attribute) _writer (kelvin.application.KelvinStream attribute) (kelvin.application.stream.KelvinStream attribute)

A

access (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) (kelvin.config.appyaml.MetricMap attribute) action_id (kelvin.message.CustomActionResult attribute) actions (kelvin.message.Recommendation attribute) add_asset() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_assets() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_control_change_input() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_control_change_output() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_custom_action() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_custom_action_input() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_custom_action_output() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_custom_actions() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_datastream() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_datastreams() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_extra_assets() (kelvin.publisher.server.PublishServer method) add_input() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_input_cc_output() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_input_output_cc() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_output() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) add_source() (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) advance_time() (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) after (kelvin.message.ControlAck attribute) allowed_assets (kelvin.publisher.server.PublishServer attribute) allowed_resources (kelvin.config.manifest.DeploymentFlags attribute) api (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) api_permissions (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.manifest.DefaultsDefinition attribute) (kelvin.config.smart_app.SmartAppConfig attribute) app (kelvin.config.appyaml.AppYaml attribute) (kelvin.config.common.AppTypes attribute) (kelvin.config.manifest.DefaultsDefinition attribute) (kelvin.config.smart_app.DatastreamMapping attribute) (kelvin.testing.app_test.KelvinAppTest attribute) (kelvin.testing.app_test.KelvinAppTest property) (kelvin.testing.KelvinAppTest attribute) (kelvin.testing.KelvinAppTest property)

app_config (kelvin.publisher.server.PublishServer attribute) (kelvin.publisher.simulator.Simulator attribute) app_configuration (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) app_yaml (kelvin.publisher.simulator.Simulator attribute) AppBaseConfig (class in kelvin.config.common) AppBridge (class in kelvin.config.appyaml) AppConfig (class in kelvin.config.appyaml) AppConfigObj (class in kelvin.config.parser) AppDefaults (class in kelvin.config.manifest) AppDocker (class in kelvin.config.appyaml) AppIO (class in kelvin.application.client) (class in kelvin.publisher.server) AppKelvin (class in kelvin.config.appyaml) applied (kelvin.message.StateEnum attribute) AppManifest (class in kelvin.config.manifest) AppParameter (class in kelvin.message) AppParameters (class in kelvin.message) AppTypes (class in kelvin.config.common) AppYaml (class in kelvin.config.appyaml) AppYamlInfo (class in kelvin.config.appyaml) asset (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) (kelvin.publisher.main.AssetParameterOverride attribute) (kelvin.publisher.server.AppIO attribute) (kelvin.testing.DataSource property) (kelvin.testing.sources.base.DataSource property) (kelvin.testing.sources.DataSource property) asset_equals() (in module kelvin.application.filters) asset_name (kelvin.config.appyaml.MetricMap attribute) asset_names (kelvin.config.appyaml.MetricInfo attribute) asset_params (kelvin.publisher.server.PublishServer attribute) asset_type_name (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) asset_type_title (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) AssetDataMessage (class in kelvin.message) AssetDataQualityMessage (class in kelvin.message) AssetDataStreamDataQualityMessage (class in kelvin.message) AssetInfo (class in kelvin.application) (class in kelvin.application.client) AssetParameter (class in kelvin.message) AssetParameterOverride (class in kelvin.publisher.main) AssetParameters (class in kelvin.message) assets (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) (kelvin.config.appyaml.AppKelvin attribute) (kelvin.publisher.simulator.Simulator attribute) AssetsEntry (class in kelvin.config.appyaml) auto_accepted (kelvin.message.Recommendation attribute)

B

BaseTimeWindow (class in kelvin.application.window) BaseWindow (class in kelvin.application.window) before (kelvin.message.ControlAck attribute) Boolean (class in kelvin.message) boolean (kelvin.config.common.PrimitiveTypes attribute) BooleanParameter (class in kelvin.message) both (kelvin.config.manifest.DynamicIoOwnership attribute) (kelvin.config.manifest.DynamicIoType attribute)

bridge (kelvin.config.appyaml.AppConfig attribute) (kelvin.config.common.AppTypes attribute) bridge_app_yaml_to_runtime() (kelvin.publisher.server.PublishServer method) build() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) build_config_message() (kelvin.publisher.server.PublishServer method) build_cron_expressions() (in module kelvin.application.scheduler)

C

CallbackSlot (class in kelvin.application.client) category (kelvin.config.common.AppBaseConfig attribute) clear() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) ClickUnion (class in kelvin.publisher.main) clock (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) (kelvin.testing.app_test.KelvinAppTest attribute) (kelvin.testing.app_test.KelvinAppTest property) (kelvin.testing.KelvinAppTest attribute) (kelvin.testing.KelvinAppTest property) cluster (kelvin.config.manifest.DeploymentTargetDefaults attribute) ClusterDefinition (class in kelvin.config.manifest) comment (kelvin.message.AppParameter attribute) components (kelvin.message.KMessageType attribute) confidence (kelvin.message.Recommendation attribute) config (kelvin.config.parser.AppConfigObj attribute) config_received (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) ConfigBaseModel (class in kelvin.config.common) ConfigError configuration (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) (kelvin.config.appyaml.AppBridge attribute) (kelvin.config.appyaml.AppKelvin attribute) (kelvin.config.appyaml.MetricMap attribute) (kelvin.config.exporter.DeploymentDefaults attribute) (kelvin.config.exporter.RuntimeUpdateConfig attribute) (kelvin.config.exporter.SchemasConfig attribute) (kelvin.config.external.DeploymentDefaults attribute) (kelvin.config.external.RuntimeUpdateConfig attribute) (kelvin.config.external.SchemasConfig attribute) (kelvin.config.importer.DeploymentDefaults attribute) (kelvin.config.importer.RuntimeUpdateConfig attribute) (kelvin.config.importer.SchemasConfig attribute) (kelvin.config.manifest.AppDefaults attribute) (kelvin.config.manifest.RuntimeUpdateFlags attribute) (kelvin.config.manifest.SchemasDefinition attribute) (kelvin.config.smart_app.DeploymentDefaults attribute) (kelvin.config.smart_app.RuntimeUpdateConfig attribute) (kelvin.config.smart_app.SchemasConfig attribute) ConfigurationError, [1] configure_logger() (in module kelvin.logs) connect() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.application.KelvinStream method) (kelvin.application.stream.KelvinStream method) (kelvin.application.stream.StreamInterface method) (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.in_memory_stream.InMemoryStream method) (kelvin.testing.KelvinAppTest method)

connection (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) ConstantWave (class in kelvin.testing) (class in kelvin.testing.sources.synthetic) contexts (kelvin.message.DataTag attribute) control (kelvin.config.importer.ImporterIO attribute) (kelvin.config.manifest.DynamicIoType attribute) control_change (kelvin.config.appyaml.Metric attribute) control_change_id (kelvin.message.ControlChange attribute) (kelvin.message.RecommendationControlChange attribute) control_changes (kelvin.config.smart_app.SmartAppConfig attribute) (kelvin.message.Recommendation attribute) (kelvin.message.RecommendationActions attribute) ControlAck (class in kelvin.message) ControlChange (class in kelvin.message) ControlChangeAck (class in kelvin.message) ControlChangeAckPayload (class in kelvin.message) ControlChangeMsg (class in kelvin.message) ControlChangePayload (class in kelvin.message) ControlChangeQueueing (class in kelvin.message) ControlChangeStatus (class in kelvin.message) convert() (kelvin.publisher.main.ClickUnion method) convert_exporter_to_manifest() (in module kelvin.config.exporter) convert_external_to_manifest() (in module kelvin.config.external) convert_importer_to_manifest() (in module kelvin.config.importer) convert_smart_app_to_manifest() (in module kelvin.config.smart_app) coro() (in module kelvin.publisher.main) cron_expressions (kelvin.application.scheduler.Scheduler attribute) CSV_ASSET_KEYS (kelvin.publisher.csv_publisher.CSVPublisher attribute) CSVPublisher (class in kelvin.publisher.csv_publisher) CSVSource (class in kelvin.testing) (class in kelvin.testing.sources) (class in kelvin.testing.sources.csv_source) current_value (kelvin.publisher.simulator.Simulator attribute) custom_action_id (kelvin.message.CustomAction attribute) custom_actions (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.manifest.AppManifest attribute) (kelvin.config.smart_app.SmartAppConfig attribute) (kelvin.message.RecommendationActions attribute) custom_identifier (kelvin.message.Recommendation attribute) CustomAction (class in kelvin.message) CustomActionDef (class in kelvin.config.common) CustomActionMsg (class in kelvin.message) CustomActionResult (class in kelvin.message) CustomActionResultMsg (class in kelvin.message) CustomActionsIO (class in kelvin.config.common) CustomActionWay (class in kelvin.config.manifest) CYCLE_TIMEOUT_S (kelvin.publisher.server.PublishServer attribute)

D

data (kelvin.config.manifest.DynamicIoType attribute) data_quality (kelvin.config.manifest.AppManifest attribute) (kelvin.config.smart_app.SmartAppConfig attribute) data_streams (kelvin.config.smart_app.DataQualityConfig attribute) (kelvin.config.smart_app.SmartAppConfig attribute) data_tags (kelvin.config.manifest.AppManifest attribute) (kelvin.config.smart_app.SmartAppConfig attribute) data_type (kelvin.config.appyaml.Metric attribute) (kelvin.config.appyaml.MetricMap attribute) (kelvin.config.appyaml.ParameterDefinition attribute) (kelvin.config.manifest.IODefinition attribute) (kelvin.config.manifest.ManifCustomDataQuality attribute) (kelvin.config.manifest.ParamDefinition attribute) (kelvin.config.smart_app.DataQualityConfig attribute) (kelvin.config.smart_app.IOConfig attribute) (kelvin.config.smart_app.SmartAppParams attribute) (kelvin.publisher.server.AppIO attribute) data_types (kelvin.config.exporter.ExporterIO attribute) (kelvin.config.importer.ImporterIO attribute) (kelvin.config.manifest.DynamicIODefinition attribute) DataFrameSource (class in kelvin.testing) (class in kelvin.testing.sources) (class in kelvin.testing.sources.dataframe_source) DataGenerator (class in kelvin.publisher) (class in kelvin.publisher.server) DataIo (class in kelvin.config.smart_app) DataQualityConfig (class in kelvin.config.smart_app) DataQualityIO (class in kelvin.config.smart_app) DataSource (class in kelvin.testing) (class in kelvin.testing.sources) (class in kelvin.testing.sources.base) Datastream (class in kelvin.application) (class in kelvin.application.client) datastream (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) (kelvin.config.manifest.IODatastreamMapping attribute) (kelvin.config.smart_app.DatastreamMapping attribute) datastream_mapping (kelvin.config.smart_app.DeploymentDefaults attribute) DatastreamMapping (class in kelvin.config.smart_app) datastreams (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) (kelvin.config.manifest.ManifCustomDataQuality attribute) DataTag (class in kelvin.message) DataTagMsg (class in kelvin.message)

DataTagsIO (class in kelvin.config.smart_app) DataTagWay (class in kelvin.config.manifest) decode() (kelvin.message.Message class method) default (kelvin.config.appyaml.ParameterDefinition attribute) (kelvin.config.manifest.ParamDefinition attribute) defaults (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.manifest.AppManifest attribute) (kelvin.config.smart_app.SmartAppConfig attribute) DefaultsDefinition (class in kelvin.config.manifest) deployment (kelvin.config.manifest.DefaultsDefinition attribute) (kelvin.config.manifest.Flags attribute) deployment_type (kelvin.config.manifest.DeploymentDefaults attribute) DeploymentDefaults (class in kelvin.config.exporter) (class in kelvin.config.external) (class in kelvin.config.importer) (class in kelvin.config.manifest) (class in kelvin.config.smart_app) DeploymentFlags (class in kelvin.config.manifest) DeploymentTargetDefaults (class in kelvin.config.manifest) DeploymentType (class in kelvin.config.manifest) description (kelvin.config.appyaml.AppYamlInfo attribute) (kelvin.config.common.AppBaseConfig attribute) (kelvin.message.CustomAction attribute) (kelvin.message.DataTag attribute) (kelvin.message.Recommendation attribute) dict() (kelvin.message.Message method) disconnect() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.application.KelvinStream method) (kelvin.application.stream.KelvinStream method) (kelvin.application.stream.StreamInterface method) (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.in_memory_stream.InMemoryStream method) (kelvin.testing.KelvinAppTest method) docker (kelvin.config.appyaml.AppConfig attribute) (kelvin.config.common.AppTypes attribute) DQWay (class in kelvin.config.manifest) drain_outputs() (kelvin.testing.in_memory_stream.InMemoryStream method) dynamic_io (kelvin.config.manifest.AppManifest attribute) DynamicIODataTypes (class in kelvin.config.manifest) DynamicIODefinition (class in kelvin.config.manifest) DynamicIoOwnership (class in kelvin.config.manifest) DynamicIoType (class in kelvin.config.manifest)

E

enable_runtime_update (kelvin.config.exporter.ExporterFlags attribute) (kelvin.config.external.ExternalFlags attribute) (kelvin.config.importer.ImporterFlags attribute) (kelvin.config.manifest.Flags attribute) (kelvin.config.smart_app.SmartAppFlags attribute) encode() (kelvin.message.KMessageType method) (kelvin.message.Message method) end_date (kelvin.message.DataTag attribute) ENQUEUE (kelvin.message.ControlChangeQueueing attribute) environment (kelvin.config.appyaml.AppYaml attribute) EnvironmentConfig (class in kelvin.config.appyaml) evidences (kelvin.message.Recommendation attribute) expiration_date (kelvin.message.ControlChange attribute) (kelvin.message.ControlChangePayload attribute) (kelvin.message.CustomAction attribute) (kelvin.message.Recommendation attribute) (kelvin.message.RecommendationControlChange attribute)

expiration_delta (kelvin.message.ControlChange attribute) (kelvin.message.RecommendationControlChange attribute) exporter (kelvin.config.common.AppTypes attribute) exporter_io (kelvin.config.exporter.ExporterConfig attribute) ExporterConfig (class in kelvin.config.exporter) ExporterFlags (class in kelvin.config.exporter) ExporterIO (class in kelvin.config.exporter) ExternalConfig (class in kelvin.config.external) ExternalFlags (class in kelvin.config.external)

F

failed (kelvin.message.StateEnum attribute) filter() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) Flags (class in kelvin.config.manifest) flags (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.manifest.AppManifest attribute) (kelvin.config.smart_app.SmartAppConfig attribute) flatten() (in module kelvin.message.utils) flatten_dict() (in module kelvin.publisher.server) from_app_yaml() (kelvin.testing.manifest.ManifestBuilder class method) (kelvin.testing.ManifestBuilder class method) from_dict() (kelvin.testing.manifest.ManifestBuilder class method) (kelvin.testing.ManifestBuilder class method)

from_krn() (kelvin.message.KMessageType class method) (kelvin.message.KMessageTypeControl class method) (kelvin.message.KMessageTypeControlStatus class method) (kelvin.message.KMessageTypeDataTag class method) (kelvin.message.KMessageTypePrimitive class method) (kelvin.message.KMessageTypeRecommendation class method) from_message() (kelvin.message.ControlChange class method) (kelvin.message.CustomAction class method) (kelvin.message.CustomActionResult class method) (kelvin.message.DataTag class method) from_rfc3339_timestamp() (in module kelvin.message.utils) from_string() (kelvin.message.KMessageType class method) from_value (kelvin.message.ControlChange attribute)

G

generate() (kelvin.testing.DataSource method) (kelvin.testing.RandomSource method) (kelvin.testing.sources.base.DataSource method) (kelvin.testing.sources.DataSource method) (kelvin.testing.sources.random_source.RandomSource method) (kelvin.testing.sources.RandomSource method) (kelvin.testing.sources.synthetic.SyntheticSource method) (kelvin.testing.sources.SyntheticSource method) (kelvin.testing.sources.TabularSource method) (kelvin.testing.SyntheticSource method) (kelvin.testing.TabularSource method)

generate_random_value() (kelvin.publisher.simulator.Simulator method) get_df() (kelvin.application.window.BaseWindow method) get_field_value() (kelvin.config.appconfig.KelvinYamlConfigSettingsSource method)

H

handle_generator() (kelvin.publisher.server.PublishServer method) handle_read() (kelvin.publisher.server.PublishServer method) handle_write() (kelvin.publisher.server.PublishServer method)

hopping_window() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) HoppingWindow (class in kelvin.application.window)

I

icd (kelvin.message.KMessageTypePrimitive attribute) id (kelvin.message.Message attribute) IMMEDIATE (kelvin.message.ControlChangeQueueing attribute) importer (kelvin.config.common.AppTypes attribute) importer_io (kelvin.config.importer.ImporterConfig attribute) ImporterConfig (class in kelvin.config.importer) ImporterFlags (class in kelvin.config.importer) ImporterIO (class in kelvin.config.importer) info (kelvin.config.appyaml.AppYaml attribute) initialize_api_client() (in module kelvin.application.api_client) inject() (kelvin.testing.in_memory_stream.InMemoryStream method) inject_test_config() (in module kelvin.publisher.server) InMemoryStream (class in kelvin.testing.in_memory_stream) input (kelvin.config.manifest.DataTagWay attribute) (kelvin.config.manifest.DQWay attribute) (kelvin.config.manifest.IOWay attribute) (kelvin.message.WayEnum attribute) input_ca (kelvin.config.manifest.CustomActionWay attribute) input_cc (kelvin.config.manifest.IOWay attribute) (kelvin.message.WayEnum attribute) input_cc_output (kelvin.config.manifest.IOWay attribute) (kelvin.message.WayEnum attribute) input_equals() (in module kelvin.application.filters) input_output_cc (kelvin.config.manifest.IOWay attribute) (kelvin.message.WayEnum attribute) input_queue_size() (kelvin.testing.in_memory_stream.InMemoryStream method) inputs (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) (kelvin.config.appyaml.AppKelvin attribute) (kelvin.config.common.CustomActionsIO attribute) (kelvin.config.smart_app.DataIo attribute) (kelvin.config.smart_app.DataQualityIO attribute) (kelvin.config.smart_app.DataTagsIO attribute) (kelvin.testing.app_test.KelvinAppTest attribute) (kelvin.testing.app_test.KelvinAppTest property) (kelvin.testing.KelvinAppTest attribute) (kelvin.testing.KelvinAppTest property) interval (kelvin.application.scheduler.Scheduler attribute) (kelvin.application.timer.Timer attribute) (kelvin.testing.DataSource property) (kelvin.testing.sources.base.DataSource property) (kelvin.testing.sources.DataSource property)

invalid_yaml_error() (in module kelvin.config.parser) invoke() (kelvin.application.client.CallbackSlot method) io (kelvin.config.manifest.AppManifest attribute) (kelvin.config.manifest.IODatastreamMapping attribute) io_configuration (kelvin.config.exporter.SchemasConfig attribute) (kelvin.config.importer.SchemasConfig attribute) io_configurations (kelvin.config.manifest.SchemasDefinition attribute) io_datastream_mapping (kelvin.config.manifest.AppDefaults attribute) io_name (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) io_schema (kelvin.config.manifest.IOSchema attribute) IOConfig (class in kelvin.config.smart_app) IODatastreamMapping (class in kelvin.config.manifest) IODefinition (class in kelvin.config.manifest) IOSchema (class in kelvin.config.manifest) IOWay (class in kelvin.config.manifest) ip (kelvin.application.stream.KelvinStreamConfig attribute), [1] (kelvin.publisher.server.KelvinPublisherConfig attribute) is_asset_data_message() (in module kelvin.application.filters) is_asset_data_quality_message() (in module kelvin.application.filters) is_asset_data_stream_quality_message() (in module kelvin.application.filters) is_connected (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) (kelvin.testing.app_test.KelvinAppTest attribute) (kelvin.testing.app_test.KelvinAppTest property) (kelvin.testing.in_memory_stream.InMemoryStream property) (kelvin.testing.KelvinAppTest attribute) (kelvin.testing.KelvinAppTest property) is_control_status_message() (in module kelvin.application.filters) is_custom_action() (in module kelvin.application.filters) is_data_message() (in module kelvin.application.filters) is_data_quality_message() (in module kelvin.application.filters) is_data_tag() (in module kelvin.application.filters) is_legacy() (kelvin.config.parser.AppConfigObj method) iso_datetime_processor() (in module kelvin.logs) iteration (kelvin.application.scheduler.Scheduler attribute) (kelvin.application.timer.Timer attribute)

J

json() (kelvin.message.Message method)

K

kelvin (kelvin.config.appyaml.AppConfig attribute) kelvin.application module kelvin.application.api_client module kelvin.application.client module kelvin.application.config module kelvin.application.filters module kelvin.application.scheduler module kelvin.application.stream module kelvin.application.timer module kelvin.application.version module kelvin.application.window module kelvin.config module kelvin.config.appconfig module kelvin.config.appyaml module kelvin.config.common module kelvin.config.exporter module kelvin.config.external module kelvin.config.importer module kelvin.config.manifest module kelvin.config.parser module kelvin.config.smart_app module kelvin.logs module kelvin.message module kelvin.message.utils module kelvin.publisher module

kelvin.publisher.csv_publisher module kelvin.publisher.main module kelvin.publisher.server module kelvin.publisher.simulator module kelvin.testing module kelvin.testing.app_test module kelvin.testing.in_memory_stream module kelvin.testing.manifest module kelvin.testing.sources module kelvin.testing.sources.base module kelvin.testing.sources.csv_source module kelvin.testing.sources.dataframe_source module kelvin.testing.sources.random_source module kelvin.testing.sources.synthetic module kelvin_app (kelvin.config.common.AppTypes attribute) kelvin_app_yaml_to_runtime() (kelvin.publisher.server.PublishServer method) KelvinApp (class in kelvin.application) (class in kelvin.application.client) KelvinAppConfig (class in kelvin.config.appconfig) KelvinAppTest (class in kelvin.testing) (class in kelvin.testing.app_test) KelvinPublisherConfig (class in kelvin.publisher.server) KelvinStream (class in kelvin.application) (class in kelvin.application.stream) KelvinStreamConfig (class in kelvin.application.stream) KelvinYamlConfigSettingsSource (class in kelvin.config.appconfig) KMessageType (class in kelvin.message) KMessageTypeControl (class in kelvin.message) KMessageTypeControlStatus (class in kelvin.message) KMessageTypeData (class in kelvin.message) KMessageTypeDataTag (class in kelvin.message) KMessageTypeParameter (class in kelvin.message) KMessageTypePrimitive (class in kelvin.message) KMessageTypeRecommendation (class in kelvin.message)

L

legacy_docker (kelvin.config.common.AppTypes attribute) limit (kelvin.application.stream.KelvinStreamConfig attribute), [1] load_class() (in module kelvin.publisher.main)

load_kelvin_yaml_config() (in module kelvin.config.appconfig) log_message() (in module kelvin.publisher.server) loop (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property)

M

main() (in module kelvin.publisher.main) ManifCustomAction (class in kelvin.config.manifest) ManifCustomDataQuality (class in kelvin.config.manifest) ManifDataTag (class in kelvin.config.manifest) manifest (kelvin.testing.app_test.KelvinAppTest attribute) (kelvin.testing.app_test.KelvinAppTest property) (kelvin.testing.KelvinAppTest attribute) (kelvin.testing.KelvinAppTest property) ManifestBuilder (class in kelvin.testing) (class in kelvin.testing.manifest) max_drift (kelvin.application.timer.Timer attribute) max_interval (kelvin.application.timer.Timer attribute) max_resources (kelvin.config.manifest.DeploymentDefaults attribute) Message (class in kelvin.message) message (kelvin.message.ControlAck attribute) (kelvin.message.CustomActionResult attribute) MESSAGE_TYPES_ (kelvin.message.Message attribute) MessageData (class in kelvin.publisher) (class in kelvin.publisher.server) metadata (kelvin.message.ControlAck attribute) (kelvin.message.CustomActionResult attribute) (kelvin.message.Recommendation attribute) Metric (class in kelvin.config.appyaml) MetricInfo (class in kelvin.config.appyaml) MetricInput (class in kelvin.config.appyaml) MetricMap (class in kelvin.config.appyaml) MetricOutput (class in kelvin.config.appyaml) metrics_map (kelvin.config.appyaml.AppBridge attribute) min_interval (kelvin.application.timer.Timer attribute) missing_config_error() (in module kelvin.config.parser) model_config (kelvin.application.stream.KelvinStreamConfig attribute) (kelvin.config.appconfig.KelvinAppConfig attribute) (kelvin.config.appyaml.AppBridge attribute) (kelvin.config.appyaml.AppConfig attribute) (kelvin.config.appyaml.AppDocker attribute) (kelvin.config.appyaml.AppKelvin attribute) (kelvin.config.appyaml.AppYaml attribute) (kelvin.config.appyaml.AppYamlInfo attribute) (kelvin.config.appyaml.AssetsEntry attribute) (kelvin.config.appyaml.EnvironmentConfig attribute) (kelvin.config.appyaml.Metric attribute) (kelvin.config.appyaml.MetricInfo attribute) (kelvin.config.appyaml.MetricInput attribute) (kelvin.config.appyaml.MetricMap attribute) (kelvin.config.appyaml.MetricOutput attribute) (kelvin.config.appyaml.ParameterDefinition attribute) (kelvin.config.appyaml.SystemConfig attribute) (kelvin.config.common.AppBaseConfig attribute) (kelvin.config.common.ConfigBaseModel attribute) (kelvin.config.common.CustomActionDef attribute) (kelvin.config.common.CustomActionsIO attribute) (kelvin.config.exporter.DeploymentDefaults attribute) (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.exporter.ExporterFlags attribute) (kelvin.config.exporter.ExporterIO attribute) (kelvin.config.exporter.RuntimeUpdateConfig attribute) (kelvin.config.exporter.SchemasConfig attribute) (kelvin.config.external.DeploymentDefaults attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.external.ExternalFlags attribute) (kelvin.config.external.RuntimeUpdateConfig attribute) (kelvin.config.external.SchemasConfig attribute) (kelvin.config.importer.DeploymentDefaults attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.importer.ImporterFlags attribute) (kelvin.config.importer.ImporterIO attribute) (kelvin.config.importer.RuntimeUpdateConfig attribute) (kelvin.config.importer.SchemasConfig attribute) (kelvin.config.manifest.AppDefaults attribute) (kelvin.config.manifest.AppManifest attribute) (kelvin.config.manifest.ClusterDefinition attribute) (kelvin.config.manifest.DefaultsDefinition attribute) (kelvin.config.manifest.DeploymentDefaults attribute) (kelvin.config.manifest.DeploymentFlags attribute) (kelvin.config.manifest.DeploymentTargetDefaults attribute) (kelvin.config.manifest.DynamicIODataTypes attribute) (kelvin.config.manifest.DynamicIODefinition attribute) (kelvin.config.manifest.Flags attribute) (kelvin.config.manifest.IODatastreamMapping attribute) (kelvin.config.manifest.IODefinition attribute) (kelvin.config.manifest.IOSchema attribute) (kelvin.config.manifest.ManifCustomAction attribute) (kelvin.config.manifest.ManifCustomDataQuality attribute) (kelvin.config.manifest.ManifDataTag attribute) (kelvin.config.manifest.ParamDefinition attribute) (kelvin.config.manifest.RuntimeUpdateFlags attribute) (kelvin.config.manifest.SchemasDefinition attribute) (kelvin.config.smart_app.DataIo attribute) (kelvin.config.smart_app.DataQualityConfig attribute) (kelvin.config.smart_app.DataQualityIO attribute) (kelvin.config.smart_app.DatastreamMapping attribute) (kelvin.config.smart_app.DataTagsIO attribute) (kelvin.config.smart_app.DeploymentDefaults attribute) (kelvin.config.smart_app.IOConfig attribute) (kelvin.config.smart_app.RuntimeUpdateConfig attribute) (kelvin.config.smart_app.SchemasConfig attribute) (kelvin.config.smart_app.SmartAppConfig attribute) (kelvin.config.smart_app.SmartAppFlags attribute) (kelvin.config.smart_app.SmartAppParams attribute) (kelvin.message.AssetDataMessage attribute) (kelvin.message.AssetDataQualityMessage attribute) (kelvin.message.AssetDataStreamDataQualityMessage attribute) (kelvin.message.Boolean attribute) (kelvin.message.BooleanParameter attribute) (kelvin.message.ControlChangeAck attribute) (kelvin.message.ControlChangeAckPayload attribute) (kelvin.message.ControlChangeMsg attribute) (kelvin.message.ControlChangePayload attribute) (kelvin.message.ControlChangeStatus attribute) (kelvin.message.CustomActionMsg attribute) (kelvin.message.CustomActionResultMsg attribute) (kelvin.message.DataTagMsg attribute) (kelvin.message.Message attribute) (kelvin.message.Number attribute) (kelvin.message.NumberParameter attribute) (kelvin.message.RecommendationActions attribute) (kelvin.message.RecommendationControlChange attribute) (kelvin.message.RecommendationMsg attribute) (kelvin.message.RuntimeManifest attribute) (kelvin.message.String attribute) (kelvin.message.StringParameter attribute) (kelvin.message.ValuePoint attribute) (kelvin.publisher.server.KelvinPublisherConfig attribute)

model_dump() (kelvin.config.common.ConfigBaseModel method) module kelvin.application kelvin.application.api_client kelvin.application.client kelvin.application.config kelvin.application.filters kelvin.application.scheduler kelvin.application.stream kelvin.application.timer kelvin.application.version kelvin.application.window kelvin.config kelvin.config.appconfig kelvin.config.appyaml kelvin.config.common kelvin.config.exporter kelvin.config.external kelvin.config.importer kelvin.config.manifest kelvin.config.parser kelvin.config.smart_app kelvin.logs kelvin.message kelvin.message.utils kelvin.publisher kelvin.publisher.csv_publisher kelvin.publisher.main kelvin.publisher.server kelvin.publisher.simulator kelvin.testing kelvin.testing.app_test kelvin.testing.in_memory_stream kelvin.testing.manifest kelvin.testing.sources kelvin.testing.sources.base kelvin.testing.sources.csv_source kelvin.testing.sources.dataframe_source kelvin.testing.sources.random_source kelvin.testing.sources.synthetic msg_is_control_change() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) msg_type (kelvin.message.KMessageType attribute) msg_type_param_dict() (in module kelvin.publisher.server)

N

name (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) (kelvin.application.client.Datastream attribute) (kelvin.application.Datastream attribute) (kelvin.application.scheduler.Scheduler attribute) (kelvin.application.timer.Timer attribute) (kelvin.config.appyaml.AppYamlInfo attribute) (kelvin.config.appyaml.AssetsEntry attribute) (kelvin.config.appyaml.Metric attribute) (kelvin.config.appyaml.MetricMap attribute) (kelvin.config.appyaml.ParameterDefinition attribute) (kelvin.config.common.AppBaseConfig attribute) (kelvin.config.exporter.ExporterIO attribute) (kelvin.config.importer.ImporterIO attribute) (kelvin.config.manifest.ClusterDefinition attribute) (kelvin.config.manifest.DynamicIODataTypes attribute) (kelvin.config.manifest.IODefinition attribute) (kelvin.config.manifest.ManifCustomDataQuality attribute) (kelvin.config.manifest.ParamDefinition attribute) (kelvin.config.parser.AppConfigObj attribute) (kelvin.config.smart_app.DataQualityConfig attribute) (kelvin.config.smart_app.IOConfig attribute) (kelvin.config.smart_app.SmartAppParams attribute) (kelvin.publisher.main.ClickUnion attribute) (kelvin.publisher.server.AppIO attribute)

new_client() (kelvin.publisher.server.PublishServer method) NEXT (kelvin.message.ControlChangeQueueing attribute) NODE (kelvin.publisher.server.PublishServer attribute) node_name (kelvin.config.appyaml.EnvironmentConfig attribute) NoiseWave (class in kelvin.testing) (class in kelvin.testing.sources.synthetic) Number (class in kelvin.message) number (kelvin.config.common.PrimitiveTypes attribute) NumberParameter (class in kelvin.message)

O

object (kelvin.config.common.PrimitiveTypes attribute) on_app_configuration (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_asset_change (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_asset_input (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_connect (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_control_change (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_control_status (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_custom_action (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_data_tag (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_disconnect (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) on_message (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) (kelvin.publisher.server.PublishServer attribute)

output (kelvin.config.manifest.DataTagWay attribute) (kelvin.config.manifest.DQWay attribute) (kelvin.config.manifest.IOWay attribute) (kelvin.message.WayEnum attribute) output_ca (kelvin.config.manifest.CustomActionWay attribute) output_cc (kelvin.config.manifest.IOWay attribute) (kelvin.message.WayEnum attribute) outputs (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) (kelvin.config.appyaml.AppKelvin attribute) (kelvin.config.common.CustomActionsIO attribute) (kelvin.config.smart_app.DataIo attribute) (kelvin.config.smart_app.DataQualityIO attribute) (kelvin.config.smart_app.DataTagsIO attribute) (kelvin.testing.app_test.KelvinAppTest attribute) (kelvin.testing.app_test.KelvinAppTest property) (kelvin.testing.KelvinAppTest attribute) (kelvin.testing.KelvinAppTest property) overlaps (kelvin.application.timer.Timer attribute) owned (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) (kelvin.config.manifest.DynamicIoOwnership attribute) ownership (kelvin.config.manifest.DynamicIODefinition attribute)

P

param (kelvin.publisher.main.AssetParameterOverride attribute) ParamDefinition (class in kelvin.config.manifest) ParameterDefinition (class in kelvin.config.appyaml) parameters (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) (kelvin.config.appyaml.AppKelvin attribute) (kelvin.config.appyaml.AssetsEntry attribute) (kelvin.config.manifest.AppManifest attribute) (kelvin.config.manifest.SchemasDefinition attribute) (kelvin.config.smart_app.DeploymentDefaults attribute) (kelvin.config.smart_app.RuntimeUpdateConfig attribute) (kelvin.config.smart_app.SchemasConfig attribute) (kelvin.config.smart_app.SmartAppConfig attribute) (kelvin.message.AppParameters attribute) params_override (kelvin.publisher.simulator.Simulator attribute) parse_assets_csv() (in module kelvin.publisher.server) parse_at() (in module kelvin.application.scheduler) parse_config() (in module kelvin.config.parser) parse_config_file() (in module kelvin.config.parser) parse_timestamp() (kelvin.publisher.csv_publisher.CSVPublisher method) payload (kelvin.message.Boolean attribute) (kelvin.message.BooleanParameter attribute) (kelvin.message.ControlChange attribute) (kelvin.message.ControlChangeAck attribute) (kelvin.message.ControlChangeMsg attribute) (kelvin.message.ControlChangeStatus attribute) (kelvin.message.CustomAction attribute) (kelvin.message.CustomActionMsg attribute) (kelvin.message.CustomActionResultMsg attribute) (kelvin.message.DataTagMsg attribute) (kelvin.message.Message attribute) (kelvin.message.Number attribute) (kelvin.message.NumberParameter attribute) (kelvin.message.RecommendationMsg attribute) (kelvin.message.RuntimeManifest attribute) (kelvin.message.String attribute) (kelvin.message.StringParameter attribute)

pop_asset_key() (kelvin.publisher.csv_publisher.CSVPublisher method) port (kelvin.application.stream.KelvinStreamConfig attribute), [1] primitive (kelvin.message.KMessageTypePrimitive attribute) PrimitiveTypes (class in kelvin.config.common) privileged (kelvin.config.appyaml.SystemConfig attribute) processed (kelvin.message.StateEnum attribute) properties (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) (kelvin.config.appyaml.AssetsEntry attribute) publish() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) publish_batch() (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) publish_data() (kelvin.publisher.server.PublishServer method) publish_unsafe() (kelvin.publisher.server.PublishServer method) PublisherError PublishServer (class in kelvin.publisher.server)

Q

quantize_time() (in module kelvin.application.window)

queueing (kelvin.message.ControlChange attribute)

R

RampWave (class in kelvin.testing) (class in kelvin.testing.sources.synthetic) rand_max (kelvin.publisher.simulator.Simulator attribute) rand_min (kelvin.publisher.simulator.Simulator attribute) random (kelvin.publisher.simulator.Simulator attribute) RandomSource (class in kelvin.testing) (class in kelvin.testing.sources) (class in kelvin.testing.sources.random_source) read() (kelvin.application.KelvinStream method) (kelvin.application.stream.KelvinStream method) (kelvin.application.stream.StreamInterface method) (kelvin.testing.in_memory_stream.InMemoryStream method) read_schema_file() (in module kelvin.config.common) ready (kelvin.message.StateEnum attribute) Recommendation (class in kelvin.message) RecommendationActions (class in kelvin.message) RecommendationControlChange (class in kelvin.message) RecommendationMsg (class in kelvin.message) rejected (kelvin.message.StateEnum attribute) remote (kelvin.config.manifest.DynamicIoOwnership attribute) reset() (kelvin.testing.in_memory_stream.InMemoryStream method) resolve_schema_path() (in module kelvin.config.common) resource (kelvin.message.AppParameter attribute) (kelvin.message.AppParameters attribute) (kelvin.message.AssetDataMessage attribute), [1] (kelvin.message.AssetDataQualityMessage attribute), [1] (kelvin.message.AssetDataStreamDataQualityMessage attribute), [1] (kelvin.message.ControlAck attribute) (kelvin.message.ControlChange attribute) (kelvin.message.CustomAction attribute) (kelvin.message.CustomActionResult attribute) (kelvin.message.DataTag attribute) (kelvin.message.DataTagMsg attribute) (kelvin.message.Message attribute) (kelvin.message.Recommendation attribute) (kelvin.message.RecommendationControlChange attribute) (kelvin.publisher.MessageData attribute) (kelvin.publisher.server.MessageData attribute)

resource_equals() (in module kelvin.application.filters) resource_parameters (kelvin.config.manifest.RuntimeUpdateFlags attribute) resource_properties (kelvin.config.manifest.RuntimeUpdateFlags attribute) (kelvin.config.smart_app.RuntimeUpdateConfig attribute) ResourceDatastream (class in kelvin.application) (class in kelvin.application.client) resources_required (kelvin.config.exporter.ExporterFlags attribute) (kelvin.config.importer.ImporterFlags attribute) (kelvin.config.manifest.Flags attribute) result() (kelvin.message.CustomAction method) retries (kelvin.message.ControlChange attribute) (kelvin.message.ControlChangePayload attribute) (kelvin.message.RecommendationControlChange attribute) retry_interval (kelvin.message.ControlChange attribute) rolling_window() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) RollingWindow (class in kelvin.application.window) round_nearest_time() (in module kelvin.application.window) run() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.publisher.csv_publisher.CSVPublisher method) (kelvin.publisher.DataGenerator method) (kelvin.publisher.server.DataGenerator method) (kelvin.publisher.simulator.Simulator method) run_forever() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) run_until_idle() (kelvin.testing.app_test.KelvinAppTest method) (kelvin.testing.KelvinAppTest method) runtime_from_app_manifest() (kelvin.publisher.server.PublishServer method) RuntimeManifest (class in kelvin.message) RuntimeUpdateConfig (class in kelvin.config.exporter) (class in kelvin.config.external) (class in kelvin.config.importer) (class in kelvin.config.smart_app) RuntimeUpdateFlags (class in kelvin.config.manifest)

S

schedule() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) Scheduler (class in kelvin.application.scheduler) schemas (kelvin.config.manifest.AppManifest attribute) SchemasConfig (class in kelvin.config.exporter) (class in kelvin.config.external) (class in kelvin.config.importer) (class in kelvin.config.smart_app) SchemasDefinition (class in kelvin.config.manifest) sent (kelvin.message.StateEnum attribute) serialize_timestamp() (kelvin.message.ControlChangePayload method) (kelvin.message.Message method) (kelvin.message.RecommendationControlChange method) (kelvin.message.ValuePoint method) set() (kelvin.application.client.CallbackSlot method) set_configuration() (kelvin.testing.manifest.ManifestBuilder method) (kelvin.testing.ManifestBuilder method) settings_customise_sources() (kelvin.config.appconfig.KelvinAppConfig class method) Simulator (class in kelvin.publisher.simulator) SineWave (class in kelvin.testing) (class in kelvin.testing.sources.synthetic) SmartAppConfig (class in kelvin.config.smart_app) SmartAppFlags (class in kelvin.config.smart_app) SmartAppParams (class in kelvin.config.smart_app) source (kelvin.message.Message attribute) (kelvin.message.ValuePoint attribute) sources (kelvin.config.appyaml.MetricInput attribute) spec_version (kelvin.config.appyaml.AppYaml attribute) (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.manifest.Flags attribute) (kelvin.config.smart_app.SmartAppConfig attribute)

SquareWave (class in kelvin.testing) (class in kelvin.testing.sources.synthetic) staged_instant_apply (kelvin.config.manifest.DeploymentType attribute) staged_only (kelvin.config.manifest.DeploymentType attribute) standard (kelvin.config.manifest.DeploymentType attribute) start_date (kelvin.message.DataTag attribute) start_server() (kelvin.publisher.server.PublishServer method) state (kelvin.message.ControlAck attribute) (kelvin.message.RecommendationControlChange attribute) StateEnum (class in kelvin.message) storage (kelvin.config.manifest.IODefinition attribute) stream() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) (kelvin.application.window.BaseTimeWindow method) (kelvin.application.window.RollingWindow method) stream_filter() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) StreamInterface (class in kelvin.application.stream) String (class in kelvin.message) string (kelvin.config.common.PrimitiveTypes attribute) string_to_strict_type() (in module kelvin.publisher.server) StringParameter (class in kelvin.message) success (kelvin.message.CustomActionResult attribute) SyntheticSource (class in kelvin.testing) (class in kelvin.testing.sources) (class in kelvin.testing.sources.synthetic) system (kelvin.config.appyaml.AppYaml attribute) (kelvin.config.exporter.DeploymentDefaults attribute) (kelvin.config.external.DeploymentDefaults attribute) (kelvin.config.importer.DeploymentDefaults attribute) (kelvin.config.manifest.DefaultsDefinition attribute) (kelvin.config.smart_app.DeploymentDefaults attribute) SystemConfig (class in kelvin.config.appyaml)

T

TabularSource (class in kelvin.testing) (class in kelvin.testing.sources) tag_name (kelvin.config.manifest.ManifDataTag attribute) (kelvin.message.DataTag attribute) target (kelvin.config.manifest.DeploymentDefaults attribute) targets (kelvin.config.appyaml.MetricOutput attribute) task() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) tasks (kelvin.application.client.KelvinApp property) (kelvin.application.KelvinApp property) timeout (kelvin.message.ControlChange attribute) Timer (class in kelvin.application.timer) timer() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) timestamp (kelvin.message.Message attribute) (kelvin.message.ValuePoint attribute) (kelvin.publisher.MessageData attribute) (kelvin.publisher.server.MessageData attribute) title (kelvin.application.AssetInfo attribute) (kelvin.application.client.AssetInfo attribute) (kelvin.config.appyaml.AppYamlInfo attribute) (kelvin.config.common.AppBaseConfig attribute) (kelvin.config.manifest.ParamDefinition attribute) (kelvin.message.CustomAction attribute) to_app_manifest() (kelvin.config.parser.AppConfigObj method) to_manifest() (kelvin.config.appyaml.AppYaml method) (kelvin.config.exporter.ExporterConfig method) (kelvin.config.external.ExternalConfig method) (kelvin.config.importer.ImporterConfig method) (kelvin.config.smart_app.SmartAppConfig method) to_message() (kelvin.message.AppParameters method) (kelvin.message.ControlAck method) (kelvin.message.ControlChange method) (kelvin.message.CustomAction method) (kelvin.message.CustomActionResult method) (kelvin.message.DataTag method) (kelvin.message.Recommendation method) to_rfc3339_timestamp() (in module kelvin.message.utils) trace_id (kelvin.message.ControlChange attribute) (kelvin.message.CustomAction attribute) (kelvin.message.CustomActionResult attribute) (kelvin.message.Message attribute) (kelvin.message.Recommendation attribute) (kelvin.message.RecommendationControlChange attribute) tumbling_window() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) TumblingWindow (class in kelvin.application.window) type (kelvin.application.client.Datastream attribute) (kelvin.application.Datastream attribute) (kelvin.config.appyaml.AppConfig attribute) (kelvin.config.common.AppBaseConfig attribute) (kelvin.config.common.CustomActionDef attribute) (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.manifest.DeploymentTargetDefaults attribute) (kelvin.config.manifest.DynamicIODefinition attribute) (kelvin.config.manifest.ManifCustomAction attribute) (kelvin.config.parser.AppConfigObj attribute) (kelvin.config.smart_app.SmartAppConfig attribute) (kelvin.message.AssetDataMessage attribute), [1] (kelvin.message.AssetDataQualityMessage attribute), [1] (kelvin.message.AssetDataStreamDataQualityMessage attribute), [1] (kelvin.message.Boolean attribute) (kelvin.message.BooleanParameter attribute) (kelvin.message.ControlChangeAck attribute) (kelvin.message.ControlChangeMsg attribute) (kelvin.message.ControlChangeStatus attribute) (kelvin.message.CustomAction attribute) (kelvin.message.CustomActionMsg attribute) (kelvin.message.CustomActionResultMsg attribute) (kelvin.message.DataTagMsg attribute) (kelvin.message.Message attribute) (kelvin.message.Number attribute) (kelvin.message.NumberParameter attribute) (kelvin.message.Recommendation attribute) (kelvin.message.RecommendationMsg attribute) (kelvin.message.RuntimeManifest attribute) (kelvin.message.String attribute) (kelvin.message.StringParameter attribute)

TYPE_ (kelvin.message.Boolean attribute) (kelvin.message.BooleanParameter attribute) (kelvin.message.ControlChangeAck attribute) (kelvin.message.ControlChangeMsg attribute) (kelvin.message.ControlChangeStatus attribute) (kelvin.message.CustomActionMsg attribute) (kelvin.message.CustomActionResultMsg attribute) (kelvin.message.DataTagMsg attribute) (kelvin.message.Message attribute) (kelvin.message.Number attribute) (kelvin.message.NumberParameter attribute) (kelvin.message.RecommendationMsg attribute) (kelvin.message.RuntimeManifest attribute) (kelvin.message.String attribute) (kelvin.message.StringParameter attribute) type_name (kelvin.config.manifest.DynamicIODefinition attribute) (kelvin.config.manifest.IOSchema attribute) tz (kelvin.application.scheduler.Scheduler attribute)

U

ui_schemas (kelvin.config.exporter.ExporterConfig attribute) (kelvin.config.external.ExternalConfig attribute) (kelvin.config.importer.ImporterConfig attribute) (kelvin.config.smart_app.SmartAppConfig attribute) UnavailableApiClientError

unit (kelvin.application.client.Datastream attribute) (kelvin.application.Datastream attribute) (kelvin.config.manifest.IODefinition attribute) (kelvin.config.smart_app.IOConfig attribute) update_param() (kelvin.publisher.server.PublishServer method)

V

validate() (kelvin.message.KMessageType class method) value (kelvin.message.AppParameter attribute) (kelvin.message.ValuePoint attribute) (kelvin.publisher.main.AssetParameterOverride attribute) (kelvin.publisher.MessageData attribute) (kelvin.publisher.server.MessageData attribute) value_at() (kelvin.testing.ConstantWave method) (kelvin.testing.NoiseWave method) (kelvin.testing.RampWave method) (kelvin.testing.SineWave method) (kelvin.testing.sources.synthetic.ConstantWave method) (kelvin.testing.sources.synthetic.NoiseWave method) (kelvin.testing.sources.synthetic.RampWave method) (kelvin.testing.sources.synthetic.SineWave method) (kelvin.testing.sources.synthetic.SquareWave method) (kelvin.testing.sources.synthetic.WavePattern method) (kelvin.testing.SquareWave method)

ValuePoint (class in kelvin.message) version (kelvin.config.appyaml.AppYamlInfo attribute) (kelvin.config.common.AppBaseConfig attribute) (kelvin.config.parser.AppConfigObj attribute)

W

wait_for_inputs() (kelvin.testing.in_memory_stream.InMemoryStream method) wait_for_processing() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) wait_for_tasks() (kelvin.application.client.KelvinApp method) (kelvin.application.KelvinApp method) WavePattern (class in kelvin.testing.sources.synthetic) way (kelvin.application.client.ResourceDatastream attribute) (kelvin.application.ResourceDatastream attribute) (kelvin.config.manifest.IODefinition attribute) (kelvin.config.manifest.ManifCustomAction attribute) (kelvin.config.manifest.ManifCustomDataQuality attribute) (kelvin.config.manifest.ManifDataTag attribute) WayEnum (class in kelvin.message) with_asset() (kelvin.testing.DataSource method) (kelvin.testing.sources.base.DataSource method) (kelvin.testing.sources.DataSource method) with_column_mapping() (kelvin.testing.sources.TabularSource method) (kelvin.testing.TabularSource method) with_columns() (kelvin.testing.sources.TabularSource method) (kelvin.testing.TabularSource method)

with_count() (kelvin.testing.RandomSource method) (kelvin.testing.sources.random_source.RandomSource method) (kelvin.testing.sources.RandomSource method) with_datastreams() (kelvin.testing.RandomSource method) (kelvin.testing.sources.random_source.RandomSource method) (kelvin.testing.sources.RandomSource method) with_range() (kelvin.testing.RandomSource method) (kelvin.testing.sources.random_source.RandomSource method) (kelvin.testing.sources.RandomSource method) with_timing() (kelvin.testing.DataSource method) (kelvin.testing.sources.base.DataSource method) (kelvin.testing.sources.DataSource method) WORKLOAD (kelvin.publisher.server.PublishServer attribute) workload_name (kelvin.config.appyaml.EnvironmentConfig attribute) write() (kelvin.application.KelvinStream method) (kelvin.application.stream.KelvinStream method) (kelvin.application.stream.StreamInterface method) (kelvin.testing.in_memory_stream.InMemoryStream method) write_queue (kelvin.publisher.server.PublishServer attribute)

Y

YAML_PATHS (kelvin.config.appconfig.KelvinAppConfig attribute)