lib

type AdminStore struct {
	// contains filtered or unexported fields
}

type LagInfo struct {
	// ConsumerGroup is the consumer group name
	ConsumerGroup string
	// Topic is the topic being consumed
	Topic string
	// PartitionKey is the partition being consumed
	PartitionKey string
	// LatestOffset is the highest message offset in this partition
	LatestOffset int64
	// AckedOffset is the last acked offset for this consumer group
	AckedOffset int64
	// Lag is the number of unprocessed messages (LatestOffset - AckedOffset)
	Lag int64
}

type LeaseInfo struct {
	// ConsumerGroup is the consumer group name
	ConsumerGroup string
	// Topic is the topic being consumed
	Topic string
	// PartitionKey is the partition that is leased
	PartitionKey string
	// LeasedBy is the worker that owns the lease
	LeasedBy string
	// LeasedAt is the epoch milliseconds when the lease was acquired
	LeasedAt int64
	// LeaseRenewedAt is the epoch milliseconds of the last renewal
	LeaseRenewedAt int64
}

type MessageDetail struct {
	MessageSummary
	// Payload is the message body
	Payload []byte
	// Metadata contains key-value pairs for message attributes
	Metadata map[string]string
	// FailedAt is epoch milliseconds when the message failed (0 for normal)
	FailedAt int64
	// FailureCount is total failures before DLQ move (0 for normal)
	FailureCount int
	// LastError is the error message from final failure
	LastError string
	// OriginalTopic is where the message originally failed
	OriginalTopic string
}

type MessageSummary struct {
	// Offset is the auto-incrementing sequence number
	Offset int64
	// ID is the unique message identifier
	ID string
	// Topic identifies the queue type
	Topic string
	// PartitionKey determines message distribution
	PartitionKey string
	// CreatedAt is the epoch milliseconds when the message was created
	CreatedAt int64
	// PublishedAt is the epoch milliseconds when the message was published
	PublishedAt int64
}

type OffsetInfo struct {
	// ConsumerGroup is the consumer group name
	ConsumerGroup string
	// Topic is the topic being consumed
	Topic string
	// PartitionKey is the partition being consumed
	PartitionKey string
	// OffsetAcked is the last successfully acked offset
	OffsetAcked int64
	// UpdatedAt is the epoch milliseconds of the last update
	UpdatedAt int64
}

type TopicInfo struct {
	// Topic is the queue topic name
	Topic string
	// MessageCount is the number of messages in this topic
	MessageCount int64
}

type TopicStats struct {
	// Topic is the queue topic name
	Topic string
	// TotalMessages is the total number of messages
	TotalMessages int64
	// DLQCount is the number of messages in the DLQ for this topic
	DLQCount int64
	// PartitionCount is the number of distinct partitions
	PartitionCount int64
	// ConsumerGroupCount is the number of consumer groups consuming this topic
	ConsumerGroupCount int64
}