Index

_

__call__() (ska_sdp_config.operations.arbitrary.ArbitraryOperations method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method)

A

arbitrary (ska_sdp_config.config.Transaction attribute) arbitrary_check_is_alive() (ska_sdp_config.operations.component.ComponentOperations method) arbitrary_create_is_alive() (ska_sdp_config.operations.component.ComponentOperations method) ArbitraryOperations (class in ska_sdp_config.operations.arbitrary)

args (ska_sdp_config.entity.deployment.Deployment attribute) attribute_name (ska_sdp_config.entity.common.TangoAttributeUrl property) attribute_url (ska_sdp_config.entity.flow.TangoAttribute attribute) attributes (ska_sdp_config.entity.flow.TangoAttributeMap attribute)

B

backend (ska_sdp_config.config.Config property) BeamId (in module ska_sdp_config.entity.flow)

beams (ska_sdp_config.entity.eb.ExecutionBlock attribute) bootstrap_address (ska_sdp_config.entity.common.KafkaUrl property)

C

channel_map (ska_sdp_config.entity.flow.SpeadStream attribute) ChannelAddressMapping (in module ska_sdp_config.entity.flow) ChannelMap (in module ska_sdp_config.entity.flow) channels (ska_sdp_config.entity.eb.ExecutionBlock attribute) client_lease (ska_sdp_config.config.Config property) close() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.config.Config method) CollectiveEntityOperations (class in ska_sdp_config.operations.entity_operations) command (ska_sdp_config.entity.owner.Owner attribute) commit() (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.etcd3_watcher.Etcd3TransactionWatcher method) (ska_sdp_config.backend.memory.MemoryTransaction method) ComparisonMode (class in ska_sdp_config.operations.entity_operations) component (ska_sdp_config.config.Transaction attribute)

ComponentOperations (class in ska_sdp_config.operations.component) Config (class in ska_sdp_config.config) ConfigCollision ConfigVanished context (ska_sdp_config.entity.eb.ExecutionBlock attribute) continuous_mode (ska_sdp_config.entity.flow.SpeadStream attribute) create() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.backend.memory.MemoryTransaction method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.EntityOperations method) (ska_sdp_config.operations.entity_operations.StateOperations method) create_or_update() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.EntityOperations method)

D

data_dir (ska_sdp_config.entity.flow.DataProduct attribute) data_model (ska_sdp_config.entity.flow.Flow attribute) DataProduct (class in ska_sdp_config.entity.flow) DataQueue (class in ska_sdp_config.entity.flow) default_value (ska_sdp_config.entity.flow.TangoAttribute attribute) delete() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.backend.memory.MemoryTransaction method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.EntityOperations method)

dependencies (ska_sdp_config.entity.pb.ProcessingBlock attribute) Deployment (class in ska_sdp_config.entity.deployment) deployment (ska_sdp_config.config.Transaction attribute) DeploymentOperations (class in ska_sdp_config.operations.deployment) depth_of_path() (in module ska_sdp_config.backend.common) device_name (ska_sdp_config.entity.common.TangoAttributeUrl property) device_url (ska_sdp_config.entity.common.TangoAttributeUrl property) Display (class in ska_sdp_config.entity.flow) dtype (ska_sdp_config.entity.flow.TangoAttribute attribute)

E

eb_id (ska_sdp_config.entity.pb.ProcessingBlock attribute) endpoint (ska_sdp_config.entity.flow.Display attribute) EntityOperations (class in ska_sdp_config.operations.entity_operations) EQ (ska_sdp_config.operations.entity_operations.ComparisonMode attribute) Etcd3Backend (class in ska_sdp_config.backend.etcd3) Etcd3Transaction (class in ska_sdp_config.backend.etcd3)

Etcd3TransactionWatcher (class in ska_sdp_config.backend.etcd3_watcher) Etcd3Watcher (class in ska_sdp_config.backend.etcd3_watcher) execution_block (ska_sdp_config.config.Transaction attribute) ExecutionBlock (class in ska_sdp_config.entity.eb) ExecutionBlockOperations (class in ska_sdp_config.operations.execution_block) exists() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.PathOperations method)

F

family_name (ska_sdp_config.entity.common.TangoAttributeUrl property) fields (ska_sdp_config.entity.eb.ExecutionBlock attribute) Flow (class in ska_sdp_config.entity.flow) flow (ska_sdp_config.config.Transaction attribute)

Flow.Key (class in ska_sdp_config.entity.flow) FlowOperations (class in ska_sdp_config.operations.flow) FlowSource (class in ska_sdp_config.entity.flow) format (ska_sdp_config.entity.flow.DataQueue attribute) function (ska_sdp_config.entity.flow.FlowSource attribute)

G

get() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.etcd3_watcher.Etcd3TransactionWatcher method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.backend.memory.MemoryTransaction method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.EntityOperations method) (ska_sdp_config.operations.entity_operations.OwnershipOperations method) (ska_sdp_config.operations.entity_operations.PathOperations method)

H

HAS_OWNER (ska_sdp_config.operations.component.ComponentOperations attribute) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations attribute) (ska_sdp_config.operations.flow.FlowOperations attribute) (ska_sdp_config.operations.processing_block.ProcessingBlockOperations attribute) HAS_STATE (ska_sdp_config.operations.deployment.DeploymentOperations attribute) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations attribute) (ska_sdp_config.operations.execution_block.ExecutionBlockOperations attribute) (ska_sdp_config.operations.flow.FlowOperations attribute) (ska_sdp_config.operations.processing_block.ProcessingBlockOperations attribute)

host (ska_sdp_config.entity.flow.DataQueue attribute) host_path (ska_sdp_config.entity.flow.SharedMem attribute) hostname (ska_sdp_config.entity.owner.Owner attribute)

I

image (ska_sdp_config.entity.script.Script attribute) impl (ska_sdp_config.entity.flow.SharedMem attribute) index_by_key_parts() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) instances (ska_sdp_config.entity.flow.SpeadStream property) InvalidKey

is_alive() (ska_sdp_config.config.Config method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.OwnedEntityOperationsMixIn method) is_owned() (ska_sdp_config.operations.entity_operations.OwnershipOperations method) is_owned_by_this_process() (ska_sdp_config.operations.entity_operations.OwnershipOperations method)

K

k8s_namespaces (ska_sdp_config.entity.common.PVCPath attribute) k8s_pvc_name (ska_sdp_config.entity.common.PVCPath attribute) KafkaTopicName (in module ska_sdp_config.entity.flow) KafkaUrl (class in ska_sdp_config.entity.common) key (ska_sdp_config.entity.deployment.Deployment attribute) (ska_sdp_config.entity.eb.ExecutionBlock attribute) (ska_sdp_config.entity.flow.Flow attribute) (ska_sdp_config.entity.flow.TelModel attribute) (ska_sdp_config.entity.pb.ProcessingBlock attribute) (ska_sdp_config.entity.script.Script attribute) (ska_sdp_config.operations.entity_operations.EntityOperations property) KEY_PARTS (ska_sdp_config.operations.component.ComponentOperations attribute) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations attribute)

key_parts (ska_sdp_config.operations.entity_operations.EntityOperations property) KEY_PARTS (ska_sdp_config.operations.execution_block.ExecutionBlockOperations attribute) kind (ska_sdp_config.entity.deployment.Deployment attribute) (ska_sdp_config.entity.flow.DataProduct attribute) (ska_sdp_config.entity.flow.DataQueue attribute) (ska_sdp_config.entity.flow.Display attribute) (ska_sdp_config.entity.flow.Flow.Key attribute) (ska_sdp_config.entity.flow.SharedMem attribute) (ska_sdp_config.entity.flow.SpeadStream attribute) (ska_sdp_config.entity.flow.TangoAttribute attribute) (ska_sdp_config.entity.flow.TangoAttributeMap attribute) (ska_sdp_config.entity.flow.TelModel attribute) (ska_sdp_config.entity.pb.PBDependency attribute) (ska_sdp_config.entity.script.Script.Key attribute)

L

lease() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.config.Config method) list_keys() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.etcd3_watcher.Etcd3TransactionWatcher method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.backend.memory.MemoryTransaction method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method)

list_values() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method)

M

max_dim_x (ska_sdp_config.entity.flow.TangoAttribute attribute) max_dim_y (ska_sdp_config.entity.flow.TangoAttribute attribute) max_length (ska_sdp_config.entity.eb.ExecutionBlock attribute) member_name (ska_sdp_config.entity.common.TangoAttributeUrl property) MemoryBackend (class in ska_sdp_config.backend.memory) MemoryTransaction (class in ska_sdp_config.backend.memory) MemoryWatcher (class in ska_sdp_config.backend.memory) MODEL_CLASS (ska_sdp_config.operations.deployment.DeploymentOperations attribute) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations attribute) (ska_sdp_config.operations.entity_operations.EntityOperations attribute) (ska_sdp_config.operations.execution_block.ExecutionBlockOperations attribute) (ska_sdp_config.operations.flow.FlowOperations attribute) (ska_sdp_config.operations.processing_block.ProcessingBlockOperations attribute) (ska_sdp_config.operations.script.ScriptOperations attribute) model_config (ska_sdp_config.entity.common.PVCPath attribute) model_post_init() (ska_sdp_config.entity.flow.Flow method) (ska_sdp_config.entity.flow.TangoAttributeMap method) module ska_sdp_config.backend.common ska_sdp_config.backend.etcd3 ska_sdp_config.backend.etcd3_watcher ska_sdp_config.backend.memory ska_sdp_config.config ska_sdp_config.entity.common ska_sdp_config.entity.deployment ska_sdp_config.entity.eb ska_sdp_config.entity.flow ska_sdp_config.entity.owner ska_sdp_config.entity.pb ska_sdp_config.entity.script ska_sdp_config.operations ska_sdp_config.operations.arbitrary ska_sdp_config.operations.component ska_sdp_config.operations.deployment ska_sdp_config.operations.entity_operations ska_sdp_config.operations.execution_block ska_sdp_config.operations.flow ska_sdp_config.operations.processing_block ska_sdp_config.operations.script

N

name (ska_sdp_config.entity.flow.Flow.Key attribute) (ska_sdp_config.entity.script.Script.Key attribute)

new_execution_block_id() (ska_sdp_config.config.Transaction method) new_processing_block_id() (ska_sdp_config.config.Transaction method)

O

on_commit() (ska_sdp_config.backend.etcd3.Etcd3Transaction method) OwnedEntityOperationsMixIn (class in ska_sdp_config.operations.entity_operations) Owner (class in ska_sdp_config.entity.owner)

ownership (ska_sdp_config.operations.entity_operations.OwnedEntityOperationsMixIn property) ownership() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) OwnershipOperations (class in ska_sdp_config.operations.entity_operations)

P

parameters (ska_sdp_config.entity.flow.FlowSource attribute) (ska_sdp_config.entity.pb.ProcessingBlock attribute) (ska_sdp_config.entity.script.Script attribute) path (ska_sdp_config.entity.common.PVCPath property) (ska_sdp_config.operations.entity_operations.PathOperations property) path() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) PathOperations (class in ska_sdp_config.operations.entity_operations) paths (ska_sdp_config.entity.flow.DataProduct attribute) pb_batch (ska_sdp_config.entity.eb.ExecutionBlock attribute) pb_id (ska_sdp_config.entity.flow.Flow.Key attribute) (ska_sdp_config.entity.pb.PBDependency attribute) pb_realtime (ska_sdp_config.entity.eb.ExecutionBlock attribute) PBDependency (class in ska_sdp_config.entity.pb) pid (ska_sdp_config.entity.owner.Owner attribute) polarisations (ska_sdp_config.entity.eb.ExecutionBlock attribute)

PREFIX (ska_sdp_config.operations.component.ComponentOperations attribute) (ska_sdp_config.operations.deployment.DeploymentOperations attribute) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations attribute) (ska_sdp_config.operations.entity_operations.ComparisonMode attribute) (ska_sdp_config.operations.execution_block.ExecutionBlockOperations attribute) (ska_sdp_config.operations.flow.FlowOperations attribute) (ska_sdp_config.operations.processing_block.ProcessingBlockOperations attribute) (ska_sdp_config.operations.script.ScriptOperations attribute) processing_block (ska_sdp_config.config.Transaction attribute) ProcessingBlock (class in ska_sdp_config.entity.pb) ProcessingBlockOperations (class in ska_sdp_config.operations.processing_block) pvc_data_dir (ska_sdp_config.entity.flow.TelModel attribute) pvc_mount_path (ska_sdp_config.entity.common.PVCPath attribute) pvc_subpath (ska_sdp_config.entity.common.PVCPath attribute) PVCPath (class in ska_sdp_config.entity.common)

Q

query_keys() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method)

query_values() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method)

R

raw (ska_sdp_config.config.Transaction property) receiver_version (ska_sdp_config.entity.flow.SpeadStream attribute) ReceiverId (in module ska_sdp_config.entity.flow) reset() (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.etcd3_watcher.Etcd3TransactionWatcher method) (ska_sdp_config.backend.memory.MemoryTransaction method)

resources (ska_sdp_config.entity.eb.ExecutionBlock attribute) revision (ska_sdp_config.backend.etcd3.Etcd3Transaction property) revoke_lease() (ska_sdp_config.config.Config method)

S

scan_types (ska_sdp_config.entity.eb.ExecutionBlock attribute) ScanTypeId (in module ska_sdp_config.entity.flow) Script (class in ska_sdp_config.entity.script) script (ska_sdp_config.config.Transaction attribute) (ska_sdp_config.entity.pb.ProcessingBlock attribute) Script.Key (class in ska_sdp_config.entity.script) ScriptOperations (class in ska_sdp_config.operations.script) sdp_version (ska_sdp_config.entity.script.Script attribute) select (ska_sdp_config.entity.flow.TangoAttributeMap.DataQuery attribute) self (ska_sdp_config.config.Transaction property) set_alive() (ska_sdp_config.config.Config method) SharedMem (class in ska_sdp_config.entity.flow) sink (ska_sdp_config.entity.flow.Flow attribute) ska_sdp_config.backend.common module ska_sdp_config.backend.etcd3 module ska_sdp_config.backend.etcd3_watcher module ska_sdp_config.backend.memory module ska_sdp_config.config module ska_sdp_config.entity.common module ska_sdp_config.entity.deployment module ska_sdp_config.entity.eb module ska_sdp_config.entity.flow module ska_sdp_config.entity.owner module

ska_sdp_config.entity.pb module ska_sdp_config.entity.script module ska_sdp_config.operations module ska_sdp_config.operations.arbitrary module ska_sdp_config.operations.component module ska_sdp_config.operations.deployment module ska_sdp_config.operations.entity_operations module ska_sdp_config.operations.execution_block module ska_sdp_config.operations.flow module ska_sdp_config.operations.processing_block module ska_sdp_config.operations.script module sources (ska_sdp_config.entity.flow.Flow attribute) SpeadStream (class in ska_sdp_config.entity.flow) state (ska_sdp_config.operations.entity_operations.StatefulEntityOperationsMixIn property) state() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) StatefulEntityOperationsMixIn (class in ska_sdp_config.operations.entity_operations) StateOperations (class in ska_sdp_config.operations.entity_operations) streams (ska_sdp_config.entity.flow.SpeadStream attribute) subarray_id (ska_sdp_config.entity.eb.ExecutionBlock attribute) SUFFIX (ska_sdp_config.operations.entity_operations.ComparisonMode attribute) system (ska_sdp_config.config.Transaction attribute)

T

take() (ska_sdp_config.operations.entity_operations.OwnershipOperations method) take_ownership_if_not_alive() (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.OwnedEntityOperationsMixIn method) TangoAttribute (class in ska_sdp_config.entity.flow) TangoAttributeMap (class in ska_sdp_config.entity.flow) TangoAttributeMap.DataQuery (class in ska_sdp_config.entity.flow) TangoAttributeUrl (class in ska_sdp_config.entity.common) TelModel (class in ska_sdp_config.entity.flow)

topics (ska_sdp_config.entity.flow.DataQueue attribute) Transaction (class in ska_sdp_config.config) transport_protocol (ska_sdp_config.entity.flow.SpeadStream attribute) trigger() (ska_sdp_config.backend.etcd3_watcher.Etcd3Watcher method) txn() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.etcd3_watcher.Etcd3Watcher method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.backend.memory.MemoryWatcher method) (ska_sdp_config.config.Config method)

U

update() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.etcd3.Etcd3Transaction method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.backend.memory.MemoryTransaction method) (ska_sdp_config.operations.entity_operations.CollectiveEntityOperations method) (ska_sdp_config.operations.entity_operations.EntityOperations method) (ska_sdp_config.operations.entity_operations.StateOperations method)

uri (ska_sdp_config.entity.flow.FlowSource attribute)

V

version (ska_sdp_config.entity.script.Script.Key attribute)

W

watcher() (ska_sdp_config.backend.etcd3.Etcd3Backend method) (ska_sdp_config.backend.memory.MemoryBackend method) (ska_sdp_config.config.Config method)

when (ska_sdp_config.entity.flow.TangoAttributeMap.DataQuery attribute) widget (ska_sdp_config.entity.flow.Display attribute)