Struct pingora_core::server::configuration::ServerConf

source ·
pub struct ServerConf {
Show 17 fields pub version: usize, pub daemon: bool, pub error_log: Option<String>, pub pid_file: String, pub upgrade_sock: String, pub user: Option<String>, pub group: Option<String>, pub threads: usize, pub work_stealing: bool, pub ca_file: Option<String>, pub grace_period_seconds: Option<u64>, pub graceful_shutdown_timeout_seconds: Option<u64>, pub client_bind_to_ipv4: Vec<String>, pub client_bind_to_ipv6: Vec<String>, pub upstream_keepalive_pool_size: usize, pub upstream_connect_offload_threadpools: Option<usize>, pub upstream_connect_offload_thread_per_pool: Option<usize>,
}
Expand description

The configuration file

Pingora configuration files are by default YAML files, but any key value format can potentially be used.

§Extension

New keys can be added to the configuration files which this configuration object will ignore. Then, users can parse these key-values to pass to their code to use.

Fields§

§version: usize

Version

§daemon: bool

Whether to run this process in the background.

§error_log: Option<String>

When configured, error log will be written to the given file. Otherwise StdErr will be used.

§pid_file: String

The pid (process ID) file of this server

§upgrade_sock: String

the path to the upgrade socket

In order to perform zero downtime restart, both the new and old process need to agree on the path to this sock in order to coordinate the upgrade.

§user: Option<String>

If configured, after daemonization, this process will switch to the given user before starting to serve traffic.

§group: Option<String>

Similar to user, the group this process should switch to.

§threads: usize

How many threads each service should get. The threads are not shared across services.

§work_stealing: bool

Allow work stealing between threads of the same service. Default true.

§ca_file: Option<String>

The path to CA file the SSL library should use. If empty, the default trust store location defined by the SSL library will be used.

§grace_period_seconds: Option<u64>

Grace period in seconds before starting the final step of the graceful shutdown after signaling shutdown.

§graceful_shutdown_timeout_seconds: Option<u64>

Timeout in seconds of the final step for the graceful shutdown.

§client_bind_to_ipv4: Vec<String>

IPv4 addresses for a client connector to bind to. See [ConnectorOptions]. Note: this is an unstable field that may be renamed or removed in the future.

§client_bind_to_ipv6: Vec<String>

IPv6 addresses for a client connector to bind to. See [ConnectorOptions]. Note: this is an unstable field that may be renamed or removed in the future.

§upstream_keepalive_pool_size: usize

Keepalive pool size for client connections to upstream. See [ConnectorOptions]. Note: this is an unstable field that may be renamed or removed in the future.

§upstream_connect_offload_threadpools: Option<usize>

Number of dedicated thread pools to use for upstream connection establishment. See [ConnectorOptions]. Note: this is an unstable field that may be renamed or removed in the future.

§upstream_connect_offload_thread_per_pool: Option<usize>

Number of threads per dedicated upstream connection establishment pool. See [ConnectorOptions]. Note: this is an unstable field that may be renamed or removed in the future.

Implementations§

source§

impl ServerConf

source

pub fn load_from_yaml<P>(path: P) -> Result<Self>
where P: AsRef<Path> + Display,

source

pub fn load_yaml_with_opt_override(opt: &Opt) -> Result<Self>

source

pub fn new() -> Option<Self>

source

pub fn new_with_opt_override(opt: &Opt) -> Option<Self>

source

pub fn from_yaml(conf_str: &str) -> Result<Self>

source

pub fn to_yaml(&self) -> String

source

pub fn validate(self) -> Result<Self>

source

pub fn merge_with_opt(&mut self, opt: &Opt)

Trait Implementations§

source§

impl Debug for ServerConf

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for ServerConf

source§

fn default() -> Self

Returns the “default value” for a type. Read more
source§

impl<'de> Deserialize<'de> for ServerConf

source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
source§

impl PartialEq for ServerConf

source§

fn eq(&self, other: &ServerConf) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl Serialize for ServerConf

source§

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

Serialize this value into the given Serde serializer. Read more
source§

impl Eq for ServerConf

source§

impl StructuralPartialEq for ServerConf

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

source§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,