yozefu-lib 0.0.30

Core library of yozefu
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use crate::{ConsumerGroupDetail, ConsumerGroupMember, ConsumerGroupState};

#[test]
fn test_lag() {
    let consumer_detail = ConsumerGroupDetail {
        name: "my-topic".to_string(),
        members: vec![
            ConsumerGroupMember {
                member: "member-1".to_string(),
                start_offset: 0,
                end_offset: 100,
                assignments: vec![],
            },
            ConsumerGroupMember {
                member: "member-2".to_string(),
                start_offset: 45,
                end_offset: 50,
                assignments: vec![],
            },
        ],
        state: ConsumerGroupState::Empty,
    };
    assert_eq!(consumer_detail.lag(), 105);
}