Skip to content

Commit

Permalink
chore: add description pause and resume
Browse files Browse the repository at this point in the history
  • Loading branch information
Abdulsametileri committed Apr 2, 2024
1 parent 3a9a202 commit 58a3234
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions consumer_base.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,13 @@ type Consumer interface {
Consume()

// Pause function pauses consumer, it is stop consuming new messages
// It works idempotent under the hood
// Calling with multiple goroutines is safe
Pause()

// Resume function resumes consumer, it is start to working
// It works idempotent under the hood
// Calling with multiple goroutines is safe
Resume()

// GetMetricCollectors for the purpose of making metric collectors available.
Expand Down

0 comments on commit 58a3234

Please sign in to comment.