package
0.2.2
Repository: https://github.com/gig/kafka-client.git
Documentation: pkg.go.dev

# Functions

AwaitCondition waits until a given condition is satisfied or times out.
AwaitWaitGroup does a timed wait on the wait group.
NewRunLifecycle returns a lifecycle object that can be used by a Runnable implementation to make sure the start/stop operations are idempotent.

# Structs

RunLifecycle manages the start/stop lifecycle for a runnable implementation.