valkeystream

type ConfigurationError struct {
	// Field identifies the invalid package-owned option without its value.
	Field string
	// Cause retains the validation cause for errors.Is and errors.As.
	Cause error
}

type DeliveryAttemptLimitResolver func(core.TaskMessage) int64

type Option func(*options) error

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

type Stats struct {
	// Depth is pending plus lag, or -1 when lag is unknown.
	Depth int64
	// Pending is the server-reported consumer-group pending count.
	Pending int64
	// Lag is the server-reported count not yet delivered to the group.
	Lag int64
	// LagKnown reports whether Depth and Lag are determinate.
	LagKnown bool
	// OldestPendingAge is derived from the oldest pending stream identifier.
	OldestPendingAge time.Duration
	// Enqueued counts successful appends observed by this worker process.
	Enqueued uint64
	// Delivered counts messages returned by Request in this worker process.
	Delivered uint64
	// Reclaimed counts delivered messages recovered through XAUTOCLAIM.
	Reclaimed uint64
	// Retries counts reclaimed retry deliveries observed by this worker.
	Retries uint64
	// Acknowledged counts successful source acknowledgements.
	Acknowledged uint64
	// DeadLettered counts successful terminal dead-letter transfers.
	DeadLettered uint64
	// SettlementFailures counts failed ack and dead-letter operations.
	SettlementFailures uint64
}

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