timely/dataflow/operators/generic/
operator_info.rs

1use std::rc::Rc;
2
3/// Information about the operator being constructed
4#[derive(Clone)]
5pub struct OperatorInfo {
6    /// Scope-local index assigned to the operator being constructed.
7    pub local_id: usize,
8    /// Worker-unique identifier.
9    pub global_id: usize,
10    /// Operator address.
11    pub address: Rc<[usize]>,
12}
13
14impl OperatorInfo {
15    /// Construct a new `OperatorInfo`.
16    pub fn new(local_id: usize, global_id: usize, address: Rc<[usize]>) -> OperatorInfo {
17        OperatorInfo {
18            local_id,
19            global_id,
20            address,
21        }
22    }
23}