List of all items

Structs

• AdmissionEvaluation
• AdmissionFacts
• Checkpoint
• log::LogEntry

Enums

• AckValidation
• MissedPolicy
• OpaqueSchemaValidation
• Outcome
• Resume
• log::LogLevel

Functions

• bulk_action_states
• codec::decode_checkpoint_bytes
• codec::decode_checkpoint_str
• codec::decode_checkpoint_value
• codec::decode_headers_bytes
• codec::decode_headers_str
• codec::decode_headers_value
• codec::decode_string_list
• codec::encode_checkpoint_json
• codec::encode_checkpoint_value
• codec::encode_headers_json
• codec::encode_headers_value
• codec::encode_string_list
• duration_millis
• effective_max_attempts
• effective_queue
• effective_schema_version
• effective_weight
• evaluate_admission
• format_generated_id
• inspection::age_ms
• inspection::time_to_drain_ms
• log::log_text
• normalize_queues
• valid_worker_command
• validate_ack
• validate_opaque_schema

Constants

• DEFAULT_MAX_ATTEMPTS
• DEFAULT_QUEUE
• DEFAULT_SCHEMA_VERSION
• DEFAULT_WEIGHT
• MAX_OPAQUE_SCHEMA_VERSION
• inspection::MAX_PAGE
• inspection::MEMORY_SAMPLE_LIMIT
• inspection::POSITION_LIMIT
• inspection::QUIET_PARTITION_LIMIT
• inspection::SAMPLE_LIMIT
• log::LOG_CAP_MESSAGE
• log::LOG_PREFIX
• log::MAX_LOG_BYTES
• log::MAX_LOG_FIELDS