List of all items

Structs

• checkpoint::assignment::AssignmentDrainId
• checkpoint::assignment::AssignmentDrainTransition
• checkpoint::assignment::CheckpointAssignmentAdoption
• checkpoint::assignment::CheckpointAssignmentFence
• checkpoint::assignment::CheckpointParticipant
• checkpoint::attempt::ArchivedCheckpointAttempt
• checkpoint::attempt::CheckpointAttempt
• checkpoint::attempt::CheckpointAttemptResolver
• checkpoint::authority::LeaderProof
• checkpoint::authority::LeaderProofOwner
• checkpoint::barrier::BarrierPollHandle
• checkpoint::barrier::CheckpointBarrier
• checkpoint::barrier::CheckpointBarrierInjector
• checkpoint::checkpoint_manifest::ByteRange
• checkpoint::checkpoint_manifest::ChannelProgress
• checkpoint::checkpoint_manifest::CheckpointManifest
• checkpoint::checkpoint_manifest::ConnectorCheckpoint
• checkpoint::checkpoint_manifest::ManifestValidationError
• checkpoint::checkpoint_manifest::NodeDataObject
• checkpoint::checkpoint_manifest::PipelineIdentity
• checkpoint::checkpoint_manifest::PreparedSinkArtifactIntent
• checkpoint::checkpoint_manifest::PreparedSinkDescriptor
• checkpoint::checkpoint_manifest::ReferencedStateChunk
• checkpoint::checkpoint_manifest::StateChunkId
• checkpoint::checkpoint_manifest::StateFrame
• checkpoint::checkpoint_store::CheckpointManifestAbortSeal
• checkpoint::checkpoint_store::CheckpointSinkArtifactIntent
• checkpoint::checkpoint_store::ObjectStoreCheckpointStore
• checkpoint::checkpoint_store::SubscriptionOrphanCleanup
• checkpoint::committed_checkpoint::CommittedCheckpointIndex
• checkpoint::committed_checkpoint::CommittedCheckpointRef
• checkpoint::committed_checkpoint::CommittedParticipantRef
• checkpoint::subscription::MergedSubscriptionCheckpoint
• checkpoint::subscription::NodePartitionRange
• checkpoint::subscription::NodeSubscriptionManifest
• checkpoint::subscription::NodeSubscriptionStreamManifest
• checkpoint::subscription::OutputDistributionCertificate
• checkpoint::subscription::OutputFrameId
• checkpoint::subscription::OutputPartitionId
• checkpoint::subscription::OutputSegmentRef
• checkpoint::subscription::PartitionFrontier
• checkpoint::subscription::PartitionSequence
• checkpoint::subscription::StreamGeneration
• checkpoint::subscription::SubscriptionCheckpointManifest
• checkpoint::subscription::SubscriptionDigest
• checkpoint::subscription::SubscriptionProtocolVersion
• checkpoint_decision::CheckpointArtifactInventory
• checkpoint_decision::CheckpointDecisionHead
• checkpoint_decision::CheckpointDecisionStore
• checkpoint_decision::CheckpointOutcome
• checkpoint_decision::CheckpointRetentionCursor
• checkpoint_decision::CheckpointSinkOpenWitness
• cluster::control::LeaseDeadline
• cluster::control::NamespaceProofError
• cluster::control::VerifiedClusterNamespaces
• cluster::control::barrier::BarrierAck
• cluster::control::barrier::BarrierAnnouncement
• cluster::control::barrier::BarrierCoordinator
• cluster::control::barrier::InMemoryKv
• cluster::control::catalog_manifest::CatalogManifest
• cluster::control::catalog_manifest::CatalogManifestEntry
• cluster::control::catalog_manifest::CatalogManifestRef
• cluster::control::catalog_manifest::CatalogManifestStore
• cluster::control::chitchat_kv::ChitchatKv
• cluster::control::controller::ClusterController
• cluster::control::controller::LocalProcessAuthorityEvidence
• cluster::control::controller::LocalProcessAuthorityIdentity
• cluster::control::controller::RecoveryAdmissionSnapshot
• cluster::control::controller::RecoveryAnnouncement
• cluster::control::controller::RecoveryFault
• cluster::control::controller::RecoveryFaultInventory
• cluster::control::controller::RecoveryFaultRequest
• cluster::control::controller::RecoveryReleaseGuard
• cluster::control::controller::RecoveryRound
• cluster::control::controller::RecoveryRoundId
• cluster::control::controller::RecoveryStoppedReport
• cluster::control::leader_lease::AssignmentDrainDecision
• cluster::control::leader_lease::AssignmentRecoveryDecision
• cluster::control::leader_lease::ClusterArtifactCleanupCursor
• cluster::control::leader_lease::ClusterOutcomeInventory
• cluster::control::leader_lease::ClusterOutcomeRetentionBoundary
• cluster::control::leader_lease::LeaderCandidacy
• cluster::control::leader_lease::LeaderLease
• cluster::control::leader_lease::LeaderLeaseConfig
• cluster::control::leader_lease::LeaderLeaseManager
• cluster::control::leader_lease::LeaderLeaseObservation
• cluster::control::leader_lease::LeaderLeaseOwner
• cluster::control::leader_lease::LeaderLeaseStore
• cluster::control::leader_lease::SubscriptionReplayPin
• cluster::control::process_lease::ProcessLease
• cluster::control::process_lease::ProcessLeaseAuthority
• cluster::control::process_lease::ProcessLeaseConfig
• cluster::control::process_lease::ProcessLeaseFence
• cluster::control::process_lease::ProcessLeaseManager
• cluster::control::process_lease::ProcessLeaseObservation
• cluster::control::process_lease::ProcessLeaseStore
• cluster::control::snapshot::AssignmentSnapshot
• cluster::control::snapshot::AssignmentSnapshotRef
• cluster::control::snapshot::AssignmentSnapshotStore
• cluster::control::tls::ClusterTls
• cluster::discovery::ArchivedNodeInfo
• cluster::discovery::ArchivedNodeMetadata
• cluster::discovery::GossipDiscovery
• cluster::discovery::GossipDiscoveryConfig
• cluster::discovery::NodeInfo
• cluster::discovery::NodeInfoResolver
• cluster::discovery::NodeMetadata
• cluster::discovery::NodeMetadataResolver
• cluster::discovery::StaticDiscovery
• cluster::discovery::StaticDiscoveryConfig
• cluster::testing::FaultyObjectStore
• cluster::testing::MiniCluster
• cluster::testing::NetworkRules
• cluster::testing::NodeHandle
• cluster::testing::PartitionableTransport
• lookup::align::KeyAligner
• lookup::lookup_cache::LookupCacheKey
• lookup::lookup_cache::LookupMemoryCache
• lookup::lookup_cache::LookupMemoryCacheConfig
• lookup::predicate::SourceCapabilities
• lookup::predicate::SplitPredicates
• lookup::source::LookupSourceCapabilities
• lookup::source::PushdownAdapter
• mv::MaterializedView
• mv::MvRegistry
• operator::Event
• operator::sliding_window::SlidingWindowAssigner
• operator::sliding_window::SlidingWindowIter
• operator::window::ChangelogRecord
• operator::window::TumblingWindowAssigner
• operator::window::WindowAssignmentError
• operator::window::WindowId
• serialization::BatchStreamDecoder
• serialization::BoundedBytesWriter
• shuffle::routing::CheckpointRoutePlan
• shuffle::routing::LocalRoute
• shuffle::routing::RemoteRoute
• shuffle::transport::ReceivedBatch
• shuffle::transport::ReceivedFrontierCut
• shuffle::transport::ReceivedShuffle
• shuffle::transport::ShuffleBatchAdmission
• shuffle::transport::ShuffleReceiver
• shuffle::transport::ShuffleSender
• state::partition_key::PartitionKeyCodecV1
• state::partition_key::PartitionKeySchemaV1
• state::vnode::ArchivedNodeId
• state::vnode::InvalidKeyGroupCount
• state::vnode::KeyGroupCount
• state::vnode::Locality
• state::vnode::NodeId
• state::vnode::NodeIdResolver
• state::vnode::VnodeAssignmentReadGuard
• state::vnode::VnodeAssignmentSnapshot
• state::vnode::VnodeRegistry
• storage_location::AdaptedStorageLocation
• storage_location::EndpointOverride
• storage_location::StorageLocation
• streaming::channel::AsyncConsumer
• streaming::channel::Producer
• streaming::checkpoint::StreamCheckpointConfig
• streaming::config::ChannelConfig
• streaming::config::SourceConfig
• streaming::error::TryPushError
• streaming::sink::Sink
• streaming::source::Source
• streaming::subscription::Subscription
• time::AscendingTimestampsGenerator
• time::BoundedOutOfOrdernessGenerator
• time::CastError
• time::EventTimeExtractor
• time::PeriodicGenerator
• time::ProcessingTimeGenerator
• time::PunctuatedGenerator
• time::SourceProvidedGenerator
• time::TimerRegistration
• time::TimerService
• time::Watermark
• time::WatermarkRestoreError
• time::WatermarkTracker

Enums

• Error
• catalog::CatalogObjectKind
• checkpoint::attempt::CheckpointAttemptRelation
• checkpoint::barrier::StreamMessage
• checkpoint::checkpoint_manifest::StateFrameKey
• checkpoint::checkpoint_store::CheckpointStoreError
• checkpoint::committed_checkpoint::CheckpointScope
• checkpoint::committed_checkpoint::CheckpointWatermark
• checkpoint::object_store_builder::CheckpointStorageScope
• checkpoint::object_store_builder::ObjectStoreBuilderError
• checkpoint::subscription::ChangelogMode
• checkpoint::subscription::OutputDistribution
• checkpoint::subscription::SubscriptionContractError
• checkpoint_decision::CheckpointArtifactInventoryUpdateResult
• checkpoint_decision::CheckpointRetentionState
• checkpoint_decision::CheckpointRetentionUpdateResult
• checkpoint_decision::CheckpointVerdict
• checkpoint_decision::DecisionError
• checkpoint_decision::RecordOutcomeResult
• cluster::control::barrier::BarrierAckDisposition
• cluster::control::barrier::Phase
• cluster::control::barrier::QuorumOutcome
• cluster::control::catalog_manifest::CatalogManifestError
• cluster::control::catalog_manifest::CatalogSealOutcome
• cluster::control::controller::CheckpointPrepareObservation
• cluster::control::controller::LocalProcessAuthorityEvidenceError
• cluster::control::controller::RecoverPhase
• cluster::control::controller::RecoveryControlError
• cluster::control::controller::RecoveryFaultDisposition
• cluster::control::controller::RecoveryFaultReportOutcome
• cluster::control::controller::ReleaseCommitStatus
• cluster::control::leader_lease::AssignmentDrainVerdict
• cluster::control::leader_lease::ClusterArtifactCleanupPhase
• cluster::control::leader_lease::ClusterAttemptStatus
• cluster::control::leader_lease::ClusterCheckpointAuthorityError
• cluster::control::leader_lease::LeaseError
• cluster::control::leader_lease::LeaseOutcome
• cluster::control::leader_lease::RecordAssignmentDrainDecisionResult
• cluster::control::leader_lease::RecordAssignmentRecoveryDecisionResult
• cluster::control::leader_lease::SubscriptionReplayPinAcquire
• cluster::control::process_lease::ProcessLeaseError
• cluster::control::process_lease::ProcessLeaseOutcome
• cluster::control::snapshot::RotateOutcome
• cluster::control::snapshot::SnapshotError
• cluster::discovery::ArchivedNodeState
• cluster::discovery::DiscoveryError
• cluster::discovery::MembershipEvent
• cluster::discovery::NodeState
• cluster::discovery::NodeStateResolver
• cluster::testing::ObjectStoreFault
• durable_fs::DurableRenameMode
• error_codes::HotPathError
• error_codes::WarningSeverity
• gcs_credentials::GcsCredentialError
• lookup::LookupResult
• lookup::predicate::Predicate
• lookup::predicate::ScalarValue
• lookup::source::LookupError
• mv::MvError
• mv::MvState
• operator::OperatorError
• operator::window::CdcOperation
• operator::window::EmitStrategy
• shuffle::message::ShuffleMessage
• shuffle::routing::ShuffleRoutingError
• state::partition_key::PartitionKeyCodecError
• storage_auth::AuthSource
• storage_location::StorageConsumer
• storage_location::StorageEndpointClass
• storage_location::StorageLocationError
• storage_location::StorageProvider
• streaming::config::BackpressureStrategy
• streaming::config::WaitStrategy
• streaming::error::RecvError
• streaming::error::StreamingError
• time::EventTimeError
• time::ExtractionMode
• time::FilterError
• time::ThresholdOp
• time::TimeError
• time::TimestampField

Traits

• checkpoint::checkpoint_store::CheckpointStore
• cluster::control::barrier::ClusterKv
• cluster::discovery::Discovery
• lookup::source::LookupSource
• lookup::source::LookupSourceDyn
• operator::window::WindowAssigner
• streaming::source::Record
• time::WatermarkGenerator

Functions

• checkpoint::barrier::decode_shuffle_flush_flags
• checkpoint::barrier::encode_shuffle_flush_flags
• checkpoint::channel_progress_frontier
• checkpoint::channel_progress_frontiers_by_source
• checkpoint::checkpoint_manifest::checkpoint_artifact_intent_sha256
• checkpoint::checkpoint_manifest::checkpoint_descriptor_sha256
• checkpoint::checkpoint_manifest::checkpoint_sha256
• checkpoint::checkpoint_store::checkpoint_artifact_identity_sha256
• checkpoint::checkpoint_store::checkpoint_manifest_bytes
• checkpoint::checkpoint_store::probe_object_store_conditional_create
• checkpoint::checkpoint_store::probe_object_store_conditional_update
• checkpoint::checkpoint_store::validate_max_checkpoint_node_data_bytes
• checkpoint::classify_channel_progress
• checkpoint::committed_checkpoint::canonical_json_bytes
• checkpoint::committed_checkpoint::canonical_json_sha256
• checkpoint::object_store_builder::build_object_store
• checkpoint::object_store_builder::durable_local_object_store
• checkpoint::object_store_builder::file_url_path
• checkpoint::object_store_builder::is_absolute_local_file_url
• checkpoint::subscription::merge_node_subscription_manifests
• cluster::control::leader::leader_of
• cluster::control::leader_lease::lease_grants_leadership
• cluster::control::leader_lease::lease_grants_proof
• cluster::control::prove_shared_object_store_namespaces
• cluster::control::tls::claim_cluster_plaintext
• cluster::control::tls::set_cluster_tls
• cluster::discovery::assignable_node_ids
• durable_fs::durable_rename
• durable_fs::ensure_durable_directory
• gcs_credentials::configure_gcs_workload_identity
• gcs_credentials::gcs_workload_identity_provider
• lookup::predicate::predicate_to_sql
• lookup::predicate::split_predicates
• lookup::source::projection_names
• serialization::deserialize_batch_stream
• serialization::serialize_batch_stream
• serialization::serialize_batches_stream_bounded
• serialization::serialize_batches_stream_lz4_bounded
• shuffle::routing::logical_batch_bytes
• shuffle::routing::route_checkpointed_batch
• shuffle::routing::row_vnodes
• shuffle::transport::is_scope_cancelled
• shuffle::transport::shuffle_send_may_have_been_admitted
• state::vnode::key_hash
• state::vnode::owned_vnodes
• state::vnode::owners_per_domain
• state::vnode::peer_owners
• state::vnode::rendezvous_assignment
• storage_auth::classify_storage_auth_source
• streaming::channel::channel
• streaming::source::create
• streaming::source::create_with_config
• time::cast_to_millis_array
• time::filter_batch_by_timestamp
• time::now_unix_millis
• time::parse_duration_str

Type Aliases

• Result
• lookup::source::ColumnId
• operator::TimerKey
• operator::window::WindowIdVec
• shuffle::transport::ShufflePeerId
• time::FiredTimersVec
• time::TimerKey

Constants

• changelog::WEIGHT_COLUMN
• checkpoint::SINGLETON_WATERMARK_CHANNEL
• checkpoint::assignment::MAX_CHECKPOINT_PARTICIPANTS
• checkpoint::barrier::MAX_SHUFFLE_FLUSH_WAVE
• checkpoint::barrier::flags::CANCEL
• checkpoint::barrier::flags::DRAIN
• checkpoint::barrier::flags::FULL_SNAPSHOT
• checkpoint::barrier::flags::HANDOFF
• checkpoint::barrier::flags::NONE
• checkpoint::checkpoint_manifest::CHECKPOINT_MANIFEST_VERSION
• checkpoint::checkpoint_manifest::PIPELINE_IDENTITY_VERSION
• checkpoint::checkpoint_manifest::PREPARED_SINK_DESCRIPTOR_VERSION
• checkpoint::checkpoint_store::DEFAULT_MAX_CHECKPOINT_NODE_DATA_BYTES
• checkpoint::checkpoint_store::MAX_CHECKPOINT_SINK_ARTIFACT_INTENT_AGGREGATE_BYTES
• checkpoint::checkpoint_store::MAX_CHECKPOINT_SINK_ARTIFACT_INTENT_BYTES
• checkpoint::committed_checkpoint::COMMITTED_CHECKPOINT_INDEX_VERSION
• checkpoint::committed_checkpoint::MAX_COMMITTED_CHECKPOINT_INDEX_BYTES
• checkpoint::subscription::MAX_OUTPUT_FRAMES_PER_SEGMENT
• checkpoint::subscription::MAX_OUTPUT_SEGMENTS_PER_MANIFEST
• checkpoint::subscription::MAX_OUTPUT_SEGMENT_BYTES
• checkpoint::subscription::MAX_SUBSCRIPTION_MANIFEST_BYTES
• checkpoint::subscription::OUTPUT_DISTRIBUTION_CERTIFICATE_VERSION
• checkpoint::subscription::SUBSCRIPTION_PROTOCOL_VERSION
• cluster::control::MAX_SHARED_NAMESPACE_PROOF_TIMEOUT
• cluster::control::barrier::ACK_KEY
• cluster::control::barrier::ANNOUNCEMENT_KEY
• cluster::control::barrier::BARRIER_ADDR_KEY
• cluster::control::leader_lease::SUBSCRIPTION_REPLAY_PIN_RENEW_INTERVAL
• cluster::discovery::keys::FAILURE_DOMAIN
• cluster::discovery::keys::LOAD_CORES
• cluster::discovery::keys::LOAD_MEMORY
• cluster::discovery::keys::METADATA_TAGS
• cluster::discovery::keys::NODE_NAME
• cluster::discovery::keys::NODE_STATE
• cluster::discovery::keys::NODE_VERSION
• cluster::discovery::keys::PROTOCOL_VERSION
• cluster::discovery::keys::RPC_ADDRESS
• error_codes::ARROW_ERROR
• error_codes::BASE64_DECODE_ERROR
• error_codes::CHECKPOINT_FAILED
• error_codes::CHECKPOINT_NOT_FOUND
• error_codes::CHECKPOINT_PRUNE_FAILED
• error_codes::CLUSTER_STATE_LIFECYCLE_UNSUPPORTED
• error_codes::CONNECTOR_AUTH_FAILED
• error_codes::CONNECTOR_CONFIG_ERROR
• error_codes::CONNECTOR_CONNECTION_FAILED
• error_codes::CONNECTOR_READ_ERROR
• error_codes::CONNECTOR_SCHEMA_ERROR
• error_codes::CONNECTOR_SERDE_ERROR
• error_codes::CONNECTOR_WRITE_ERROR
• error_codes::DELIVERY_STATE_DURABILITY_MISMATCH
• error_codes::DESERIALIZATION_FAILED
• error_codes::EXACTLY_ONCE_NON_REPLAYABLE
• error_codes::EXACTLY_ONCE_NO_CHECKPOINT
• error_codes::EXACTLY_ONCE_PROTOCOL_INCOMPLETE
• error_codes::EXACTLY_ONCE_SINK_UNSUPPORTED
• error_codes::EXACTLY_ONCE_SOURCE_UNCERTIFIED
• error_codes::INTERNAL
• error_codes::INVALID_CONFIG
• error_codes::INVALID_OPERATION
• error_codes::JOIN_KEY_MISSING
• error_codes::JOIN_TIME_BOUND_MISSING
• error_codes::JOIN_TYPE_UNSUPPORTED
• error_codes::JSON_PARSE_ERROR
• error_codes::LATE_DATA_REJECTED
• error_codes::MANAGED_STATE_BUDGET_EXCEEDED
• error_codes::MANIFEST_PERSIST_FAILED
• error_codes::MATERIALIZED_VIEW_ERROR
• error_codes::MISSING_CONFIG
• error_codes::MIXED_DELIVERY_CAPABILITIES
• error_codes::NO_COMPILED_PROJECTION
• error_codes::OFFSET_METADATA_MISSING
• error_codes::PIPELINE_ERROR
• error_codes::PLAN_OPTIMIZATION_FAILED
• error_codes::QUERY_EXECUTION_FAILED
• error_codes::QUERY_PIPELINE_ERROR
• error_codes::RECOVERY_FAILED
• error_codes::SCHEMA_MISMATCH
• error_codes::SERIALIZATION_FAILED
• error_codes::SHUTDOWN
• error_codes::SINK_ALREADY_EXISTS
• error_codes::SINK_NOT_FOUND
• error_codes::SINK_ROLLBACK_FAILED
• error_codes::SOURCE_ALREADY_EXISTS
• error_codes::SOURCE_CHECKPOINT_REQUIRED
• error_codes::SOURCE_MUTATION_NOT_ADMITTED
• error_codes::SOURCE_NOT_FOUND
• error_codes::SOURCE_PRIMARY_KEY_REQUIRED
• error_codes::SQL_COLUMN_NOT_FOUND
• error_codes::SQL_PLANNING_FAILED
• error_codes::SQL_TABLE_NOT_FOUND
• error_codes::SQL_TYPE_MISMATCH
• error_codes::SQL_UNSUPPORTED
• error_codes::STATE_CORRUPTION
• error_codes::STATE_KEY_MISSING
• error_codes::SUBSCRIPTION_ASSIGNMENT_CHANGED
• error_codes::SUBSCRIPTION_BACKEND_UNAVAILABLE
• error_codes::SUBSCRIPTION_CONFLICTING_DUPLICATE
• error_codes::SUBSCRIPTION_EPOCH_NOT_COMMITTED
• error_codes::SUBSCRIPTION_GENERATION_MISMATCH
• error_codes::SUBSCRIPTION_LAGGED
• error_codes::SUBSCRIPTION_MANIFEST_CORRUPT
• error_codes::SUBSCRIPTION_PLAN_UNSUPPORTED
• error_codes::SUBSCRIPTION_PROTOCOL_UNSUPPORTED
• error_codes::SUBSCRIPTION_REPLAY_PRUNED
• error_codes::SUBSCRIPTION_RESUME_TOKEN_EXPIRED
• error_codes::SUBSCRIPTION_RESUME_TOKEN_INVALID
• error_codes::SUBSCRIPTION_RETENTION_LOST
• error_codes::SUBSCRIPTION_SCHEMA_MISMATCH
• error_codes::SUBSCRIPTION_SEGMENT_CORRUPT
• error_codes::SUBSCRIPTION_SEGMENT_MISSING
• error_codes::SUBSCRIPTION_SEQUENCE_GAP
• error_codes::SUBSCRIPTION_STALE_WRITER
• error_codes::TEMPORAL_JOIN_NO_PK
• error_codes::UNRESOLVED_CONFIG_VAR
• error_codes::WAL_CHECKSUM_MISMATCH
• error_codes::WAL_ERROR
• error_codes::WAL_INVALID_LENGTH
• error_codes::WATERMARK_REQUIRED
• error_codes::WINDOW_INVALID
• error_codes::WINDOW_SIZE_INVALID
• serialization::jsonb_tags::ARRAY
• serialization::jsonb_tags::BOOL_FALSE
• serialization::jsonb_tags::BOOL_TRUE
• serialization::jsonb_tags::FLOAT64
• serialization::jsonb_tags::INT64
• serialization::jsonb_tags::NULL
• serialization::jsonb_tags::OBJECT
• serialization::jsonb_tags::STRING
• shuffle::message::MAX_PAYLOAD_BYTES
• shuffle::routing::ROUTE_MAX_BATCH_BYTES
• shuffle::routing::ROUTE_MAX_BATCH_ROWS
• shuffle::routing::ROUTE_TARGET_BATCH_BYTES
• shuffle::transport::SHUFFLE_ADDR_KEY
• state::vnode::DEFAULT_KEY_GROUP_COUNT
• state::vnode::LOCAL_NODE_ID
• state::vnode::MAX_KEY_GROUP_COUNT
• state::vnode::PARTITIONING_ABI_VERSION
• streaming::config::DEFAULT_BUFFER_SIZE
• streaming::config::MAX_BUFFER_SIZE
• streaming::config::MIN_BUFFER_SIZE
• time::DEFAULT_MAX_FUTURE_SKEW_MS