Index

_

__init__ (Affinity attribute) __init__() (Alarm method) (AlarmInfo method) (ClientInfo method) (Config method) (Consumer method) (cpp_instance_class method) (CreateParam method) (DataInfo method) (DeploymentConfig method) (DoubleCounter method) (Element method) (FunctionGroupContext method) (FunctionGroupHandler method) (FunctionGroupMethodProxy method) (FunctionGroupOptions method) (FunctionProxy method) (Gauge method) (GetParam method) (GetParams method) (InstanceCreator method) (InvokeOptions method) (LabelOperator method) (MSetParam method) (ObjectRef method) (Producer method) (ResourceGroup method) (SetParam method) (UInt64Counter method) (UserTLSConfig method)

A

accelerate() (FunctionGroupHandler method) add_labels() (DoubleCounter method) (Gauge method) (UInt64Counter method) Affinity (C++ class) Affinity::Affinity (C++ function), [1], [2] Affinity::GetAffinityKind (C++ function) Affinity::GetAffinityScope (C++ function) Affinity::GetAffinityType (C++ function) Affinity::GetLabelOperators (C++ function)

Affinity::SetAffinityScope (C++ function) Affinity::~Affinity (C++ function) affinity_kind (Affinity attribute) affinity_type (Affinity attribute) alarm_name (AlarmInfo attribute) alarm_severity (AlarmInfo attribute) alias_params (InvokeOptions attribute) as_future() (ObjectRef method) auto (config attribute) auto_clean_up (ProducerConfig attribute)

B

built-in function kv_set() kv_write_with_param() yr.cancel() yr.cpp_function() yr.create_function_group() yr.create_resource_group() yr.create_stream_producer(), [1] yr.delete_stream() yr.exit() yr.finalize() yr.get() yr.get_function_group_context() yr.get_instance() yr.init() yr.instance() yr.invoke() yr.is_initialized() yr.java_function() yr.kv_del() yr.kv_get() yr.kv_get_with_param() yr.kv_m_write_tx() yr.kv_read() yr.kv_write() yr.list_named_instances() yr.load_state() yr.method() yr.put() yr.remove_resource_group() yr.resources() yr.save_state() yr.wait()

bundle_index (ResourceGroupOptions attribute) bundle_specs (ResourceGroup attribute)

C

cache_type (CreateParam attribute) (MSetParam attribute) (SetParam attribute) cancel() (ObjectRef method) CAUSAL (ConsistencyType attribute) cause (AlarmInfo attribute) certificate_file_path (config attribute) check_options_valid() (InvokeOptions method) ClientInfo (C++ struct) ClientInfo::jobId (C++ member) ClientInfo::serverVersion (C++ member) ClientInfo::version (C++ member) close() (Consumer method) (Producer method) code_dir (config attribute) concurrency (FunctionGroupOptions attribute) (InvokeOptions attribute) Config (C++ struct) Config::attach (C++ member) Config::certificateFilePath (C++ member) Config::customEnvs (C++ member) Config::dataSystemAddr (C++ member) Config::dsPublicKeyContextPath (C++ member) Config::enableDsAuth (C++ member) Config::enableDsEncrypt (C++ member) Config::enableMetrics (C++ member) Config::enableMTLS (C++ member) Config::enableServerMode (C++ member) Config::functionUrn (C++ member) Config::isLowReliabilityTask (C++ member) Config::javaFunctionUrn (C++ member) Config::loadPaths (C++ member) Config::localThreadPoolSize (C++ member) Config::logCompress (C++ member) Config::logDir (C++ member) Config::logLevel (C++ member) Config::logPath (C++ member)

Config::maxConcurrencyCreateNum (C++ member) Config::maxLogFileNum (C++ member) Config::maxLogSizeMb (C++ member) Config::maxTaskInstanceNum (C++ member) Config::metricsLogPath (C++ member) Config::mode (C++ member) Config::ns (C++ member) Config::privateKeyPath (C++ member) Config::pythonFunctionUrn (C++ member) Config::recycleTime (C++ member) Config::rpcTimeout (C++ member) Config::runtimePrivateKeyContextPath (C++ member) Config::runtimePublicKeyContextPath (C++ member) Config::serverAddr (C++ member) Config::serverName (C++ member) Config::threadPoolSize (C++ member) Config::verifyFilePath (C++ member) Config::workingdir (C++ member) connection_nums (config attribute) consistency_type (CreateParam attribute) Context (C++ struct) Context::id (C++ member) cpp_function_id (config attribute) cpu (DeploymentConfig attribute) (FunctionGroupOptions attribute) (InvokeOptions attribute) create_cpp_user_class() (InstanceCreator method) create_cross_user_class() (InstanceCreator method) create_from_user_class() (InstanceCreator method) CreateParam (C++ struct) CreateParam::cacheType (C++ member) CreateParam::consistencyType (C++ member) CreateParam::writeMode (C++ member) custom_envs (config attribute) custom_extensions (FunctionGroupOptions attribute) custom_options (AlarmInfo attribute) custom_resources (FunctionGroupOptions attribute)

D

datamem (DeploymentConfig attribute) delay_flush_time (ProducerConfig attribute) DelParam (C++ struct) DelParam::traceId (C++ member) deployment_config (config attribute)

deserialization_() (InstanceProxy method) device_name (FunctionGroupContext attribute) DISK (CacheType attribute) done() (ObjectRef method) ds_address (config attribute) ds_public_key_path (config attribute)

E

Element (C++ struct) Element::id (C++ member) Element::ptr (C++ member) Element::size (C++ member) enable_ds_encrypt (config attribute) enable_metrics (config attribute) enable_mtls (config attribute) encrypt_stream (ProducerConfig attribute) ends_at (AlarmInfo attribute) env_vars (InvokeOptions attribute)

Exception (C++ class) exception() (ObjectRef method) Exception::Code (C++ function) Exception::MCode (C++ function) Exception::Msg (C++ function) Exception::what (C++ function) existence (MSetParam attribute) (SetParam attribute) extend_config (ProducerConfig attribute) (SubscriptionConfig attribute)

F

flush() (Producer method)

function_group_options (InvokeOptions attribute) function_id (config attribute)

G

get() (ObjectRef method) get_class_name() (cpp_instance_class method) get_factory_name() (cpp_instance_class method) get_function_group_handler() (InstanceProxy method) get_function_key() (cpp_instance_class method) get_future() (ObjectRef method) get_instance() (InstanceCreator method) get_original_cls() (InstanceCreator method) get_original_func() (FunctionProxy method) get_params (GetParams attribute) get_value() (DoubleCounter method) (UInt64Counter method) GetParam (C++ struct)

GetParam::offset (C++ member) GetParam::size (C++ member) GetParams (C++ struct) GetParams::getParams (C++ member) GetParams::traceId (C++ member) Group (C++ class) Group::GetGroupName (C++ function) Group::Group (C++ function), [1], [2] Group::Invoke (C++ function) Group::Terminate (C++ function) Group::Wait (C++ function) GroupOptions (C++ struct) GroupOptions::sameLifecycle (C++ member) GroupOptions::timeout (C++ member)

I

id (ObjectRef property) increase() (DoubleCounter method) (UInt64Counter method) INFO (AlarmSeverity attribute) INSTANCE (AffinityKind attribute) InstancePreferredAffinity (C++ class) InstancePreferredAffinity::InstancePreferredAffinity (C++ function), [1] InstancePreferredAntiAffinity (C++ class) InstancePreferredAntiAffinity::InstancePreferredAntiAffinity (C++ function), [1] InstanceRequiredAffinity (C++ class)

InstanceRequiredAffinity::InstanceRequiredAffinity (C++ function), [1] InstanceRequiredAntiAffinity (C++ class) InstanceRequiredAntiAffinity::InstanceRequiredAntiAffinity (C++ function), [1] invoke() (cpp_instance_class method) (FunctionGroupMethodProxy method) (InstanceCreator method) (MethodProxy method) invoke_timeout (config attribute) is_activate() (InstanceProxy method) is_driver (config attribute) is_exception() (ObjectRef method)

J

java_instance_class()

job_id (ClientInfo attribute) (config attribute)

K

kv_set() built-in function

kv_write_with_param() built-in function

L

LABEL_EXISTS (OperatorType attribute) LABEL_IN (OperatorType attribute) LABEL_NOT_EXISTS (OperatorType attribute) LABEL_NOT_IN (OperatorType attribute) label_operators (Affinity attribute) LabelDoesNotExistOperator (C++ class) LabelDoesNotExistOperator::LabelDoesNotExistOperator (C++ function) LabelExistsOperator (C++ class) LabelExistsOperator::LabelExistsOperator (C++ function) LabelInOperator (C++ class) LabelInOperator::LabelInOperator (C++ function) LabelNotInOperator (C++ class) LabelNotInOperator::LabelNotInOperator (C++ function) LabelOperator (C++ class)

LabelOperator::GetKey (C++ function) LabelOperator::GetOperatorType (C++ function) LabelOperator::GetValues (C++ function) LabelOperator::LabelOperator (C++ function), [1], [2] LabelOperator::~LabelOperator (C++ function) labels (InvokeOptions attribute) load_paths (config attribute) local_mode (config attribute) location_info (AlarmInfo attribute) log_dir (config attribute) log_file_num_max (config attribute) log_file_size_max (config attribute) log_flush_interval (config attribute) log_level (config attribute)

M

MAJOR (AlarmSeverity attribute) master_addr_list (config attribute) max_instances (InvokeOptions attribute) max_invoke_latency (InvokeOptions attribute) max_stream_size (ProducerConfig attribute) max_task_instance_num (config attribute) mem (DeploymentConfig attribute) MEMORY (CacheType attribute) memory (FunctionGroupOptions attribute) (InvokeOptions attribute)

min_instances (InvokeOptions attribute) MINOR (AlarmSeverity attribute) module_cert_path (UserTLSConfig attribute) module_key_path (UserTLSConfig attribute) MSetParam (C++ struct) MSetParam::cacheType (C++ member) MSetParam::existence (C++ member) MSetParam::extendParams (C++ member) MSetParam::ttlSecond (C++ member) MSetParam::writeMode (C++ member)

N

name (InvokeOptions attribute) NamedInstance (C++ class) NamedInstance::CppFunction (C++ function) NamedInstance::Export (C++ function) NamedInstance::Function (C++ function) NamedInstance::GetInstances (C++ function) NamedInstance::Import (C++ function) NamedInstance::JavaFunction (C++ function)

NamedInstance::PyFunction (C++ function) NamedInstance::Terminate (C++ function), [1] namespace (InvokeOptions attribute) need_order (InvokeOptions attribute) NONE (ExistenceOpt attribute) NONE_L2_CACHE (WriteMode attribute) NONE_L2_CACHE_EVICT (WriteMode attribute) ns (config attribute) NX (ExistenceOpt attribute)

O

ObjectRef (C++ class) ObjectRef::ID (C++ function) ObjectRef::IsLocal (C++ function) OFF (AlarmSeverity attribute) offset (GetParam attribute)

on_complete() (ObjectRef method) openYuanrong 函数（openYuanrong Function） options() (cpp_instance_class method) (FunctionProxy method) (InstanceCreator method) (MethodProxy method)

P

page_size (ProducerConfig attribute) pod_labels (InvokeOptions attribute) PRAM (ConsistencyType attribute) PREFERRED (AffinityType attribute) PREFERRED_ANTI (AffinityType attribute) preferred_anti_other_labels (InvokeOptions attribute) preferred_priority (InvokeOptions attribute) private_key_path (config attribute) ProducerConf (C++ struct) ProducerConf::autoCleanup (C++ member)

ProducerConf::delayFlushTime (C++ member) ProducerConf::encryptStream (C++ member) ProducerConf::extendConfig (C++ member) ProducerConf::maxStreamSize (C++ member) ProducerConf::pageSize (C++ member) ProducerConf::reserveSize (C++ member) ProducerConf::retainForNumConsumers (C++ member) ProducerConf::traceId (C++ member) PyFunctionHandler (C++ class) PyFunctionHandler::operator() (C++ function)

R

rank_id (FunctionGroupContext attribute) receive() (Consumer method) recover_retry_times (FunctionGroupOptions attribute) (InvokeOptions attribute) recycle_time (config attribute) REQUIRED (AffinityType attribute) REQUIRED_AFFINITY_IN_EACH_BUNDLE (config.SchedulingAffinityType attribute) REQUIRED_ANTI (AffinityType attribute) required_priority (FunctionGroupOptions attribute) reserve_size (ProducerConfig attribute) reset() (DoubleCounter method) (UInt64Counter method) RESOURCE (AffinityKind attribute) resource_group_name (ResourceGroup attribute) (ResourceGroupOptions attribute) resource_group_options (InvokeOptions attribute) ResourceGroupOptions() ResourcePreferredAffinity (C++ class)

ResourcePreferredAffinity::ResourcePreferredAffinity (C++ function), [1] ResourcePreferredAntiAffinity (C++ class) ResourcePreferredAntiAffinity::ResourcePreferredAntiAffinity (C++ function), [1] ResourceRequiredAffinity (C++ class) ResourceRequiredAffinity::ResourceRequiredAffinity (C++ function), [1] ResourceRequiredAntiAffinity (C++ class) ResourceRequiredAntiAffinity::ResourceRequiredAntiAffinity (C++ function), [1] resources (FunctionGroupOptions attribute) retain_for_num_consumers (ProducerConfig attribute) retry_times (FunctionGroupOptions attribute) root_cert_path (UserTLSConfig attribute) rpc_broadcast_mq (FunctionGroupMethodProxy attribute) rpc_timeout (config attribute) rt_server_address (config attribute) runtime_env (InvokeOptions attribute) runtime_id (config attribute) runtime_private_key_path (config attribute) runtime_public_key_path (config attribute)

S

schedule_affinities (InvokeOptions attribute) scheduling_affinity_each_bundle_size (FunctionGroupOptions attribute) scheduling_affinity_type (FunctionGroupOptions attribute) send() (Producer method) serialization_() (InstanceProxy method) server_address (config attribute) server_list (FunctionGroupContext attribute) server_name (config attribute) (UserTLSConfig attribute) set() (Alarm method) (DoubleCounter method) (Gauge method) (UInt64Counter method) set_data() (ObjectRef method) set_exception() (ObjectRef method) set_function_group_size() (FunctionProxy method) (InstanceCreator method) set_rpc_broadcast_mq() (FunctionGroupMethodProxy method) set_urn() (FunctionProxy method) SetParam (C++ struct) SetParam::existence (C++ member) SetParam::traceId (C++ member) SetParam::ttlSecond (C++ member) SetParam::writeMode (C++ member) SetParamV2 (C++ struct)

SetParamV2::cacheType (C++ member) SetParamV2::existence (C++ member) SetParamV2::extendParams (C++ member) SetParamV2::traceId (C++ member) SetParamV2::ttlSecond (C++ member) SetParamV2::writeMode (C++ member) size (GetParam attribute) spill_limit (DeploymentConfig attribute) spill_path (DeploymentConfig attribute) starts_at (AlarmInfo attribute) StreamConsumer (C++ class) StreamConsumer::Ack (C++ function) StreamConsumer::Close (C++ function) StreamConsumer::Receive (C++ function), [1] StreamProducer (C++ class) StreamProducer::Close (C++ function) StreamProducer::Send (C++ function), [1] StreamProducer::YR::Subscribe (C++ function) subscription_name (SubscriptionConfig attribute) SubscriptionConfig (C++ struct) SubscriptionConfig::extendConfig (C++ member) SubscriptionConfig::SubscriptionConfig (C++ function) SubscriptionConfig::subscriptionName (C++ member) SubscriptionConfig::subscriptionType (C++ member) SubscriptionConfig::traceId (C++ member) subscriptionType (SubscriptionConfig attribute)

T

task_id (ObjectRef property) terminate() (FunctionGroupHandler method) (InstanceProxy method) timeout (AlarmInfo attribute) (FunctionGroupOptions attribute)

tls_config (config attribute) trace_id (FunctionGroupOptions attribute) ttl_second (MsetParam attribute) (SetParam attribute)

U

use_shared_memory (FunctionGroupMethodProxy attribute)

V

verify_file_path (config attribute)

W

wait() (ObjectRef method) (ResourceGroup method) working_dir (Config attribute) world_size (FunctionGroupContext attribute)

WRITE_BACK_L2_CACHE (WriteMode attribute) write_mode (MSetParam attribute) (SetParam attribute) WRITE_THROUGH_L2_CACHE (WriteMode attribute)

Y

yr.affinity.Affinity (built-in class) yr.affinity.AffinityKind (built-in class) yr.affinity.AffinityType (built-in class) yr.affinity.LabelOperator (built-in class) yr.affinity.OperatorType (built-in class) yr.Alarm (built-in class) yr.AlarmInfo (built-in class) yr.AlarmSeverity (built-in class) yr.cancel() built-in function yr.Config (built-in class) yr.config.ClientInfo (built-in class) yr.config.DeploymentConfig (built-in class) yr.config.ResourceGroupOptions (built-in class) yr.config.UserTLSConfig (built-in class) yr.cpp_function() built-in function yr.cpp_instance_class (built-in class) yr.create_function_group() built-in function yr.create_resource_group() built-in function yr.create_stream_producer() built-in function, [1] yr.delete_stream() built-in function yr.device.DataInfo (built-in class) yr.DoubleCounter (built-in class) yr.Element (built-in class) yr.exit() built-in function yr.finalize() built-in function yr.fnruntime.Consumer (built-in class) yr.fnruntime.Producer (built-in class) yr.FunctionGroupContext (built-in class) yr.FunctionGroupHandler (built-in class) yr.FunctionGroupMethodProxy (built-in class) yr.FunctionGroupOptions (built-in class) yr.FunctionProxy (built-in class) yr.Gauge (built-in class) yr.get() built-in function yr.get_function_group_context() built-in function yr.get_instance() built-in function yr.init() built-in function yr.instance() built-in function yr.InstanceCreator (built-in class) yr.InstanceProxy (built-in class) yr.invoke() built-in function yr.InvokeOptions (built-in class) yr.is_initialized() built-in function yr.java_function() built-in function yr.kv_del() built-in function yr.kv_get() built-in function yr.kv_get_with_param() built-in function yr.kv_m_write_tx() built-in function yr.kv_read() built-in function yr.kv_write() built-in function yr.list_named_instances() built-in function yr.load_state() built-in function yr.method() built-in function yr.MethodProxy (built-in class) yr.object_ref.ObjectRef (built-in class) yr.ProducerConfig (built-in class) yr.put() built-in function yr.remove_resource_group() built-in function yr.ResourceGroup (built-in class) yr.resources() built-in function yr.runtime.CacheType (built-in class) yr.runtime.ConsistencyType (built-in class) yr.runtime.CreateParam (built-in class) yr.runtime.ExistenceOpt (built-in class) yr.runtime.GetParam (built-in class) yr.runtime.GetParams (built-in class) yr.runtime.MSetParam (built-in class) yr.runtime.SetParam (built-in class) yr.runtime.WriteMode (built-in class) yr.save_state() built-in function yr.SubscriptionConfig (built-in class) yr.UInt64Counter (built-in class) yr.wait() built-in function YR::AFFINITYSCOPE_NODE (C++ member) YR::AFFINITYSCOPE_POD (C++ member) YR::CacheType (C++ enum) YR::CacheType::DISK (C++ enumerator) YR::CacheType::MEMORY (C++ enumerator)

YR::Cancel (C++ function), [1] YR::Collective::AllGather (C++ function) YR::Collective::AllReduce (C++ function) YR::Collective::Backend (C++ enum) YR::Collective::Backend::GLOO (C++ enumerator) YR::Collective::Backend::INVALID (C++ enumerator) YR::Collective::Barrier (C++ function) YR::Collective::Broadcast (C++ function) YR::Collective::CollectiveGroupSpec (C++ struct) YR::Collective::CollectiveGroupSpec::backend (C++ member) YR::Collective::CollectiveGroupSpec::groupName (C++ member) YR::Collective::CollectiveGroupSpec::timeout (C++ member) YR::Collective::CollectiveGroupSpec::worldSize (C++ member) YR::Collective::CreateCollectiveGroup (C++ function) YR::Collective::DEFAULT_COLLECTIVE_TIMEOUT (C++ member) YR::Collective::DEFAULT_GROUP_NAME (C++ member) YR::Collective::DestroyCollectiveGroup (C++ function) YR::Collective::GetRank (C++ function) YR::Collective::GetWorldSize (C++ function) YR::Collective::InitCollectiveGroup (C++ function) YR::Collective::Recv (C++ function) YR::Collective::Reduce (C++ function) YR::Collective::Scatter (C++ function) YR::Collective::Send (C++ function) YR::ConsistencyType (C++ enum) YR::ConsistencyType::CAUSAL (C++ enumerator) YR::ConsistencyType::PRAM (C++ enumerator) YR::CppFunction (C++ function) YR::CppInstanceClass::FactoryCreate (C++ function) YR::CreateProducer (C++ function) YR::DataType (C++ enum) YR::DataType::DOUBLE (C++ enumerator) YR::DataType::FLOAT (C++ enumerator) YR::DataType::INT (C++ enumerator) YR::DataType::INVALID (C++ enumerator) YR::DataType::LONG (C++ enumerator) YR::DeleteStream (C++ function) YR::ExistenceOpt (C++ enum) YR::ExistenceOpt::NONE (C++ enumerator) YR::ExistenceOpt::NX (C++ enumerator) YR::Exit (C++ function) YR::Finalize (C++ function) YR::Function (C++ function) YR::FunctionHandler::Invoke (C++ function) YR::FunctionHandler::Options (C++ function) YR::FunctionHandler::SetUrn (C++ function) YR::Get (C++ function), [1] YR::GetInstance (C++ function) YR::Init (C++ function) YR::Instance (C++ function), [1], [2] YR::INSTANCE (C++ member) YR::InstanceFunctionHandler::Invoke (C++ function) YR::InstanceFunctionHandler::Options (C++ function) YR::InstanceRange (C++ struct) YR::InstanceRange::max (C++ member) YR::InstanceRange::min (C++ member) YR::InstanceRange::rangeOpts (C++ member) YR::InstanceRange::sameLifecycle (C++ member) YR::InstanceRange::step (C++ member) YR::internal::InstanceCreator::Invoke (C++ function) YR::internal::InstanceCreator::Options (C++ function) YR::internal::InstanceCreator::SetUrn (C++ function) YR::IsInitialized (C++ function) YR::IsLocalMode (C++ function) YR::JavaFunction (C++ function) YR::JavaInstanceClass::FactoryCreate (C++ function) YR::KVManager::Del (C++ function), [1] YR::KVManager::Get (C++ function), [1] YR::KVManager::GetWithParam (C++ function) YR::KVManager::MSetTx (C++ function), [1], [2], [3] YR::KVManager::MWriteTx (C++ function), [1] YR::KVManager::Read (C++ function), [1] YR::KVManager::ReadRaw (C++ function) YR::KVManager::Set (C++ function), [1], [2], [3], [4], [5], [6], [7], [8] YR::KVManager::Write (C++ function), [1], [2] YR::KVManager::WriteRaw (C++ function) YR::LABEL_DOES_NOT_EXIST (C++ member) YR::LABEL_EXISTS (C++ member) YR::LABEL_IN (C++ member) YR::LABEL_NOT_IN (C++ member) YR::LoadState (C++ function) YR::Parallel::ParallelFor (C++ function) YR::PREFERRED (C++ member) YR::PREFERRED_ANTI (C++ member) YR::Put (C++ function), [1] YR::PyFunction (C++ function) YR::PyInstanceClass::FactoryCreate (C++ function) YR::RangeOptions (C++ struct) YR::RangeOptions::timeout (C++ member) YR::ReduceOp (C++ enum) YR::ReduceOp::MAX (C++ enumerator) YR::ReduceOp::MIN (C++ enumerator) YR::ReduceOp::PRODUCT (C++ enumerator) YR::ReduceOp::SUM (C++ enumerator) YR::REQUIRED (C++ member) YR::REQUIRED_ANTI (C++ member) YR::RESOURCE (C++ member) YR::SaveState (C++ function) YR::Wait (C++ function), [1] YR::WaitResult (C++ type) YR::WriteMode (C++ enum) YR::WriteMode::NONE_L2_CACHE (C++ enumerator) YR::WriteMode::NONE_L2_CACHE_EVICT (C++ enumerator) YR::WriteMode::WRITE_BACK_L2_CACHE (C++ enumerator) YR::WriteMode::WRITE_THROUGH_L2_CACHE (C++ enumerator) YR_INVOKE (C++ function) YR_RECOVER (C++ function) YR_SHUTDOWN (C++ function) YR_STATE (C++ function)