Struct vector::sources::dnstap::tcp::TcpConfig

pub struct TcpConfig {
    pub port_key: OptionalValuePath,
    pub connection_limit: Option<u32>,
    /* private fields */
}

TCP configuration for the dnstap source.

Fields

port_key: OptionalValuePath

Overrides the name of the log field used to add the peer host’s port to each event.

The value will be the peer host’s port i.e. 9000.

By default, "port" is used.

Set to "" to suppress this key.

connection_limit: Option<u32>

The maximum number of TCP connections that are allowed at any given time.

Implementations

impl TcpConfig

pub fn from_address(address: SocketListenAddr) -> Self

pub const fn port_key(&self) -> &OptionalValuePath

pub const fn tls(&self) -> &Option<TlsSourceConfig>

pub const fn address(&self) -> SocketListenAddr

pub const fn keepalive(&self) -> Option<TcpKeepaliveConfig>

pub const fn shutdown_timeout_secs(&self) -> Duration

pub const fn receive_buffer_bytes(&self) -> Option<usize>

pub const fn max_connection_duration_secs(&self) -> Option<u64>

Trait Implementations

impl Clone for TcpConfig

fn clone(&self) -> TcpConfig

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Configurable for TcpConfig

fn referenceable_name() -> Option<&'static str>

Gets the referenceable name of this value, if any.

fn metadata() -> Metadata

Gets the metadata for this value.

fn generate_schema( schema_gen: &RefCell<SchemaGenerator>, ) -> Result<SchemaObject, GenerateError>

Generates the schema for this value.

fn is_optional() -> bool

where Self: Sized,

Whether or not this value is optional.

fn validate_metadata(_metadata: &Metadata) -> Result<(), GenerateError>

where Self: Sized,

Validates the given metadata against this type.

fn as_configurable_ref() -> ConfigurableRef

where Self: Sized + 'static,

Create a new configurable reference table.

impl Debug for TcpConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TcpConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TcpConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToValue for TcpConfig

fn to_value(&self) -> Value

Convert this value into a serde_json::Value. Must not fail.