Struct LocalSystemParamsManager

pub struct LocalSystemParamsManager {
    params: SystemParamsReaderRef,
    tx: Sender<SystemParamsReaderRef>,
}

The system parameter manager on worker nodes. It provides two methods for other components to read the latest system parameters:

• get_params returns a reference to the latest parameters that is atomically updated.
• watch_params returns a channel on which calling recv will get the latest parameters. Compared with get_params, the caller can be explicitly notified of parameter change.

Fields

params: SystemParamsReaderRef

The latest parameters.

tx: Sender<SystemParamsReaderRef>

Sender of the latest parameters.

Implementations

impl LocalSystemParamsManager

pub fn new(initial_params: SystemParamsReader) -> Self

Create a new instance of LocalSystemParamsManager and spawn a task to run the common handler.

pub fn for_test() -> Self

fn new_inner(initial_params: SystemParamsReader) -> Self

pub fn get_params(&self) -> SystemParamsReaderRef

pub fn try_set_params(&self, new_params: SystemParams)

pub fn watch_params(&self) -> Receiver<SystemParamsReaderRef>

Trait Implementations

impl Debug for LocalSystemParamsManager

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

Formats the value using the given formatter.