Multi Stream Manager

[kkharji]

Goal

Enable library users to define event schema, consume them in parallel using an easy interface.

Draft

#[derive(RedisTransportValue)]
pub enum RoomServiceKind {
    Clean,
    ExtraTowels,
    ExtraPillows,
    FoodOrder,
}
/// Define stream model for room service
#[derive(StreamModel)]
#[redis(key = "room-service")]
pub struct RoomServiceStream {
    status: String,
    room: usize,
    kind: RoomServiceKind,
}

/// Define stream model for FrontOffice events
#[derive(StreamModel)
pub enum FrontOfficeStream {
	GuestCheckIn {
		guest_name: String,
		room_number: u32,
	}
}

/// Redis Stream Provider, items must derive steam model
#[derive(RedisEventProvider)
pub enum Event {
	RoomService(RoomServiceStream),
	FrontOffice(FrontOfficeStream)
}