Skip to content
This repository was archived by the owner on Aug 3, 2020. It is now read-only.
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions topic.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,16 +22,16 @@ type TopicHandler interface {

// Topic subscription, responsible for enforcing the quality of service limits.
type topic struct {
eventIdx uint64 // Index to assign to inbound events for logging purposes
eventPool *pool.ThreadPool // Queue and concurrency limiter for the event handlers
eventUsed int32 // Actual memory usage of the event queue

// Application layer fields
handler TopicHandler // Handler for topic events

// Quality of service fields
limits *TopicLimits // Limits on the inbound message processing

eventIdx uint64 // Index to assign to inbound events for logging purposes
eventPool *pool.ThreadPool // Queue and concurrency limiter for the event handlers
eventUsed int32 // Actual memory usage of the event queue

// Bookkeeping fields
logger log15.Logger
}
Expand Down