scan

type PendingMessage struct {
	// MessageID is the ID of the pending message
	MessageID string
	// ConsumerName is the name of the consumer who was sent the pending message
	ConsumerName string
	// IdleTime is how much milliseconds have passed since the last time the message was delivered to the consumer
	IdleTime int
	// NumberOfDeliveries  is the number of times that this message was delivered to the consumer
	DeliveryCount int
}

type PendingMessages []PendingMessage

type StreamElement struct {
	// Name is the stream name
	Name string

	// Items is the stream items (ID and list of field-value pairs)
	Items []StreamItem
}

type StreamElements []StreamElement

type StreamGroup struct {
	// Consumers is the number of consumers in the group
	Consumers int
	// Pending is the number of the pending messages (not ACKED)
	Pending int
	// LastDeliveredId is the ID of the last delivered item
	LastDeliveredId string
}

type StreamGroups map[string]StreamGroup

type StreamItem struct {
	// ID is the item ID
	ID string

	// FieldValue represent the unscan list of field-value pairs
	FieldValues []string
}