from google.protobuf import timestamp_pb2 as _timestamp_pb2 from . import metrics as _metrics from .logger_pb import options as _options_pb2 from google.protobuf.internal import containers as _containers from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import message as _message from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union DESCRIPTOR: _descriptor.FileDescriptor class AudioCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () DEFAULT_AC: _ClassVar[AudioCodec] OPUS: _ClassVar[AudioCodec] AAC: _ClassVar[AudioCodec] AC_MP3: _ClassVar[AudioCodec] class VideoCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () DEFAULT_VC: _ClassVar[VideoCodec] H264_BASELINE: _ClassVar[VideoCodec] H264_MAIN: _ClassVar[VideoCodec] H264_HIGH: _ClassVar[VideoCodec] VP8: _ClassVar[VideoCodec] class ImageCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () IC_DEFAULT: _ClassVar[ImageCodec] IC_JPEG: _ClassVar[ImageCodec] class BackupCodecPolicy(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () PREFER_REGRESSION: _ClassVar[BackupCodecPolicy] SIMULCAST: _ClassVar[BackupCodecPolicy] REGRESSION: _ClassVar[BackupCodecPolicy] class TrackType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () AUDIO: _ClassVar[TrackType] VIDEO: _ClassVar[TrackType] DATA: _ClassVar[TrackType] class TrackSource(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () UNKNOWN: _ClassVar[TrackSource] CAMERA: _ClassVar[TrackSource] MICROPHONE: _ClassVar[TrackSource] SCREEN_SHARE: _ClassVar[TrackSource] SCREEN_SHARE_AUDIO: _ClassVar[TrackSource] class DataTrackExtensionID(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () DTEI_INVALID: _ClassVar[DataTrackExtensionID] DTEI_PARTICIPANT_SID: _ClassVar[DataTrackExtensionID] class VideoQuality(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () LOW: _ClassVar[VideoQuality] MEDIUM: _ClassVar[VideoQuality] HIGH: _ClassVar[VideoQuality] OFF: _ClassVar[VideoQuality] class ConnectionQuality(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () POOR: _ClassVar[ConnectionQuality] GOOD: _ClassVar[ConnectionQuality] EXCELLENT: _ClassVar[ConnectionQuality] LOST: _ClassVar[ConnectionQuality] class ClientConfigSetting(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () UNSET: _ClassVar[ClientConfigSetting] DISABLED: _ClassVar[ClientConfigSetting] ENABLED: _ClassVar[ClientConfigSetting] class DisconnectReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () UNKNOWN_REASON: _ClassVar[DisconnectReason] CLIENT_INITIATED: _ClassVar[DisconnectReason] DUPLICATE_IDENTITY: _ClassVar[DisconnectReason] SERVER_SHUTDOWN: _ClassVar[DisconnectReason] PARTICIPANT_REMOVED: _ClassVar[DisconnectReason] ROOM_DELETED: _ClassVar[DisconnectReason] STATE_MISMATCH: _ClassVar[DisconnectReason] JOIN_FAILURE: _ClassVar[DisconnectReason] MIGRATION: _ClassVar[DisconnectReason] SIGNAL_CLOSE: _ClassVar[DisconnectReason] ROOM_CLOSED: _ClassVar[DisconnectReason] USER_UNAVAILABLE: _ClassVar[DisconnectReason] USER_REJECTED: _ClassVar[DisconnectReason] SIP_TRUNK_FAILURE: _ClassVar[DisconnectReason] CONNECTION_TIMEOUT: _ClassVar[DisconnectReason] MEDIA_FAILURE: _ClassVar[DisconnectReason] AGENT_ERROR: _ClassVar[DisconnectReason] class ReconnectReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () RR_UNKNOWN: _ClassVar[ReconnectReason] RR_SIGNAL_DISCONNECTED: _ClassVar[ReconnectReason] RR_PUBLISHER_FAILED: _ClassVar[ReconnectReason] RR_SUBSCRIBER_FAILED: _ClassVar[ReconnectReason] RR_SWITCH_CANDIDATE: _ClassVar[ReconnectReason] class SubscriptionError(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () SE_UNKNOWN: _ClassVar[SubscriptionError] SE_CODEC_UNSUPPORTED: _ClassVar[SubscriptionError] SE_TRACK_NOTFOUND: _ClassVar[SubscriptionError] class AudioTrackFeature(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () TF_STEREO: _ClassVar[AudioTrackFeature] TF_NO_DTX: _ClassVar[AudioTrackFeature] TF_AUTO_GAIN_CONTROL: _ClassVar[AudioTrackFeature] TF_ECHO_CANCELLATION: _ClassVar[AudioTrackFeature] TF_NOISE_SUPPRESSION: _ClassVar[AudioTrackFeature] TF_ENHANCED_NOISE_CANCELLATION: _ClassVar[AudioTrackFeature] TF_PRECONNECT_BUFFER: _ClassVar[AudioTrackFeature] class PacketTrailerFeature(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () PTF_USER_TIMESTAMP: _ClassVar[PacketTrailerFeature] PTF_FRAME_ID: _ClassVar[PacketTrailerFeature] DEFAULT_AC: AudioCodec OPUS: AudioCodec AAC: AudioCodec AC_MP3: AudioCodec DEFAULT_VC: VideoCodec H264_BASELINE: VideoCodec H264_MAIN: VideoCodec H264_HIGH: VideoCodec VP8: VideoCodec IC_DEFAULT: ImageCodec IC_JPEG: ImageCodec PREFER_REGRESSION: BackupCodecPolicy SIMULCAST: BackupCodecPolicy REGRESSION: BackupCodecPolicy AUDIO: TrackType VIDEO: TrackType DATA: TrackType UNKNOWN: TrackSource CAMERA: TrackSource MICROPHONE: TrackSource SCREEN_SHARE: TrackSource SCREEN_SHARE_AUDIO: TrackSource DTEI_INVALID: DataTrackExtensionID DTEI_PARTICIPANT_SID: DataTrackExtensionID LOW: VideoQuality MEDIUM: VideoQuality HIGH: VideoQuality OFF: VideoQuality POOR: ConnectionQuality GOOD: ConnectionQuality EXCELLENT: ConnectionQuality LOST: ConnectionQuality UNSET: ClientConfigSetting DISABLED: ClientConfigSetting ENABLED: ClientConfigSetting UNKNOWN_REASON: DisconnectReason CLIENT_INITIATED: DisconnectReason DUPLICATE_IDENTITY: DisconnectReason SERVER_SHUTDOWN: DisconnectReason PARTICIPANT_REMOVED: DisconnectReason ROOM_DELETED: DisconnectReason STATE_MISMATCH: DisconnectReason JOIN_FAILURE: DisconnectReason MIGRATION: DisconnectReason SIGNAL_CLOSE: DisconnectReason ROOM_CLOSED: DisconnectReason USER_UNAVAILABLE: DisconnectReason USER_REJECTED: DisconnectReason SIP_TRUNK_FAILURE: DisconnectReason CONNECTION_TIMEOUT: DisconnectReason MEDIA_FAILURE: DisconnectReason AGENT_ERROR: DisconnectReason RR_UNKNOWN: ReconnectReason RR_SIGNAL_DISCONNECTED: ReconnectReason RR_PUBLISHER_FAILED: ReconnectReason RR_SUBSCRIBER_FAILED: ReconnectReason RR_SWITCH_CANDIDATE: ReconnectReason SE_UNKNOWN: SubscriptionError SE_CODEC_UNSUPPORTED: SubscriptionError SE_TRACK_NOTFOUND: SubscriptionError TF_STEREO: AudioTrackFeature TF_NO_DTX: AudioTrackFeature TF_AUTO_GAIN_CONTROL: AudioTrackFeature TF_ECHO_CANCELLATION: AudioTrackFeature TF_NOISE_SUPPRESSION: AudioTrackFeature TF_ENHANCED_NOISE_CANCELLATION: AudioTrackFeature TF_PRECONNECT_BUFFER: AudioTrackFeature PTF_USER_TIMESTAMP: PacketTrailerFeature PTF_FRAME_ID: PacketTrailerFeature class Pagination(_message.Message): __slots__ = ("after_id", "limit") AFTER_ID_FIELD_NUMBER: _ClassVar[int] LIMIT_FIELD_NUMBER: _ClassVar[int] after_id: str limit: int def __init__(self, after_id: _Optional[str] = ..., limit: _Optional[int] = ...) -> None: ... class TokenPagination(_message.Message): __slots__ = ("token",) TOKEN_FIELD_NUMBER: _ClassVar[int] token: str def __init__(self, token: _Optional[str] = ...) -> None: ... class ListUpdate(_message.Message): __slots__ = ("set", "add", "remove", "clear") SET_FIELD_NUMBER: _ClassVar[int] ADD_FIELD_NUMBER: _ClassVar[int] REMOVE_FIELD_NUMBER: _ClassVar[int] CLEAR_FIELD_NUMBER: _ClassVar[int] set: _containers.RepeatedScalarFieldContainer[str] add: _containers.RepeatedScalarFieldContainer[str] remove: _containers.RepeatedScalarFieldContainer[str] clear: bool def __init__(self, set: _Optional[_Iterable[str]] = ..., add: _Optional[_Iterable[str]] = ..., remove: _Optional[_Iterable[str]] = ..., clear: bool = ...) -> None: ... class Room(_message.Message): __slots__ = ("sid", "name", "empty_timeout", "departure_timeout", "max_participants", "creation_time", "creation_time_ms", "turn_password", "enabled_codecs", "metadata", "num_participants", "num_publishers", "active_recording", "version") SID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] EMPTY_TIMEOUT_FIELD_NUMBER: _ClassVar[int] DEPARTURE_TIMEOUT_FIELD_NUMBER: _ClassVar[int] MAX_PARTICIPANTS_FIELD_NUMBER: _ClassVar[int] CREATION_TIME_FIELD_NUMBER: _ClassVar[int] CREATION_TIME_MS_FIELD_NUMBER: _ClassVar[int] TURN_PASSWORD_FIELD_NUMBER: _ClassVar[int] ENABLED_CODECS_FIELD_NUMBER: _ClassVar[int] METADATA_FIELD_NUMBER: _ClassVar[int] NUM_PARTICIPANTS_FIELD_NUMBER: _ClassVar[int] NUM_PUBLISHERS_FIELD_NUMBER: _ClassVar[int] ACTIVE_RECORDING_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] sid: str name: str empty_timeout: int departure_timeout: int max_participants: int creation_time: int creation_time_ms: int turn_password: str enabled_codecs: _containers.RepeatedCompositeFieldContainer[Codec] metadata: str num_participants: int num_publishers: int active_recording: bool version: TimedVersion def __init__(self, sid: _Optional[str] = ..., name: _Optional[str] = ..., empty_timeout: _Optional[int] = ..., departure_timeout: _Optional[int] = ..., max_participants: _Optional[int] = ..., creation_time: _Optional[int] = ..., creation_time_ms: _Optional[int] = ..., turn_password: _Optional[str] = ..., enabled_codecs: _Optional[_Iterable[_Union[Codec, _Mapping]]] = ..., metadata: _Optional[str] = ..., num_participants: _Optional[int] = ..., num_publishers: _Optional[int] = ..., active_recording: bool = ..., version: _Optional[_Union[TimedVersion, _Mapping]] = ...) -> None: ... class Codec(_message.Message): __slots__ = ("mime", "fmtp_line") MIME_FIELD_NUMBER: _ClassVar[int] FMTP_LINE_FIELD_NUMBER: _ClassVar[int] mime: str fmtp_line: str def __init__(self, mime: _Optional[str] = ..., fmtp_line: _Optional[str] = ...) -> None: ... class PlayoutDelay(_message.Message): __slots__ = ("enabled", "min", "max") ENABLED_FIELD_NUMBER: _ClassVar[int] MIN_FIELD_NUMBER: _ClassVar[int] MAX_FIELD_NUMBER: _ClassVar[int] enabled: bool min: int max: int def __init__(self, enabled: bool = ..., min: _Optional[int] = ..., max: _Optional[int] = ...) -> None: ... class ParticipantPermission(_message.Message): __slots__ = ("can_subscribe", "can_publish", "can_publish_data", "can_publish_sources", "hidden", "recorder", "can_update_metadata", "agent", "can_subscribe_metrics", "can_manage_agent_session") CAN_SUBSCRIBE_FIELD_NUMBER: _ClassVar[int] CAN_PUBLISH_FIELD_NUMBER: _ClassVar[int] CAN_PUBLISH_DATA_FIELD_NUMBER: _ClassVar[int] CAN_PUBLISH_SOURCES_FIELD_NUMBER: _ClassVar[int] HIDDEN_FIELD_NUMBER: _ClassVar[int] RECORDER_FIELD_NUMBER: _ClassVar[int] CAN_UPDATE_METADATA_FIELD_NUMBER: _ClassVar[int] AGENT_FIELD_NUMBER: _ClassVar[int] CAN_SUBSCRIBE_METRICS_FIELD_NUMBER: _ClassVar[int] CAN_MANAGE_AGENT_SESSION_FIELD_NUMBER: _ClassVar[int] can_subscribe: bool can_publish: bool can_publish_data: bool can_publish_sources: _containers.RepeatedScalarFieldContainer[TrackSource] hidden: bool recorder: bool can_update_metadata: bool agent: bool can_subscribe_metrics: bool can_manage_agent_session: bool def __init__(self, can_subscribe: bool = ..., can_publish: bool = ..., can_publish_data: bool = ..., can_publish_sources: _Optional[_Iterable[_Union[TrackSource, str]]] = ..., hidden: bool = ..., recorder: bool = ..., can_update_metadata: bool = ..., agent: bool = ..., can_subscribe_metrics: bool = ..., can_manage_agent_session: bool = ...) -> None: ... class ParticipantInfo(_message.Message): __slots__ = ("sid", "identity", "state", "tracks", "metadata", "joined_at", "joined_at_ms", "name", "version", "permission", "region", "is_publisher", "kind", "attributes", "disconnect_reason", "kind_details", "data_tracks", "client_protocol") class State(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () JOINING: _ClassVar[ParticipantInfo.State] JOINED: _ClassVar[ParticipantInfo.State] ACTIVE: _ClassVar[ParticipantInfo.State] DISCONNECTED: _ClassVar[ParticipantInfo.State] JOINING: ParticipantInfo.State JOINED: ParticipantInfo.State ACTIVE: ParticipantInfo.State DISCONNECTED: ParticipantInfo.State class Kind(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () STANDARD: _ClassVar[ParticipantInfo.Kind] INGRESS: _ClassVar[ParticipantInfo.Kind] EGRESS: _ClassVar[ParticipantInfo.Kind] SIP: _ClassVar[ParticipantInfo.Kind] AGENT: _ClassVar[ParticipantInfo.Kind] CONNECTOR: _ClassVar[ParticipantInfo.Kind] BRIDGE: _ClassVar[ParticipantInfo.Kind] STANDARD: ParticipantInfo.Kind INGRESS: ParticipantInfo.Kind EGRESS: ParticipantInfo.Kind SIP: ParticipantInfo.Kind AGENT: ParticipantInfo.Kind CONNECTOR: ParticipantInfo.Kind BRIDGE: ParticipantInfo.Kind class KindDetail(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () CLOUD_AGENT: _ClassVar[ParticipantInfo.KindDetail] FORWARDED: _ClassVar[ParticipantInfo.KindDetail] CONNECTOR_WHATSAPP: _ClassVar[ParticipantInfo.KindDetail] CONNECTOR_TWILIO: _ClassVar[ParticipantInfo.KindDetail] BRIDGE_RTSP: _ClassVar[ParticipantInfo.KindDetail] CLOUD_AGENT: ParticipantInfo.KindDetail FORWARDED: ParticipantInfo.KindDetail CONNECTOR_WHATSAPP: ParticipantInfo.KindDetail CONNECTOR_TWILIO: ParticipantInfo.KindDetail BRIDGE_RTSP: ParticipantInfo.KindDetail class AttributesEntry(_message.Message): __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str value: str def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... SID_FIELD_NUMBER: _ClassVar[int] IDENTITY_FIELD_NUMBER: _ClassVar[int] STATE_FIELD_NUMBER: _ClassVar[int] TRACKS_FIELD_NUMBER: _ClassVar[int] METADATA_FIELD_NUMBER: _ClassVar[int] JOINED_AT_FIELD_NUMBER: _ClassVar[int] JOINED_AT_MS_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] PERMISSION_FIELD_NUMBER: _ClassVar[int] REGION_FIELD_NUMBER: _ClassVar[int] IS_PUBLISHER_FIELD_NUMBER: _ClassVar[int] KIND_FIELD_NUMBER: _ClassVar[int] ATTRIBUTES_FIELD_NUMBER: _ClassVar[int] DISCONNECT_REASON_FIELD_NUMBER: _ClassVar[int] KIND_DETAILS_FIELD_NUMBER: _ClassVar[int] DATA_TRACKS_FIELD_NUMBER: _ClassVar[int] CLIENT_PROTOCOL_FIELD_NUMBER: _ClassVar[int] sid: str identity: str state: ParticipantInfo.State tracks: _containers.RepeatedCompositeFieldContainer[TrackInfo] metadata: str joined_at: int joined_at_ms: int name: str version: int permission: ParticipantPermission region: str is_publisher: bool kind: ParticipantInfo.Kind attributes: _containers.ScalarMap[str, str] disconnect_reason: DisconnectReason kind_details: _containers.RepeatedScalarFieldContainer[ParticipantInfo.KindDetail] data_tracks: _containers.RepeatedCompositeFieldContainer[DataTrackInfo] client_protocol: int def __init__(self, sid: _Optional[str] = ..., identity: _Optional[str] = ..., state: _Optional[_Union[ParticipantInfo.State, str]] = ..., tracks: _Optional[_Iterable[_Union[TrackInfo, _Mapping]]] = ..., metadata: _Optional[str] = ..., joined_at: _Optional[int] = ..., joined_at_ms: _Optional[int] = ..., name: _Optional[str] = ..., version: _Optional[int] = ..., permission: _Optional[_Union[ParticipantPermission, _Mapping]] = ..., region: _Optional[str] = ..., is_publisher: bool = ..., kind: _Optional[_Union[ParticipantInfo.Kind, str]] = ..., attributes: _Optional[_Mapping[str, str]] = ..., disconnect_reason: _Optional[_Union[DisconnectReason, str]] = ..., kind_details: _Optional[_Iterable[_Union[ParticipantInfo.KindDetail, str]]] = ..., data_tracks: _Optional[_Iterable[_Union[DataTrackInfo, _Mapping]]] = ..., client_protocol: _Optional[int] = ...) -> None: ... class Encryption(_message.Message): __slots__ = () class Type(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () NONE: _ClassVar[Encryption.Type] GCM: _ClassVar[Encryption.Type] CUSTOM: _ClassVar[Encryption.Type] NONE: Encryption.Type GCM: Encryption.Type CUSTOM: Encryption.Type def __init__(self) -> None: ... class SimulcastCodecInfo(_message.Message): __slots__ = ("mime_type", "mid", "cid", "layers", "video_layer_mode", "sdp_cid") MIME_TYPE_FIELD_NUMBER: _ClassVar[int] MID_FIELD_NUMBER: _ClassVar[int] CID_FIELD_NUMBER: _ClassVar[int] LAYERS_FIELD_NUMBER: _ClassVar[int] VIDEO_LAYER_MODE_FIELD_NUMBER: _ClassVar[int] SDP_CID_FIELD_NUMBER: _ClassVar[int] mime_type: str mid: str cid: str layers: _containers.RepeatedCompositeFieldContainer[VideoLayer] video_layer_mode: VideoLayer.Mode sdp_cid: str def __init__(self, mime_type: _Optional[str] = ..., mid: _Optional[str] = ..., cid: _Optional[str] = ..., layers: _Optional[_Iterable[_Union[VideoLayer, _Mapping]]] = ..., video_layer_mode: _Optional[_Union[VideoLayer.Mode, str]] = ..., sdp_cid: _Optional[str] = ...) -> None: ... class TrackInfo(_message.Message): __slots__ = ("sid", "type", "name", "muted", "width", "height", "simulcast", "disable_dtx", "source", "layers", "mime_type", "mid", "codecs", "stereo", "disable_red", "encryption", "stream", "version", "audio_features", "backup_codec_policy", "packet_trailer_features") SID_FIELD_NUMBER: _ClassVar[int] TYPE_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] MUTED_FIELD_NUMBER: _ClassVar[int] WIDTH_FIELD_NUMBER: _ClassVar[int] HEIGHT_FIELD_NUMBER: _ClassVar[int] SIMULCAST_FIELD_NUMBER: _ClassVar[int] DISABLE_DTX_FIELD_NUMBER: _ClassVar[int] SOURCE_FIELD_NUMBER: _ClassVar[int] LAYERS_FIELD_NUMBER: _ClassVar[int] MIME_TYPE_FIELD_NUMBER: _ClassVar[int] MID_FIELD_NUMBER: _ClassVar[int] CODECS_FIELD_NUMBER: _ClassVar[int] STEREO_FIELD_NUMBER: _ClassVar[int] DISABLE_RED_FIELD_NUMBER: _ClassVar[int] ENCRYPTION_FIELD_NUMBER: _ClassVar[int] STREAM_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] AUDIO_FEATURES_FIELD_NUMBER: _ClassVar[int] BACKUP_CODEC_POLICY_FIELD_NUMBER: _ClassVar[int] PACKET_TRAILER_FEATURES_FIELD_NUMBER: _ClassVar[int] sid: str type: TrackType name: str muted: bool width: int height: int simulcast: bool disable_dtx: bool source: TrackSource layers: _containers.RepeatedCompositeFieldContainer[VideoLayer] mime_type: str mid: str codecs: _containers.RepeatedCompositeFieldContainer[SimulcastCodecInfo] stereo: bool disable_red: bool encryption: Encryption.Type stream: str version: TimedVersion audio_features: _containers.RepeatedScalarFieldContainer[AudioTrackFeature] backup_codec_policy: BackupCodecPolicy packet_trailer_features: _containers.RepeatedScalarFieldContainer[PacketTrailerFeature] def __init__(self, sid: _Optional[str] = ..., type: _Optional[_Union[TrackType, str]] = ..., name: _Optional[str] = ..., muted: bool = ..., width: _Optional[int] = ..., height: _Optional[int] = ..., simulcast: bool = ..., disable_dtx: bool = ..., source: _Optional[_Union[TrackSource, str]] = ..., layers: _Optional[_Iterable[_Union[VideoLayer, _Mapping]]] = ..., mime_type: _Optional[str] = ..., mid: _Optional[str] = ..., codecs: _Optional[_Iterable[_Union[SimulcastCodecInfo, _Mapping]]] = ..., stereo: bool = ..., disable_red: bool = ..., encryption: _Optional[_Union[Encryption.Type, str]] = ..., stream: _Optional[str] = ..., version: _Optional[_Union[TimedVersion, _Mapping]] = ..., audio_features: _Optional[_Iterable[_Union[AudioTrackFeature, str]]] = ..., backup_codec_policy: _Optional[_Union[BackupCodecPolicy, str]] = ..., packet_trailer_features: _Optional[_Iterable[_Union[PacketTrailerFeature, str]]] = ...) -> None: ... class DataTrackInfo(_message.Message): __slots__ = ("pub_handle", "sid", "name", "encryption") PUB_HANDLE_FIELD_NUMBER: _ClassVar[int] SID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] ENCRYPTION_FIELD_NUMBER: _ClassVar[int] pub_handle: int sid: str name: str encryption: Encryption.Type def __init__(self, pub_handle: _Optional[int] = ..., sid: _Optional[str] = ..., name: _Optional[str] = ..., encryption: _Optional[_Union[Encryption.Type, str]] = ...) -> None: ... class DataTrackExtensionParticipantSid(_message.Message): __slots__ = ("id", "participant_sid") ID_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_SID_FIELD_NUMBER: _ClassVar[int] id: DataTrackExtensionID participant_sid: str def __init__(self, id: _Optional[_Union[DataTrackExtensionID, str]] = ..., participant_sid: _Optional[str] = ...) -> None: ... class DataTrackSubscriptionOptions(_message.Message): __slots__ = ("target_fps",) TARGET_FPS_FIELD_NUMBER: _ClassVar[int] target_fps: int def __init__(self, target_fps: _Optional[int] = ...) -> None: ... class VideoLayer(_message.Message): __slots__ = ("quality", "width", "height", "bitrate", "ssrc", "spatial_layer", "rid", "repair_ssrc") class Mode(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () MODE_UNUSED: _ClassVar[VideoLayer.Mode] ONE_SPATIAL_LAYER_PER_STREAM: _ClassVar[VideoLayer.Mode] MULTIPLE_SPATIAL_LAYERS_PER_STREAM: _ClassVar[VideoLayer.Mode] ONE_SPATIAL_LAYER_PER_STREAM_INCOMPLETE_RTCP_SR: _ClassVar[VideoLayer.Mode] MODE_UNUSED: VideoLayer.Mode ONE_SPATIAL_LAYER_PER_STREAM: VideoLayer.Mode MULTIPLE_SPATIAL_LAYERS_PER_STREAM: VideoLayer.Mode ONE_SPATIAL_LAYER_PER_STREAM_INCOMPLETE_RTCP_SR: VideoLayer.Mode QUALITY_FIELD_NUMBER: _ClassVar[int] WIDTH_FIELD_NUMBER: _ClassVar[int] HEIGHT_FIELD_NUMBER: _ClassVar[int] BITRATE_FIELD_NUMBER: _ClassVar[int] SSRC_FIELD_NUMBER: _ClassVar[int] SPATIAL_LAYER_FIELD_NUMBER: _ClassVar[int] RID_FIELD_NUMBER: _ClassVar[int] REPAIR_SSRC_FIELD_NUMBER: _ClassVar[int] quality: VideoQuality width: int height: int bitrate: int ssrc: int spatial_layer: int rid: str repair_ssrc: int def __init__(self, quality: _Optional[_Union[VideoQuality, str]] = ..., width: _Optional[int] = ..., height: _Optional[int] = ..., bitrate: _Optional[int] = ..., ssrc: _Optional[int] = ..., spatial_layer: _Optional[int] = ..., rid: _Optional[str] = ..., repair_ssrc: _Optional[int] = ...) -> None: ... class DataPacket(_message.Message): __slots__ = ("kind", "participant_identity", "destination_identities", "user", "speaker", "sip_dtmf", "transcription", "metrics", "chat_message", "rpc_request", "rpc_ack", "rpc_response", "stream_header", "stream_chunk", "stream_trailer", "encrypted_packet", "sequence", "participant_sid") class Kind(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () RELIABLE: _ClassVar[DataPacket.Kind] LOSSY: _ClassVar[DataPacket.Kind] RELIABLE: DataPacket.Kind LOSSY: DataPacket.Kind KIND_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_IDENTITY_FIELD_NUMBER: _ClassVar[int] DESTINATION_IDENTITIES_FIELD_NUMBER: _ClassVar[int] USER_FIELD_NUMBER: _ClassVar[int] SPEAKER_FIELD_NUMBER: _ClassVar[int] SIP_DTMF_FIELD_NUMBER: _ClassVar[int] TRANSCRIPTION_FIELD_NUMBER: _ClassVar[int] METRICS_FIELD_NUMBER: _ClassVar[int] CHAT_MESSAGE_FIELD_NUMBER: _ClassVar[int] RPC_REQUEST_FIELD_NUMBER: _ClassVar[int] RPC_ACK_FIELD_NUMBER: _ClassVar[int] RPC_RESPONSE_FIELD_NUMBER: _ClassVar[int] STREAM_HEADER_FIELD_NUMBER: _ClassVar[int] STREAM_CHUNK_FIELD_NUMBER: _ClassVar[int] STREAM_TRAILER_FIELD_NUMBER: _ClassVar[int] ENCRYPTED_PACKET_FIELD_NUMBER: _ClassVar[int] SEQUENCE_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_SID_FIELD_NUMBER: _ClassVar[int] kind: DataPacket.Kind participant_identity: str destination_identities: _containers.RepeatedScalarFieldContainer[str] user: UserPacket speaker: ActiveSpeakerUpdate sip_dtmf: SipDTMF transcription: Transcription metrics: _metrics.MetricsBatch chat_message: ChatMessage rpc_request: RpcRequest rpc_ack: RpcAck rpc_response: RpcResponse stream_header: DataStream.Header stream_chunk: DataStream.Chunk stream_trailer: DataStream.Trailer encrypted_packet: EncryptedPacket sequence: int participant_sid: str def __init__(self, kind: _Optional[_Union[DataPacket.Kind, str]] = ..., participant_identity: _Optional[str] = ..., destination_identities: _Optional[_Iterable[str]] = ..., user: _Optional[_Union[UserPacket, _Mapping]] = ..., speaker: _Optional[_Union[ActiveSpeakerUpdate, _Mapping]] = ..., sip_dtmf: _Optional[_Union[SipDTMF, _Mapping]] = ..., transcription: _Optional[_Union[Transcription, _Mapping]] = ..., metrics: _Optional[_Union[_metrics.MetricsBatch, _Mapping]] = ..., chat_message: _Optional[_Union[ChatMessage, _Mapping]] = ..., rpc_request: _Optional[_Union[RpcRequest, _Mapping]] = ..., rpc_ack: _Optional[_Union[RpcAck, _Mapping]] = ..., rpc_response: _Optional[_Union[RpcResponse, _Mapping]] = ..., stream_header: _Optional[_Union[DataStream.Header, _Mapping]] = ..., stream_chunk: _Optional[_Union[DataStream.Chunk, _Mapping]] = ..., stream_trailer: _Optional[_Union[DataStream.Trailer, _Mapping]] = ..., encrypted_packet: _Optional[_Union[EncryptedPacket, _Mapping]] = ..., sequence: _Optional[int] = ..., participant_sid: _Optional[str] = ...) -> None: ... class EncryptedPacket(_message.Message): __slots__ = ("encryption_type", "iv", "key_index", "encrypted_value") ENCRYPTION_TYPE_FIELD_NUMBER: _ClassVar[int] IV_FIELD_NUMBER: _ClassVar[int] KEY_INDEX_FIELD_NUMBER: _ClassVar[int] ENCRYPTED_VALUE_FIELD_NUMBER: _ClassVar[int] encryption_type: Encryption.Type iv: bytes key_index: int encrypted_value: bytes def __init__(self, encryption_type: _Optional[_Union[Encryption.Type, str]] = ..., iv: _Optional[bytes] = ..., key_index: _Optional[int] = ..., encrypted_value: _Optional[bytes] = ...) -> None: ... class EncryptedPacketPayload(_message.Message): __slots__ = ("user", "chat_message", "rpc_request", "rpc_ack", "rpc_response", "stream_header", "stream_chunk", "stream_trailer") USER_FIELD_NUMBER: _ClassVar[int] CHAT_MESSAGE_FIELD_NUMBER: _ClassVar[int] RPC_REQUEST_FIELD_NUMBER: _ClassVar[int] RPC_ACK_FIELD_NUMBER: _ClassVar[int] RPC_RESPONSE_FIELD_NUMBER: _ClassVar[int] STREAM_HEADER_FIELD_NUMBER: _ClassVar[int] STREAM_CHUNK_FIELD_NUMBER: _ClassVar[int] STREAM_TRAILER_FIELD_NUMBER: _ClassVar[int] user: UserPacket chat_message: ChatMessage rpc_request: RpcRequest rpc_ack: RpcAck rpc_response: RpcResponse stream_header: DataStream.Header stream_chunk: DataStream.Chunk stream_trailer: DataStream.Trailer def __init__(self, user: _Optional[_Union[UserPacket, _Mapping]] = ..., chat_message: _Optional[_Union[ChatMessage, _Mapping]] = ..., rpc_request: _Optional[_Union[RpcRequest, _Mapping]] = ..., rpc_ack: _Optional[_Union[RpcAck, _Mapping]] = ..., rpc_response: _Optional[_Union[RpcResponse, _Mapping]] = ..., stream_header: _Optional[_Union[DataStream.Header, _Mapping]] = ..., stream_chunk: _Optional[_Union[DataStream.Chunk, _Mapping]] = ..., stream_trailer: _Optional[_Union[DataStream.Trailer, _Mapping]] = ...) -> None: ... class ActiveSpeakerUpdate(_message.Message): __slots__ = ("speakers",) SPEAKERS_FIELD_NUMBER: _ClassVar[int] speakers: _containers.RepeatedCompositeFieldContainer[SpeakerInfo] def __init__(self, speakers: _Optional[_Iterable[_Union[SpeakerInfo, _Mapping]]] = ...) -> None: ... class SpeakerInfo(_message.Message): __slots__ = ("sid", "level", "active") SID_FIELD_NUMBER: _ClassVar[int] LEVEL_FIELD_NUMBER: _ClassVar[int] ACTIVE_FIELD_NUMBER: _ClassVar[int] sid: str level: float active: bool def __init__(self, sid: _Optional[str] = ..., level: _Optional[float] = ..., active: bool = ...) -> None: ... class UserPacket(_message.Message): __slots__ = ("participant_sid", "participant_identity", "payload", "destination_sids", "destination_identities", "topic", "id", "start_time", "end_time", "nonce") PARTICIPANT_SID_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_IDENTITY_FIELD_NUMBER: _ClassVar[int] PAYLOAD_FIELD_NUMBER: _ClassVar[int] DESTINATION_SIDS_FIELD_NUMBER: _ClassVar[int] DESTINATION_IDENTITIES_FIELD_NUMBER: _ClassVar[int] TOPIC_FIELD_NUMBER: _ClassVar[int] ID_FIELD_NUMBER: _ClassVar[int] START_TIME_FIELD_NUMBER: _ClassVar[int] END_TIME_FIELD_NUMBER: _ClassVar[int] NONCE_FIELD_NUMBER: _ClassVar[int] participant_sid: str participant_identity: str payload: bytes destination_sids: _containers.RepeatedScalarFieldContainer[str] destination_identities: _containers.RepeatedScalarFieldContainer[str] topic: str id: str start_time: int end_time: int nonce: bytes def __init__(self, participant_sid: _Optional[str] = ..., participant_identity: _Optional[str] = ..., payload: _Optional[bytes] = ..., destination_sids: _Optional[_Iterable[str]] = ..., destination_identities: _Optional[_Iterable[str]] = ..., topic: _Optional[str] = ..., id: _Optional[str] = ..., start_time: _Optional[int] = ..., end_time: _Optional[int] = ..., nonce: _Optional[bytes] = ...) -> None: ... class SipDTMF(_message.Message): __slots__ = ("code", "digit") CODE_FIELD_NUMBER: _ClassVar[int] DIGIT_FIELD_NUMBER: _ClassVar[int] code: int digit: str def __init__(self, code: _Optional[int] = ..., digit: _Optional[str] = ...) -> None: ... class Transcription(_message.Message): __slots__ = ("transcribed_participant_identity", "track_id", "segments") TRANSCRIBED_PARTICIPANT_IDENTITY_FIELD_NUMBER: _ClassVar[int] TRACK_ID_FIELD_NUMBER: _ClassVar[int] SEGMENTS_FIELD_NUMBER: _ClassVar[int] transcribed_participant_identity: str track_id: str segments: _containers.RepeatedCompositeFieldContainer[TranscriptionSegment] def __init__(self, transcribed_participant_identity: _Optional[str] = ..., track_id: _Optional[str] = ..., segments: _Optional[_Iterable[_Union[TranscriptionSegment, _Mapping]]] = ...) -> None: ... class TranscriptionSegment(_message.Message): __slots__ = ("id", "text", "start_time", "end_time", "final", "language") ID_FIELD_NUMBER: _ClassVar[int] TEXT_FIELD_NUMBER: _ClassVar[int] START_TIME_FIELD_NUMBER: _ClassVar[int] END_TIME_FIELD_NUMBER: _ClassVar[int] FINAL_FIELD_NUMBER: _ClassVar[int] LANGUAGE_FIELD_NUMBER: _ClassVar[int] id: str text: str start_time: int end_time: int final: bool language: str def __init__(self, id: _Optional[str] = ..., text: _Optional[str] = ..., start_time: _Optional[int] = ..., end_time: _Optional[int] = ..., final: bool = ..., language: _Optional[str] = ...) -> None: ... class ChatMessage(_message.Message): __slots__ = ("id", "timestamp", "edit_timestamp", "message", "deleted", "generated") ID_FIELD_NUMBER: _ClassVar[int] TIMESTAMP_FIELD_NUMBER: _ClassVar[int] EDIT_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] MESSAGE_FIELD_NUMBER: _ClassVar[int] DELETED_FIELD_NUMBER: _ClassVar[int] GENERATED_FIELD_NUMBER: _ClassVar[int] id: str timestamp: int edit_timestamp: int message: str deleted: bool generated: bool def __init__(self, id: _Optional[str] = ..., timestamp: _Optional[int] = ..., edit_timestamp: _Optional[int] = ..., message: _Optional[str] = ..., deleted: bool = ..., generated: bool = ...) -> None: ... class RpcRequest(_message.Message): __slots__ = ("id", "method", "payload", "response_timeout_ms", "version", "compressed_payload") ID_FIELD_NUMBER: _ClassVar[int] METHOD_FIELD_NUMBER: _ClassVar[int] PAYLOAD_FIELD_NUMBER: _ClassVar[int] RESPONSE_TIMEOUT_MS_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] COMPRESSED_PAYLOAD_FIELD_NUMBER: _ClassVar[int] id: str method: str payload: str response_timeout_ms: int version: int compressed_payload: bytes def __init__(self, id: _Optional[str] = ..., method: _Optional[str] = ..., payload: _Optional[str] = ..., response_timeout_ms: _Optional[int] = ..., version: _Optional[int] = ..., compressed_payload: _Optional[bytes] = ...) -> None: ... class RpcAck(_message.Message): __slots__ = ("request_id",) REQUEST_ID_FIELD_NUMBER: _ClassVar[int] request_id: str def __init__(self, request_id: _Optional[str] = ...) -> None: ... class RpcResponse(_message.Message): __slots__ = ("request_id", "payload", "error", "compressed_payload") REQUEST_ID_FIELD_NUMBER: _ClassVar[int] PAYLOAD_FIELD_NUMBER: _ClassVar[int] ERROR_FIELD_NUMBER: _ClassVar[int] COMPRESSED_PAYLOAD_FIELD_NUMBER: _ClassVar[int] request_id: str payload: str error: RpcError compressed_payload: bytes def __init__(self, request_id: _Optional[str] = ..., payload: _Optional[str] = ..., error: _Optional[_Union[RpcError, _Mapping]] = ..., compressed_payload: _Optional[bytes] = ...) -> None: ... class RpcError(_message.Message): __slots__ = ("code", "message", "data") CODE_FIELD_NUMBER: _ClassVar[int] MESSAGE_FIELD_NUMBER: _ClassVar[int] DATA_FIELD_NUMBER: _ClassVar[int] code: int message: str data: str def __init__(self, code: _Optional[int] = ..., message: _Optional[str] = ..., data: _Optional[str] = ...) -> None: ... class ParticipantTracks(_message.Message): __slots__ = ("participant_sid", "track_sids") PARTICIPANT_SID_FIELD_NUMBER: _ClassVar[int] TRACK_SIDS_FIELD_NUMBER: _ClassVar[int] participant_sid: str track_sids: _containers.RepeatedScalarFieldContainer[str] def __init__(self, participant_sid: _Optional[str] = ..., track_sids: _Optional[_Iterable[str]] = ...) -> None: ... class ServerInfo(_message.Message): __slots__ = ("edition", "version", "protocol", "region", "node_id", "debug_info", "agent_protocol") class Edition(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () Standard: _ClassVar[ServerInfo.Edition] Cloud: _ClassVar[ServerInfo.Edition] Standard: ServerInfo.Edition Cloud: ServerInfo.Edition EDITION_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] PROTOCOL_FIELD_NUMBER: _ClassVar[int] REGION_FIELD_NUMBER: _ClassVar[int] NODE_ID_FIELD_NUMBER: _ClassVar[int] DEBUG_INFO_FIELD_NUMBER: _ClassVar[int] AGENT_PROTOCOL_FIELD_NUMBER: _ClassVar[int] edition: ServerInfo.Edition version: str protocol: int region: str node_id: str debug_info: str agent_protocol: int def __init__(self, edition: _Optional[_Union[ServerInfo.Edition, str]] = ..., version: _Optional[str] = ..., protocol: _Optional[int] = ..., region: _Optional[str] = ..., node_id: _Optional[str] = ..., debug_info: _Optional[str] = ..., agent_protocol: _Optional[int] = ...) -> None: ... class ClientInfo(_message.Message): __slots__ = ("sdk", "version", "protocol", "os", "os_version", "device_model", "browser", "browser_version", "address", "network", "other_sdks", "client_protocol", "capabilities") class SDK(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () UNKNOWN: _ClassVar[ClientInfo.SDK] JS: _ClassVar[ClientInfo.SDK] SWIFT: _ClassVar[ClientInfo.SDK] ANDROID: _ClassVar[ClientInfo.SDK] FLUTTER: _ClassVar[ClientInfo.SDK] GO: _ClassVar[ClientInfo.SDK] UNITY: _ClassVar[ClientInfo.SDK] REACT_NATIVE: _ClassVar[ClientInfo.SDK] RUST: _ClassVar[ClientInfo.SDK] PYTHON: _ClassVar[ClientInfo.SDK] CPP: _ClassVar[ClientInfo.SDK] UNITY_WEB: _ClassVar[ClientInfo.SDK] NODE: _ClassVar[ClientInfo.SDK] UNREAL: _ClassVar[ClientInfo.SDK] ESP32: _ClassVar[ClientInfo.SDK] UNKNOWN: ClientInfo.SDK JS: ClientInfo.SDK SWIFT: ClientInfo.SDK ANDROID: ClientInfo.SDK FLUTTER: ClientInfo.SDK GO: ClientInfo.SDK UNITY: ClientInfo.SDK REACT_NATIVE: ClientInfo.SDK RUST: ClientInfo.SDK PYTHON: ClientInfo.SDK CPP: ClientInfo.SDK UNITY_WEB: ClientInfo.SDK NODE: ClientInfo.SDK UNREAL: ClientInfo.SDK ESP32: ClientInfo.SDK class Capability(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () CAP_UNUSED: _ClassVar[ClientInfo.Capability] CAP_PACKET_TRAILER: _ClassVar[ClientInfo.Capability] CAP_UNUSED: ClientInfo.Capability CAP_PACKET_TRAILER: ClientInfo.Capability SDK_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] PROTOCOL_FIELD_NUMBER: _ClassVar[int] OS_FIELD_NUMBER: _ClassVar[int] OS_VERSION_FIELD_NUMBER: _ClassVar[int] DEVICE_MODEL_FIELD_NUMBER: _ClassVar[int] BROWSER_FIELD_NUMBER: _ClassVar[int] BROWSER_VERSION_FIELD_NUMBER: _ClassVar[int] ADDRESS_FIELD_NUMBER: _ClassVar[int] NETWORK_FIELD_NUMBER: _ClassVar[int] OTHER_SDKS_FIELD_NUMBER: _ClassVar[int] CLIENT_PROTOCOL_FIELD_NUMBER: _ClassVar[int] CAPABILITIES_FIELD_NUMBER: _ClassVar[int] sdk: ClientInfo.SDK version: str protocol: int os: str os_version: str device_model: str browser: str browser_version: str address: str network: str other_sdks: str client_protocol: int capabilities: _containers.RepeatedScalarFieldContainer[ClientInfo.Capability] def __init__(self, sdk: _Optional[_Union[ClientInfo.SDK, str]] = ..., version: _Optional[str] = ..., protocol: _Optional[int] = ..., os: _Optional[str] = ..., os_version: _Optional[str] = ..., device_model: _Optional[str] = ..., browser: _Optional[str] = ..., browser_version: _Optional[str] = ..., address: _Optional[str] = ..., network: _Optional[str] = ..., other_sdks: _Optional[str] = ..., client_protocol: _Optional[int] = ..., capabilities: _Optional[_Iterable[_Union[ClientInfo.Capability, str]]] = ...) -> None: ... class ClientConfiguration(_message.Message): __slots__ = ("video", "screen", "resume_connection", "disabled_codecs", "force_relay") VIDEO_FIELD_NUMBER: _ClassVar[int] SCREEN_FIELD_NUMBER: _ClassVar[int] RESUME_CONNECTION_FIELD_NUMBER: _ClassVar[int] DISABLED_CODECS_FIELD_NUMBER: _ClassVar[int] FORCE_RELAY_FIELD_NUMBER: _ClassVar[int] video: VideoConfiguration screen: VideoConfiguration resume_connection: ClientConfigSetting disabled_codecs: DisabledCodecs force_relay: ClientConfigSetting def __init__(self, video: _Optional[_Union[VideoConfiguration, _Mapping]] = ..., screen: _Optional[_Union[VideoConfiguration, _Mapping]] = ..., resume_connection: _Optional[_Union[ClientConfigSetting, str]] = ..., disabled_codecs: _Optional[_Union[DisabledCodecs, _Mapping]] = ..., force_relay: _Optional[_Union[ClientConfigSetting, str]] = ...) -> None: ... class VideoConfiguration(_message.Message): __slots__ = ("hardware_encoder",) HARDWARE_ENCODER_FIELD_NUMBER: _ClassVar[int] hardware_encoder: ClientConfigSetting def __init__(self, hardware_encoder: _Optional[_Union[ClientConfigSetting, str]] = ...) -> None: ... class DisabledCodecs(_message.Message): __slots__ = ("codecs", "publish") CODECS_FIELD_NUMBER: _ClassVar[int] PUBLISH_FIELD_NUMBER: _ClassVar[int] codecs: _containers.RepeatedCompositeFieldContainer[Codec] publish: _containers.RepeatedCompositeFieldContainer[Codec] def __init__(self, codecs: _Optional[_Iterable[_Union[Codec, _Mapping]]] = ..., publish: _Optional[_Iterable[_Union[Codec, _Mapping]]] = ...) -> None: ... class RTPDrift(_message.Message): __slots__ = ("start_time", "end_time", "duration", "start_timestamp", "end_timestamp", "rtp_clock_ticks", "drift_samples", "drift_ms", "clock_rate") START_TIME_FIELD_NUMBER: _ClassVar[int] END_TIME_FIELD_NUMBER: _ClassVar[int] DURATION_FIELD_NUMBER: _ClassVar[int] START_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] END_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] RTP_CLOCK_TICKS_FIELD_NUMBER: _ClassVar[int] DRIFT_SAMPLES_FIELD_NUMBER: _ClassVar[int] DRIFT_MS_FIELD_NUMBER: _ClassVar[int] CLOCK_RATE_FIELD_NUMBER: _ClassVar[int] start_time: _timestamp_pb2.Timestamp end_time: _timestamp_pb2.Timestamp duration: float start_timestamp: int end_timestamp: int rtp_clock_ticks: int drift_samples: int drift_ms: float clock_rate: float def __init__(self, start_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., end_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., duration: _Optional[float] = ..., start_timestamp: _Optional[int] = ..., end_timestamp: _Optional[int] = ..., rtp_clock_ticks: _Optional[int] = ..., drift_samples: _Optional[int] = ..., drift_ms: _Optional[float] = ..., clock_rate: _Optional[float] = ...) -> None: ... class RTPStats(_message.Message): __slots__ = ("start_time", "end_time", "duration", "packets", "packet_rate", "bytes", "header_bytes", "bitrate", "packets_lost", "packet_loss_rate", "packet_loss_percentage", "packets_duplicate", "packet_duplicate_rate", "bytes_duplicate", "header_bytes_duplicate", "bitrate_duplicate", "packets_padding", "packet_padding_rate", "bytes_padding", "header_bytes_padding", "bitrate_padding", "packets_out_of_order", "frames", "frame_rate", "jitter_current", "jitter_max", "gap_histogram", "nacks", "nack_acks", "nack_misses", "nack_repeated", "plis", "last_pli", "firs", "last_fir", "rtt_current", "rtt_max", "key_frames", "last_key_frame", "layer_lock_plis", "last_layer_lock_pli", "packet_drift", "ntp_report_drift", "rebased_report_drift", "received_report_drift") class GapHistogramEntry(_message.Message): __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: int value: int def __init__(self, key: _Optional[int] = ..., value: _Optional[int] = ...) -> None: ... START_TIME_FIELD_NUMBER: _ClassVar[int] END_TIME_FIELD_NUMBER: _ClassVar[int] DURATION_FIELD_NUMBER: _ClassVar[int] PACKETS_FIELD_NUMBER: _ClassVar[int] PACKET_RATE_FIELD_NUMBER: _ClassVar[int] BYTES_FIELD_NUMBER: _ClassVar[int] HEADER_BYTES_FIELD_NUMBER: _ClassVar[int] BITRATE_FIELD_NUMBER: _ClassVar[int] PACKETS_LOST_FIELD_NUMBER: _ClassVar[int] PACKET_LOSS_RATE_FIELD_NUMBER: _ClassVar[int] PACKET_LOSS_PERCENTAGE_FIELD_NUMBER: _ClassVar[int] PACKETS_DUPLICATE_FIELD_NUMBER: _ClassVar[int] PACKET_DUPLICATE_RATE_FIELD_NUMBER: _ClassVar[int] BYTES_DUPLICATE_FIELD_NUMBER: _ClassVar[int] HEADER_BYTES_DUPLICATE_FIELD_NUMBER: _ClassVar[int] BITRATE_DUPLICATE_FIELD_NUMBER: _ClassVar[int] PACKETS_PADDING_FIELD_NUMBER: _ClassVar[int] PACKET_PADDING_RATE_FIELD_NUMBER: _ClassVar[int] BYTES_PADDING_FIELD_NUMBER: _ClassVar[int] HEADER_BYTES_PADDING_FIELD_NUMBER: _ClassVar[int] BITRATE_PADDING_FIELD_NUMBER: _ClassVar[int] PACKETS_OUT_OF_ORDER_FIELD_NUMBER: _ClassVar[int] FRAMES_FIELD_NUMBER: _ClassVar[int] FRAME_RATE_FIELD_NUMBER: _ClassVar[int] JITTER_CURRENT_FIELD_NUMBER: _ClassVar[int] JITTER_MAX_FIELD_NUMBER: _ClassVar[int] GAP_HISTOGRAM_FIELD_NUMBER: _ClassVar[int] NACKS_FIELD_NUMBER: _ClassVar[int] NACK_ACKS_FIELD_NUMBER: _ClassVar[int] NACK_MISSES_FIELD_NUMBER: _ClassVar[int] NACK_REPEATED_FIELD_NUMBER: _ClassVar[int] PLIS_FIELD_NUMBER: _ClassVar[int] LAST_PLI_FIELD_NUMBER: _ClassVar[int] FIRS_FIELD_NUMBER: _ClassVar[int] LAST_FIR_FIELD_NUMBER: _ClassVar[int] RTT_CURRENT_FIELD_NUMBER: _ClassVar[int] RTT_MAX_FIELD_NUMBER: _ClassVar[int] KEY_FRAMES_FIELD_NUMBER: _ClassVar[int] LAST_KEY_FRAME_FIELD_NUMBER: _ClassVar[int] LAYER_LOCK_PLIS_FIELD_NUMBER: _ClassVar[int] LAST_LAYER_LOCK_PLI_FIELD_NUMBER: _ClassVar[int] PACKET_DRIFT_FIELD_NUMBER: _ClassVar[int] NTP_REPORT_DRIFT_FIELD_NUMBER: _ClassVar[int] REBASED_REPORT_DRIFT_FIELD_NUMBER: _ClassVar[int] RECEIVED_REPORT_DRIFT_FIELD_NUMBER: _ClassVar[int] start_time: _timestamp_pb2.Timestamp end_time: _timestamp_pb2.Timestamp duration: float packets: int packet_rate: float bytes: int header_bytes: int bitrate: float packets_lost: int packet_loss_rate: float packet_loss_percentage: float packets_duplicate: int packet_duplicate_rate: float bytes_duplicate: int header_bytes_duplicate: int bitrate_duplicate: float packets_padding: int packet_padding_rate: float bytes_padding: int header_bytes_padding: int bitrate_padding: float packets_out_of_order: int frames: int frame_rate: float jitter_current: float jitter_max: float gap_histogram: _containers.ScalarMap[int, int] nacks: int nack_acks: int nack_misses: int nack_repeated: int plis: int last_pli: _timestamp_pb2.Timestamp firs: int last_fir: _timestamp_pb2.Timestamp rtt_current: int rtt_max: int key_frames: int last_key_frame: _timestamp_pb2.Timestamp layer_lock_plis: int last_layer_lock_pli: _timestamp_pb2.Timestamp packet_drift: RTPDrift ntp_report_drift: RTPDrift rebased_report_drift: RTPDrift received_report_drift: RTPDrift def __init__(self, start_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., end_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., duration: _Optional[float] = ..., packets: _Optional[int] = ..., packet_rate: _Optional[float] = ..., bytes: _Optional[int] = ..., header_bytes: _Optional[int] = ..., bitrate: _Optional[float] = ..., packets_lost: _Optional[int] = ..., packet_loss_rate: _Optional[float] = ..., packet_loss_percentage: _Optional[float] = ..., packets_duplicate: _Optional[int] = ..., packet_duplicate_rate: _Optional[float] = ..., bytes_duplicate: _Optional[int] = ..., header_bytes_duplicate: _Optional[int] = ..., bitrate_duplicate: _Optional[float] = ..., packets_padding: _Optional[int] = ..., packet_padding_rate: _Optional[float] = ..., bytes_padding: _Optional[int] = ..., header_bytes_padding: _Optional[int] = ..., bitrate_padding: _Optional[float] = ..., packets_out_of_order: _Optional[int] = ..., frames: _Optional[int] = ..., frame_rate: _Optional[float] = ..., jitter_current: _Optional[float] = ..., jitter_max: _Optional[float] = ..., gap_histogram: _Optional[_Mapping[int, int]] = ..., nacks: _Optional[int] = ..., nack_acks: _Optional[int] = ..., nack_misses: _Optional[int] = ..., nack_repeated: _Optional[int] = ..., plis: _Optional[int] = ..., last_pli: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., firs: _Optional[int] = ..., last_fir: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., rtt_current: _Optional[int] = ..., rtt_max: _Optional[int] = ..., key_frames: _Optional[int] = ..., last_key_frame: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., layer_lock_plis: _Optional[int] = ..., last_layer_lock_pli: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., packet_drift: _Optional[_Union[RTPDrift, _Mapping]] = ..., ntp_report_drift: _Optional[_Union[RTPDrift, _Mapping]] = ..., rebased_report_drift: _Optional[_Union[RTPDrift, _Mapping]] = ..., received_report_drift: _Optional[_Union[RTPDrift, _Mapping]] = ...) -> None: ... class RTCPSenderReportState(_message.Message): __slots__ = ("rtp_timestamp", "rtp_timestamp_ext", "ntp_timestamp", "at", "at_adjusted", "packets", "octets") RTP_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] RTP_TIMESTAMP_EXT_FIELD_NUMBER: _ClassVar[int] NTP_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] AT_FIELD_NUMBER: _ClassVar[int] AT_ADJUSTED_FIELD_NUMBER: _ClassVar[int] PACKETS_FIELD_NUMBER: _ClassVar[int] OCTETS_FIELD_NUMBER: _ClassVar[int] rtp_timestamp: int rtp_timestamp_ext: int ntp_timestamp: int at: int at_adjusted: int packets: int octets: int def __init__(self, rtp_timestamp: _Optional[int] = ..., rtp_timestamp_ext: _Optional[int] = ..., ntp_timestamp: _Optional[int] = ..., at: _Optional[int] = ..., at_adjusted: _Optional[int] = ..., packets: _Optional[int] = ..., octets: _Optional[int] = ...) -> None: ... class RTPForwarderState(_message.Message): __slots__ = ("started", "reference_layer_spatial", "pre_start_time", "ext_first_timestamp", "dummy_start_timestamp_offset", "rtp_munger", "vp8_munger", "sender_report_state") STARTED_FIELD_NUMBER: _ClassVar[int] REFERENCE_LAYER_SPATIAL_FIELD_NUMBER: _ClassVar[int] PRE_START_TIME_FIELD_NUMBER: _ClassVar[int] EXT_FIRST_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] DUMMY_START_TIMESTAMP_OFFSET_FIELD_NUMBER: _ClassVar[int] RTP_MUNGER_FIELD_NUMBER: _ClassVar[int] VP8_MUNGER_FIELD_NUMBER: _ClassVar[int] SENDER_REPORT_STATE_FIELD_NUMBER: _ClassVar[int] started: bool reference_layer_spatial: int pre_start_time: int ext_first_timestamp: int dummy_start_timestamp_offset: int rtp_munger: RTPMungerState vp8_munger: VP8MungerState sender_report_state: _containers.RepeatedCompositeFieldContainer[RTCPSenderReportState] def __init__(self, started: bool = ..., reference_layer_spatial: _Optional[int] = ..., pre_start_time: _Optional[int] = ..., ext_first_timestamp: _Optional[int] = ..., dummy_start_timestamp_offset: _Optional[int] = ..., rtp_munger: _Optional[_Union[RTPMungerState, _Mapping]] = ..., vp8_munger: _Optional[_Union[VP8MungerState, _Mapping]] = ..., sender_report_state: _Optional[_Iterable[_Union[RTCPSenderReportState, _Mapping]]] = ...) -> None: ... class RTPMungerState(_message.Message): __slots__ = ("ext_last_sequence_number", "ext_second_last_sequence_number", "ext_last_timestamp", "ext_second_last_timestamp", "last_marker", "second_last_marker") EXT_LAST_SEQUENCE_NUMBER_FIELD_NUMBER: _ClassVar[int] EXT_SECOND_LAST_SEQUENCE_NUMBER_FIELD_NUMBER: _ClassVar[int] EXT_LAST_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] EXT_SECOND_LAST_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] LAST_MARKER_FIELD_NUMBER: _ClassVar[int] SECOND_LAST_MARKER_FIELD_NUMBER: _ClassVar[int] ext_last_sequence_number: int ext_second_last_sequence_number: int ext_last_timestamp: int ext_second_last_timestamp: int last_marker: bool second_last_marker: bool def __init__(self, ext_last_sequence_number: _Optional[int] = ..., ext_second_last_sequence_number: _Optional[int] = ..., ext_last_timestamp: _Optional[int] = ..., ext_second_last_timestamp: _Optional[int] = ..., last_marker: bool = ..., second_last_marker: bool = ...) -> None: ... class VP8MungerState(_message.Message): __slots__ = ("ext_last_picture_id", "picture_id_used", "last_tl0_pic_idx", "tl0_pic_idx_used", "tid_used", "last_key_idx", "key_idx_used") EXT_LAST_PICTURE_ID_FIELD_NUMBER: _ClassVar[int] PICTURE_ID_USED_FIELD_NUMBER: _ClassVar[int] LAST_TL0_PIC_IDX_FIELD_NUMBER: _ClassVar[int] TL0_PIC_IDX_USED_FIELD_NUMBER: _ClassVar[int] TID_USED_FIELD_NUMBER: _ClassVar[int] LAST_KEY_IDX_FIELD_NUMBER: _ClassVar[int] KEY_IDX_USED_FIELD_NUMBER: _ClassVar[int] ext_last_picture_id: int picture_id_used: bool last_tl0_pic_idx: int tl0_pic_idx_used: bool tid_used: bool last_key_idx: int key_idx_used: bool def __init__(self, ext_last_picture_id: _Optional[int] = ..., picture_id_used: bool = ..., last_tl0_pic_idx: _Optional[int] = ..., tl0_pic_idx_used: bool = ..., tid_used: bool = ..., last_key_idx: _Optional[int] = ..., key_idx_used: bool = ...) -> None: ... class TimedVersion(_message.Message): __slots__ = ("unix_micro", "ticks") UNIX_MICRO_FIELD_NUMBER: _ClassVar[int] TICKS_FIELD_NUMBER: _ClassVar[int] unix_micro: int ticks: int def __init__(self, unix_micro: _Optional[int] = ..., ticks: _Optional[int] = ...) -> None: ... class DataStream(_message.Message): __slots__ = () class OperationType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): __slots__ = () CREATE: _ClassVar[DataStream.OperationType] UPDATE: _ClassVar[DataStream.OperationType] DELETE: _ClassVar[DataStream.OperationType] REACTION: _ClassVar[DataStream.OperationType] CREATE: DataStream.OperationType UPDATE: DataStream.OperationType DELETE: DataStream.OperationType REACTION: DataStream.OperationType class TextHeader(_message.Message): __slots__ = ("operation_type", "version", "reply_to_stream_id", "attached_stream_ids", "generated") OPERATION_TYPE_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] REPLY_TO_STREAM_ID_FIELD_NUMBER: _ClassVar[int] ATTACHED_STREAM_IDS_FIELD_NUMBER: _ClassVar[int] GENERATED_FIELD_NUMBER: _ClassVar[int] operation_type: DataStream.OperationType version: int reply_to_stream_id: str attached_stream_ids: _containers.RepeatedScalarFieldContainer[str] generated: bool def __init__(self, operation_type: _Optional[_Union[DataStream.OperationType, str]] = ..., version: _Optional[int] = ..., reply_to_stream_id: _Optional[str] = ..., attached_stream_ids: _Optional[_Iterable[str]] = ..., generated: bool = ...) -> None: ... class ByteHeader(_message.Message): __slots__ = ("name",) NAME_FIELD_NUMBER: _ClassVar[int] name: str def __init__(self, name: _Optional[str] = ...) -> None: ... class Header(_message.Message): __slots__ = ("stream_id", "timestamp", "topic", "mime_type", "total_length", "encryption_type", "attributes", "text_header", "byte_header") class AttributesEntry(_message.Message): __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str value: str def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... STREAM_ID_FIELD_NUMBER: _ClassVar[int] TIMESTAMP_FIELD_NUMBER: _ClassVar[int] TOPIC_FIELD_NUMBER: _ClassVar[int] MIME_TYPE_FIELD_NUMBER: _ClassVar[int] TOTAL_LENGTH_FIELD_NUMBER: _ClassVar[int] ENCRYPTION_TYPE_FIELD_NUMBER: _ClassVar[int] ATTRIBUTES_FIELD_NUMBER: _ClassVar[int] TEXT_HEADER_FIELD_NUMBER: _ClassVar[int] BYTE_HEADER_FIELD_NUMBER: _ClassVar[int] stream_id: str timestamp: int topic: str mime_type: str total_length: int encryption_type: Encryption.Type attributes: _containers.ScalarMap[str, str] text_header: DataStream.TextHeader byte_header: DataStream.ByteHeader def __init__(self, stream_id: _Optional[str] = ..., timestamp: _Optional[int] = ..., topic: _Optional[str] = ..., mime_type: _Optional[str] = ..., total_length: _Optional[int] = ..., encryption_type: _Optional[_Union[Encryption.Type, str]] = ..., attributes: _Optional[_Mapping[str, str]] = ..., text_header: _Optional[_Union[DataStream.TextHeader, _Mapping]] = ..., byte_header: _Optional[_Union[DataStream.ByteHeader, _Mapping]] = ...) -> None: ... class Chunk(_message.Message): __slots__ = ("stream_id", "chunk_index", "content", "version", "iv") STREAM_ID_FIELD_NUMBER: _ClassVar[int] CHUNK_INDEX_FIELD_NUMBER: _ClassVar[int] CONTENT_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] IV_FIELD_NUMBER: _ClassVar[int] stream_id: str chunk_index: int content: bytes version: int iv: bytes def __init__(self, stream_id: _Optional[str] = ..., chunk_index: _Optional[int] = ..., content: _Optional[bytes] = ..., version: _Optional[int] = ..., iv: _Optional[bytes] = ...) -> None: ... class Trailer(_message.Message): __slots__ = ("stream_id", "reason", "attributes") class AttributesEntry(_message.Message): __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str value: str def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... STREAM_ID_FIELD_NUMBER: _ClassVar[int] REASON_FIELD_NUMBER: _ClassVar[int] ATTRIBUTES_FIELD_NUMBER: _ClassVar[int] stream_id: str reason: str attributes: _containers.ScalarMap[str, str] def __init__(self, stream_id: _Optional[str] = ..., reason: _Optional[str] = ..., attributes: _Optional[_Mapping[str, str]] = ...) -> None: ... def __init__(self) -> None: ... class FilterParams(_message.Message): __slots__ = ("include_events", "exclude_events") INCLUDE_EVENTS_FIELD_NUMBER: _ClassVar[int] EXCLUDE_EVENTS_FIELD_NUMBER: _ClassVar[int] include_events: _containers.RepeatedScalarFieldContainer[str] exclude_events: _containers.RepeatedScalarFieldContainer[str] def __init__(self, include_events: _Optional[_Iterable[str]] = ..., exclude_events: _Optional[_Iterable[str]] = ...) -> None: ... class WebhookConfig(_message.Message): __slots__ = ("url", "signing_key", "filter_params") URL_FIELD_NUMBER: _ClassVar[int] SIGNING_KEY_FIELD_NUMBER: _ClassVar[int] FILTER_PARAMS_FIELD_NUMBER: _ClassVar[int] url: str signing_key: str filter_params: FilterParams def __init__(self, url: _Optional[str] = ..., signing_key: _Optional[str] = ..., filter_params: _Optional[_Union[FilterParams, _Mapping]] = ...) -> None: ... class SubscribedAudioCodec(_message.Message): __slots__ = ("codec", "enabled") CODEC_FIELD_NUMBER: _ClassVar[int] ENABLED_FIELD_NUMBER: _ClassVar[int] codec: str enabled: bool def __init__(self, codec: _Optional[str] = ..., enabled: bool = ...) -> None: ...