Index

A

ac_predictor (mstar.model.vjepa2.config.VJepa2Config attribute) accumulated_outputs (mstar.graph.base.Loop attribute) action_dim (mstar.model.pi05.config.Pi05Config attribute) action_embed_dim (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) action_hidden_size (mstar.model.pi05.config.Pi05Config attribute) action_horizon (mstar.model.pi05.config.Pi05Config attribute) action_intermediate_size (mstar.model.pi05.config.Pi05Config attribute) adarms_norm_fused() (in module mstar.utils.adarms_norm)

address (mstar.graph.base.TensorPointerInfo attribute) APIServerMessage (class in mstar.api_server.request_types) apply_masks() (in module mstar.model.vjepa2.components.vit_encoder) apply_rotary_embeddings() (mstar.model.vjepa2.components.layers.VJEPA2RopeAttention method) attention_probs_dropout_prob (mstar.model.vjepa2.config.VJepa2Config attribute) attn_drop_rate (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) audio (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) audio_speech() (in module mstar.api_server.openai.router) available_voices (mstar.model.orpheus.config.OrpheusModelConfig attribute)

B

BagelAdapter (class in mstar.api_server.openai.adapters)

BaseCommunicator (class in mstar.communication.communicator) body (mstar.api_server.request_types.APIServerMessage attribute)

C

chat_completions() (in module mstar.api_server.openai.router) chat_to_request() (mstar.api_server.openai.adapters.BagelAdapter method) (mstar.api_server.openai.adapters.OpenAIAdapter method) (mstar.api_server.openai.adapters.Qwen3OmniAdapter method) ChatCompletionRequest (class in mstar.api_server.openai.protocol) ChatMessage (class in mstar.api_server.openai.protocol) chunk_index (mstar.streaming.stream_buffer.StreamChunk attribute) chunk_policy_factory (mstar.streaming.topology.Connection attribute) ChunkPolicy (class in mstar.streaming.chunk_policy) clear() (mstar.graph.base.GraphNode method) (mstar.graph.base.GraphStateRegistry method) (mstar.graph.base.Loop method) (mstar.graph.base.ReadySignals method) (mstar.graph.base.WorkerGraphStateRegistry method) (mstar.graph.graph_io.WorkerGraphIO method) clear_speculative_inputs() (mstar.graph.graph_io.WorkerGraphIO method) clone() (mstar.graph.base.GraphEdge method) (mstar.graph.base.TensorPointerInfo method)

CommProtocol (class in mstar.communication.communicator) complete() (mstar.graph.base.GraphNode method) complete_iter() (mstar.graph.base.Loop method) conductor_new_token (mstar.graph.base.GraphEdge attribute) Connection (class in mstar.streaming.topology) connections (mstar.streaming.topology.PartitionTopology attribute) consumes_stream (mstar.graph.base.GraphNode attribute) content (mstar.api_server.openai.protocol.ChatMessage attribute) continue_after_producer_done() (mstar.streaming.chunk_policy.ChunkPolicy method) (mstar.streaming.chunk_policy.FixedChunkPolicy method) create_chat_completion() (in module mstar.api_server.openai.serving_chat) create_image_edit() (in module mstar.api_server.openai.serving_images) create_images() (in module mstar.api_server.openai.serving_images) create_speech() (in module mstar.api_server.openai.serving_speech) created (mstar.api_server.openai.protocol.ModelCard attribute) crop_size (mstar.model.vjepa2.config.VJepa2Config attribute) curr_iter (mstar.graph.base.Loop attribute) custom_token_base_id (mstar.model.orpheus.config.OrpheusModelConfig attribute)

D

data (mstar.api_server.openai.protocol.ModelList attribute) (mstar.api_server.request_types.ResultChunk attribute) (mstar.streaming.stream_buffer.StreamChunk attribute) default_action_dtype (mstar.model.pi05.config.Pi05Config attribute) depth (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) dims (mstar.graph.base.TensorPointerInfo attribute)

discretize_state() (in module mstar.model.pi05.components.flow_matching) drain() (mstar.communication.event.EventWakeup method) drop_path_rate (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute) drop_rate (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) dtype (mstar.graph.base.TensorPointerInfo attribute)

E

edge_name (mstar.streaming.stream_buffer.StreamBuffer attribute) (mstar.streaming.topology.Connection attribute) embed_dim (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) enable_async_scheduling (mstar.graph.base.GraphNode attribute) encode_prompt() (mstar.model.pi05.components.tokenization.Pi05Tokenizer method)

end_token_ids (mstar.model.orpheus.config.OrpheusModelConfig attribute) euler_step() (in module mstar.model.pi05.components.flow_matching) EventWakeup (class in mstar.communication.event) ext_inputs (mstar.graph.base.NodeInputsOutputs attribute) ext_outputs (mstar.graph.base.NodeInputsOutputs attribute) extra (mstar.model.pi05.config.Pi05Config attribute)

F

fd (mstar.communication.event.EventWakeup property) file_paths (mstar.api_server.openai.adapters.SubmitArgs attribute) (mstar.api_server.request_types.PreprocessInput attribute) filtered_signals (mstar.graph.base.NodeCompletionOutput attribute) final_outputs (mstar.api_server.request_types.RequestComplete attribute) FixedChunkPolicy (class in mstar.streaming.chunk_policy) FlashInferDecodeWrapper (class in mstar.utils.flashinfer_utils) FlashInferPrefillWrapper (class in mstar.utils.flashinfer_utils) flatten_messages() (in module mstar.api_server.openai.adapters) format_graph_edge_list() (in module mstar.graph.graph_io) forward() (mstar.model.vjepa2.components.layers.VJEPA2Layer method) (mstar.model.vjepa2.components.layers.VJEPA2MLP method) (mstar.model.vjepa2.components.layers.VJEPA2RopeAttention method) (mstar.model.vjepa2.components.predictor.VJEPA2Predictor method) (mstar.model.vjepa2.components.predictor.VJEPA2PredictorEmbeddings method) (mstar.model.vjepa2.components.vit_encoder.VJEPA2Embeddings method) (mstar.model.vjepa2.components.vit_encoder.VJEPA2Encoder method) (mstar.model.vjepa2.components.vit_encoder.VJEPA2PatchEmbeddings3D method)

frames_per_clip (mstar.model.vjepa2.config.VJepa2Config attribute) from_hf_config() (mstar.model.vjepa2.config.VJepa2Config class method) from_partition (mstar.streaming.stream_buffer.StreamBuffer attribute) (mstar.streaming.topology.Connection attribute)

G

get_adapter() (in module mstar.api_server.openai.adapters) get_all_new_messages() (mstar.communication.communicator.BaseCommunicator method) (mstar.communication.communicator.ZMQCommunicator method) get_inputs_outputs() (mstar.graph.base.GraphNode method) (mstar.graph.base.GraphSection method) (mstar.graph.base.Loop method) (mstar.graph.base.Parallel method) (mstar.graph.base.Sequential method) get_loop_indices() (mstar.graph.graph_io.WorkerGraphIO method) get_loops() (mstar.graph.base.GraphNode method) (mstar.graph.base.GraphSection method) (mstar.graph.base.Loop method) (mstar.graph.base.Parallel method) (mstar.graph.base.Sequential method) get_nested_loop_idxs() (mstar.graph.graph_io.WorkerGraphIO method)

get_nested_loop_idxs_for_node() (mstar.graph.graph_io.WorkerGraphIO method) get_node() (mstar.graph.graph_io.WorkerGraphIO method) get_nodes() (mstar.graph.base.GraphNode method) (mstar.graph.base.GraphSection method) (mstar.graph.base.Loop method) (mstar.graph.base.Parallel method) (mstar.graph.base.Sequential method) get_position_ids() (mstar.model.vjepa2.components.layers.VJEPA2RopeAttention method) graph_edge (mstar.api_server.request_types.ResultTensors attribute) graph_walk (mstar.graph.base.NodeAndGraphWalk attribute) GraphEdge (class in mstar.graph.base) GraphNode (class in mstar.graph.base) GraphSection (class in mstar.graph.base) GraphStateRegistry (class in mstar.graph.base) grid_depth (mstar.model.vjepa2.config.VJepa2Config property) grid_size (mstar.model.vjepa2.config.VJepa2Config property)

H

has_chunk_ready() (mstar.streaming.stream_buffer.StreamBuffer method) head_dim (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute)

hidden_act (mstar.model.vjepa2.config.VJepa2Config attribute) hidden_size (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute) (mstar.model.vjepa2.config.VJepa2Config attribute)

I

id (mstar.api_server.openai.protocol.ModelCard attribute) ignore_eos (mstar.model.orpheus.config.OrpheusModelConfig attribute) image_edit_to_request() (mstar.api_server.openai.adapters.BagelAdapter method) (mstar.api_server.openai.adapters.OpenAIAdapter method) image_to_request() (mstar.api_server.openai.adapters.BagelAdapter method) (mstar.api_server.openai.adapters.OpenAIAdapter method) ImageGenerationRequest (class in mstar.api_server.openai.protocol) images_edits() (in module mstar.api_server.openai.router) images_generations() (in module mstar.api_server.openai.router) img_size (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) in_chans (mstar.model.vjepa2.config.VJepa2Config attribute) ingest_external_input() (mstar.graph.base.Loop method) ingest_for_speculation() (mstar.graph.graph_io.WorkerGraphIO method) ingest_input() (mstar.graph.base.GraphNode method) (mstar.graph.graph_io.WorkerGraphIO method) input (mstar.api_server.openai.protocol.SpeechRequest attribute) input_modalities (mstar.api_server.openai.adapters.SubmitArgs attribute) (mstar.api_server.request_types.PreprocessInput attribute)

input_names (mstar.graph.base.GraphNode attribute) (mstar.graph.base.ReadySignals attribute) intermediate_size (mstar.model.orpheus.config.OrpheusModelConfig attribute) IPC (mstar.communication.communicator.CommProtocol attribute) is_done (mstar.graph.base.Loop attribute) is_final (mstar.streaming.stream_buffer.StreamChunk attribute) is_frame_causal (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) is_new_loop_iter (mstar.graph.base.SpeculativeNodeInfo attribute) is_ready (mstar.graph.base.ReadySignals attribute) is_ready() (mstar.streaming.chunk_policy.ChunkPolicy method) (mstar.streaming.chunk_policy.FixedChunkPolicy method) (mstar.streaming.chunk_policy.LeftContextChunkPolicy method) (mstar.streaming.chunk_policy.SlidingWindowChunkPolicy method) is_ready_for_speculation() (mstar.graph.base.GraphNode method) is_ready_for_streaming (mstar.graph.base.ReadySignals attribute) is_streaming (mstar.graph.base.GraphEdge attribute)

L

label_context_gt() (mstar.graph.loop_indices.NestedLoopIndices method) layer_norm_eps (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute) LeftContextChunkPolicy (class in mstar.streaming.chunk_policy) list_models() (in module mstar.api_server.openai.router) load_pi05_config() (in module mstar.model.pi05.config)

Loop (class in mstar.graph.base) loop_back (mstar.graph.base.NodeInputsOutputs attribute) loop_indices (mstar.api_server.request_types.ResultTensors attribute) (mstar.graph.loop_indices.NestedLoopIndices attribute) loop_name (mstar.graph.base.SpeculativeNodeInfo attribute) loop_name_order (mstar.graph.loop_indices.NestedLoopIndices attribute) LoopStateRegistry (class in mstar.graph.base)

M

make_layer_loop_fn() (mstar.model.vjepa2.components.predictor.VJEPA2Predictor method) managed_entities (mstar.graph.base.GraphStateRegistry attribute) mark() (in module mstar.utils.profiler) mark_entity_complete() (mstar.graph.base.GraphStateRegistry method) (mstar.graph.base.LoopStateRegistry method) (mstar.graph.base.WorkerGraphStateRegistry method) mark_node_complete() (mstar.graph.graph_io.WorkerGraphIO method) max() (mstar.graph.loop_indices.NestedLoopIndices method) max_completion_tokens (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) max_iters (mstar.graph.base.Loop attribute) max_lang_tokens (mstar.model.pi05.config.Pi05Config attribute) max_new_tokens (mstar.model.orpheus.config.OrpheusModelConfig attribute) max_position_embeddings (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute) max_rollout_horizon (mstar.model.vjepa2.config.VJepa2Config attribute) max_tokens (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) maybe_cache_output() (mstar.graph.base.Loop method) message_type (mstar.api_server.request_types.APIServerMessage attribute) messages (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) metadata (mstar.api_server.request_types.ResultChunk attribute) (mstar.api_server.request_types.ResultTensors attribute) mlp_ratio (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute) modalities (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) modality (mstar.api_server.request_types.ResultChunk attribute) (mstar.api_server.request_types.ResultTensors attribute) modality_from_mime() (in module mstar.api_server.media_io) model (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) model_config (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.ChatMessage attribute) (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) (mstar.api_server.openai.protocol.ModelCard attribute) (mstar.api_server.openai.protocol.ModelList attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) model_kwargs (mstar.api_server.openai.adapters.SubmitArgs attribute) (mstar.api_server.request_types.PreprocessInput attribute) ModelCard (class in mstar.api_server.openai.protocol) ModelList (class in mstar.api_server.openai.protocol) module mstar.api_server mstar.api_server.media_io mstar.api_server.openai mstar.api_server.openai.adapters mstar.api_server.openai.protocol mstar.api_server.openai.router mstar.api_server.openai.serving_chat mstar.api_server.openai.serving_images mstar.api_server.openai.serving_speech mstar.api_server.request_types mstar.communication mstar.communication.communicator mstar.communication.event mstar.conductor mstar.engine mstar.graph mstar.graph.base mstar.graph.graph_io mstar.graph.loop_indices mstar.graph.special_destinations mstar.model mstar.model.orpheus mstar.model.orpheus.components mstar.model.orpheus.config mstar.model.pi05 mstar.model.pi05.components mstar.model.pi05.components.flow_matching mstar.model.pi05.components.tokenization mstar.model.pi05.config mstar.model.pi05.kernels mstar.model.pi05.kernels.image_normalize mstar.model.vjepa2 mstar.model.vjepa2.components mstar.model.vjepa2.components.layers mstar.model.vjepa2.components.predictor mstar.model.vjepa2.components.rope_utils mstar.model.vjepa2.components.vit_encoder mstar.model.vjepa2.config mstar.streaming mstar.streaming.chunk_policy mstar.streaming.stream_buffer mstar.streaming.topology mstar.utils mstar.utils.adarms_norm mstar.utils.flashinfer_utils mstar.utils.logging_config mstar.utils.profiler mstar.worker mpc_cost_fn (mstar.model.vjepa2.config.VJepa2Config attribute) mstar.api_server module mstar.api_server.media_io module

mstar.api_server.openai module mstar.api_server.openai.adapters module mstar.api_server.openai.protocol module mstar.api_server.openai.router module mstar.api_server.openai.serving_chat module mstar.api_server.openai.serving_images module mstar.api_server.openai.serving_speech module mstar.api_server.request_types module mstar.communication module mstar.communication.communicator module mstar.communication.event module mstar.conductor module mstar.engine module mstar.graph module mstar.graph.base module mstar.graph.graph_io module mstar.graph.loop_indices module mstar.graph.special_destinations module mstar.model module mstar.model.orpheus module mstar.model.orpheus.components module mstar.model.orpheus.config module mstar.model.pi05 module mstar.model.pi05.components module mstar.model.pi05.components.flow_matching module mstar.model.pi05.components.tokenization module mstar.model.pi05.config module mstar.model.pi05.kernels module mstar.model.pi05.kernels.image_normalize module mstar.model.vjepa2 module mstar.model.vjepa2.components module mstar.model.vjepa2.components.layers module mstar.model.vjepa2.components.predictor module mstar.model.vjepa2.components.rope_utils module mstar.model.vjepa2.components.vit_encoder module mstar.model.vjepa2.config module mstar.streaming module mstar.streaming.chunk_policy module mstar.streaming.stream_buffer module mstar.streaming.topology module mstar.utils module mstar.utils.adarms_norm module mstar.utils.flashinfer_utils module mstar.utils.logging_config module mstar.utils.profiler module mstar.worker module

N

n (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) name (mstar.graph.base.GraphEdge attribute) (mstar.graph.base.GraphNode attribute) (mstar.graph.base.Loop attribute) nbytes (mstar.graph.base.TensorPointerInfo attribute) NestedLoopIndices (class in mstar.graph.loop_indices) next_chunk_size() (mstar.streaming.chunk_policy.ChunkPolicy method) (mstar.streaming.chunk_policy.FixedChunkPolicy method) (mstar.streaming.chunk_policy.LeftContextChunkPolicy method) (mstar.streaming.chunk_policy.SlidingWindowChunkPolicy method) next_node (mstar.graph.base.GraphEdge attribute) node (mstar.graph.base.NodeAndGraphWalk attribute) node_name (mstar.graph.base.ReadySignals attribute) (mstar.graph.base.SpeculativeNodeInfo attribute) NodeAndGraphWalk (class in mstar.graph.base) NodeCompletionOutput (class in mstar.graph.base)

NodeInputsOutputs (class in mstar.graph.base) normalize_float_images() (in module mstar.model.pi05.kernels.image_normalize) normalize_prompt() (in module mstar.model.pi05.components.tokenization) num_attention_heads (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute) num_cameras (mstar.model.pi05.config.Pi05Config attribute) num_flow_steps (mstar.model.pi05.config.Pi05Config attribute) num_frames (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) num_heads (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) num_hidden_layers (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute) num_key_value_heads (mstar.model.orpheus.config.OrpheusModelConfig attribute) num_kv_heads (mstar.model.pi05.config.Pi05Config attribute) num_layers (mstar.model.pi05.config.Pi05Config attribute) num_patches (mstar.model.vjepa2.config.VJepa2Config property) num_qo_heads (mstar.model.pi05.config.Pi05Config attribute) nvtx_range() (in module mstar.utils.profiler)

O

object (mstar.api_server.openai.protocol.ModelCard attribute) (mstar.api_server.openai.protocol.ModelList attribute) offset (mstar.graph.base.TensorPointerInfo attribute) OpenAIAdapter (class in mstar.api_server.openai.adapters) OrpheusAdapter (class in mstar.api_server.openai.adapters) OrpheusModelConfig (class in mstar.model.orpheus.config)

output_edges (mstar.graph.base.NodeCompletionOutput attribute) output_modalities (mstar.api_server.openai.adapters.SubmitArgs attribute) (mstar.api_server.request_types.PreprocessInput attribute) output_modality (mstar.graph.base.GraphEdge attribute) outputs (mstar.graph.base.GraphNode attribute) (mstar.graph.base.Loop attribute) owned_by (mstar.api_server.openai.protocol.ModelCard attribute)

P

pad_token_id (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute) pali_intermediate_size (mstar.model.pi05.config.Pi05Config attribute) Parallel (class in mstar.graph.base) partitions (mstar.streaming.topology.PartitionTopology attribute) PartitionTopology (class in mstar.streaming.topology) patch_size (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute) pcm16_to_container() (in module mstar.api_server.media_io) pcm16_to_wav_bytes() (in module mstar.api_server.media_io) persist (mstar.graph.base.GraphEdge attribute) Pi05Config (class in mstar.model.pi05.config) Pi05Tokenizer (class in mstar.model.pi05.components.tokenization) plan() (mstar.utils.flashinfer_utils.FlashInferDecodeWrapper method) (mstar.utils.flashinfer_utils.FlashInferPrefillWrapper method) png_to_data_url() (in module mstar.api_server.media_io)

policy (mstar.streaming.stream_buffer.StreamBuffer attribute) pop_chunk() (mstar.streaming.stream_buffer.StreamBuffer method) pop_waiting_edge() (mstar.streaming.stream_buffer.StreamBuffer method) pre_read_register() (mstar.streaming.stream_buffer.StreamBuffer method) pred_hidden_size (mstar.model.vjepa2.config.VJepa2Config attribute) pred_mlp_ratio (mstar.model.vjepa2.config.VJepa2Config attribute) pred_num_attention_heads (mstar.model.vjepa2.config.VJepa2Config attribute) pred_num_hidden_layers (mstar.model.vjepa2.config.VJepa2Config attribute) pred_num_mask_tokens (mstar.model.vjepa2.config.VJepa2Config attribute) pred_zero_init_mask_tokens (mstar.model.vjepa2.config.VJepa2Config attribute) predictor_embed_dim (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) predictor_kind (mstar.model.vjepa2.config.VJepa2Config attribute) PreprocessInput (class in mstar.api_server.request_types) producer_done (mstar.streaming.stream_buffer.StreamBuffer attribute) prompt (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) push_sockets (mstar.communication.communicator.ZMQCommunicator attribute) put() (mstar.streaming.stream_buffer.StreamBuffer method)

Q

qkv_bias (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute)

quiet_noisy_loggers() (in module mstar.utils.logging_config) Qwen3OmniAdapter (class in mstar.api_server.openai.adapters)

R

range_pop() (in module mstar.utils.profiler) range_push() (in module mstar.utils.profiler) RDMA (mstar.communication.communicator.CommProtocol attribute) ready_for_streaming (mstar.graph.graph_io.WorkerGraphIO property) ready_inputs (mstar.graph.base.ReadySignals attribute) ready_names (mstar.graph.base.ReadySignals attribute) ready_node_names (mstar.graph.graph_io.WorkerGraphIO property) ReadySignals (class in mstar.graph.base) register_chunk() (mstar.streaming.chunk_policy.ChunkPolicy method) register_communication_info() (mstar.graph.base.GraphNode method) (mstar.graph.base.Loop method) (mstar.graph.base.ReadySignals method) (mstar.graph.graph_io.WorkerGraphIO method) register_event_for_poll() (mstar.communication.communicator.ZMQCommunicator method) register_finished() (mstar.graph.base.Loop method) register_future() (mstar.communication.event.EventWakeup method) register_futures() (mstar.communication.event.EventWakeup method) register_ingested_input() (mstar.graph.base.GraphStateRegistry method) (mstar.graph.base.LoopStateRegistry method) (mstar.graph.base.WorkerGraphStateRegistry method) register_loop_finish_signal() (mstar.graph.graph_io.WorkerGraphIO method) remove() (mstar.graph.base.ReadySignals method) repetition_penalty (mstar.model.orpheus.config.OrpheusModelConfig attribute) request_id (mstar.api_server.request_types.PreprocessInput attribute) (mstar.api_server.request_types.RequestComplete attribute) (mstar.api_server.request_types.ResultChunk attribute) (mstar.api_server.request_types.ResultTensors attribute) (mstar.streaming.stream_buffer.StreamBuffer attribute)

RequestComplete (class in mstar.api_server.request_types) reset_for_iter() (mstar.graph.base.GraphStateRegistry method) (mstar.graph.base.WorkerGraphStateRegistry method) reset_for_outer_iter() (mstar.graph.base.GraphNode method) (mstar.graph.base.Loop method) reset_outputs() (mstar.graph.base.GraphNode method) resolve_media_ref() (in module mstar.api_server.media_io) response_format (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) ResultChunk (class in mstar.api_server.request_types) ResultTensors (class in mstar.api_server.request_types) rms_norm_eps (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute) role (mstar.api_server.openai.protocol.ChatMessage attribute) rollout_anticipation_seconds (mstar.model.vjepa2.config.VJepa2Config attribute) rollout_frames_per_second (mstar.model.vjepa2.config.VJepa2Config attribute) rollout_num_output_frames (mstar.model.vjepa2.config.VJepa2Config attribute) rope_scaling (mstar.model.orpheus.config.OrpheusModelConfig attribute) rope_theta (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute) rotate_queries_or_keys() (in module mstar.model.vjepa2.components.rope_utils) rotate_queries_or_keys_BNHD() (in module mstar.model.vjepa2.components.rope_utils) run() (mstar.utils.flashinfer_utils.FlashInferDecodeWrapper method) (mstar.utils.flashinfer_utils.FlashInferPrefillWrapper method) run_attention() (in module mstar.utils.flashinfer_utils) run_rms_norm() (in module mstar.utils.flashinfer_utils)

S

sample_rate (mstar.model.orpheus.config.OrpheusModelConfig attribute) save_base64() (in module mstar.api_server.media_io) save_data_url() (in module mstar.api_server.media_io) save_remote_url() (in module mstar.api_server.media_io) section (mstar.graph.base.Loop attribute) sections (mstar.graph.base.Parallel attribute) (mstar.graph.base.Sequential attribute) seed (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) send() (mstar.communication.communicator.BaseCommunicator method) (mstar.communication.communicator.ZMQCommunicator method) Sequential (class in mstar.graph.base) set_kv_cache() (mstar.utils.flashinfer_utils.FlashInferDecodeWrapper method) (mstar.utils.flashinfer_utils.FlashInferPrefillWrapper method) SHM (mstar.communication.communicator.CommProtocol attribute) signal_done() (mstar.streaming.stream_buffer.StreamBuffer method) sincos_timestep_embedding() (in module mstar.model.pi05.components.flow_matching) size (mstar.api_server.openai.protocol.ImageGenerationRequest attribute) SlidingWindowChunkPolicy (class in mstar.streaming.chunk_policy) snac_audio_slice_end (mstar.model.orpheus.config.OrpheusModelConfig attribute) snac_audio_slice_start (mstar.model.orpheus.config.OrpheusModelConfig attribute) snac_model_id (mstar.model.orpheus.config.OrpheusModelConfig attribute) snac_stride_tokens (mstar.model.orpheus.config.OrpheusModelConfig attribute) snac_window_tokens (mstar.model.orpheus.config.OrpheusModelConfig attribute) source_entity (mstar.graph.base.TensorPointerInfo attribute) source_session_id (mstar.graph.base.TensorPointerInfo attribute) source_tp_rank (mstar.graph.base.TensorPointerInfo attribute) source_tp_size (mstar.graph.base.TensorPointerInfo attribute)

SpeculativeNodeInfo (class in mstar.graph.base) speech_to_request() (mstar.api_server.openai.adapters.OpenAIAdapter method) (mstar.api_server.openai.adapters.OrpheusAdapter method) (mstar.api_server.openai.adapters.Qwen3OmniAdapter method) SpeechRequest (class in mstar.api_server.openai.protocol) speed (mstar.api_server.openai.protocol.SpeechRequest attribute) start_offset (mstar.streaming.stream_buffer.StreamChunk attribute) start_token_id (mstar.model.orpheus.config.OrpheusModelConfig attribute) state_dim (mstar.model.pi05.config.Pi05Config attribute) state_token_bins (mstar.model.pi05.config.Pi05Config attribute) state_token_offset (mstar.model.pi05.config.Pi05Config attribute) stop (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) stop_token_id (mstar.model.orpheus.config.OrpheusModelConfig attribute) store_uningested_edge() (mstar.streaming.stream_buffer.StreamBuffer method) stream (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) StreamBuffer (class in mstar.streaming.stream_buffer) StreamChunk (class in mstar.streaming.stream_buffer) streaming_inputs (mstar.graph.base.ReadySignals attribute) StreamingGraphEdge (class in mstar.streaming.topology) stride (mstar.graph.base.TensorPointerInfo attribute) SubmitArgs (class in mstar.api_server.openai.adapters) supports_chat (mstar.api_server.openai.adapters.BagelAdapter attribute) (mstar.api_server.openai.adapters.OpenAIAdapter attribute) (mstar.api_server.openai.adapters.Qwen3OmniAdapter attribute) supports_images (mstar.api_server.openai.adapters.BagelAdapter attribute) (mstar.api_server.openai.adapters.OpenAIAdapter attribute) supports_speech (mstar.api_server.openai.adapters.OpenAIAdapter attribute) (mstar.api_server.openai.adapters.OrpheusAdapter attribute) (mstar.api_server.openai.adapters.Qwen3OmniAdapter attribute)

T

target_partition (mstar.streaming.topology.StreamingGraphEdge attribute) TCP (mstar.communication.communicator.CommProtocol attribute) temperature (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) (mstar.model.orpheus.config.OrpheusModelConfig attribute) tensor_info (mstar.graph.base.GraphEdge attribute) TensorPointerInfo (class in mstar.graph.base) text (mstar.api_server.openai.adapters.SubmitArgs attribute) (mstar.api_server.request_types.PreprocessInput attribute)

timestep_max_period (mstar.model.pi05.config.Pi05Config attribute) timestep_min_period (mstar.model.pi05.config.Pi05Config attribute) to_partition (mstar.streaming.topology.Connection attribute) tokens_per_frame (mstar.model.orpheus.config.OrpheusModelConfig attribute) tokens_per_image (mstar.model.pi05.config.Pi05Config attribute) top_p (mstar.api_server.openai.protocol.ChatCompletionRequest attribute) (mstar.api_server.openai.protocol.SpeechRequest attribute) (mstar.model.orpheus.config.OrpheusModelConfig attribute) tubelet_size (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) (mstar.model.vjepa2.config.VJepa2Config attribute)

U

update() (mstar.graph.base.ReadySignals method) use_extrinsics (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute)

use_rope (mstar.model.vjepa2.config.VJepa2ACPredictorConfig attribute) uuid (mstar.graph.base.TensorPointerInfo attribute)

V

vit_hidden_size (mstar.model.pi05.config.Pi05Config attribute) vit_image_size (mstar.model.pi05.config.Pi05Config attribute) vit_intermediate_size (mstar.model.pi05.config.Pi05Config attribute) vit_num_heads (mstar.model.pi05.config.Pi05Config attribute) vit_num_layers (mstar.model.pi05.config.Pi05Config attribute) vit_patch_size (mstar.model.pi05.config.Pi05Config attribute) VJepa2ACPredictorConfig (class in mstar.model.vjepa2.config) VJepa2Config (class in mstar.model.vjepa2.config) VJEPA2Embeddings (class in mstar.model.vjepa2.components.vit_encoder)

VJEPA2Encoder (class in mstar.model.vjepa2.components.vit_encoder) VJEPA2Layer (class in mstar.model.vjepa2.components.layers) VJEPA2MLP (class in mstar.model.vjepa2.components.layers) VJEPA2PatchEmbeddings3D (class in mstar.model.vjepa2.components.vit_encoder) VJEPA2Predictor (class in mstar.model.vjepa2.components.predictor) VJEPA2PredictorEmbeddings (class in mstar.model.vjepa2.components.predictor) VJEPA2RopeAttention (class in mstar.model.vjepa2.components.layers) vocab_size (mstar.model.orpheus.config.OrpheusModelConfig attribute) (mstar.model.pi05.config.Pi05Config attribute) voice (mstar.api_server.openai.protocol.SpeechRequest attribute)

W

wait_for_work() (mstar.communication.communicator.ZMQCommunicator method) wav_stream_header() (in module mstar.api_server.media_io) wg_fwd_pass_idx (mstar.graph.loop_indices.NestedLoopIndices attribute) window_size() (mstar.streaming.chunk_policy.ChunkPolicy method) (mstar.streaming.chunk_policy.FixedChunkPolicy method) (mstar.streaming.chunk_policy.LeftContextChunkPolicy method) (mstar.streaming.chunk_policy.SlidingWindowChunkPolicy method)

WorkerGraphIO (class in mstar.graph.graph_io) WorkerGraphStateRegistry (class in mstar.graph.base)

Z

ZMQCommunicator (class in mstar.communication.communicator)