scan

Documentation

Index

• type PendingMessage
• type PendingMessages
  • func ScanXPendingReply(reply interface{}, err error) (PendingMessages, error)
• type StreamElement
• type StreamElements
  • func ScanXReadReply(src []interface{}, dst StreamElements) (StreamElements, error)
• type StreamGroup
• type StreamGroups
  • func ScanXInfoGroupReply(reply interface{}, err error) (StreamGroups, error)
• type StreamItem

Types

type PendingMessage

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

type PendingMessages []PendingMessage

func ScanXPendingReply

func ScanXPendingReply(reply interface{}, err error) (PendingMessages, error)

type StreamElement

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

type StreamElements []StreamElement

func ScanXReadReply

func ScanXReadReply(src []interface{}, dst StreamElements) (StreamElements, error)

type StreamGroup

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

type StreamGroups map[string]StreamGroup

func ScanXInfoGroupReply

func ScanXInfoGroupReply(reply interface{}, err error) (StreamGroups, error)

type StreamItem

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

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