package
0.0.0-20210721050518-7055b2f98007
Repository: https://github.com/crowdstrike/kafka-replicator.git
Documentation: pkg.go.dev

# Functions

CallFactory invokes the list of factories and returns the obtained instances.
ExponentialBackoff computes the exponential backoff intervals summing to provided total duration.
FormatMetricName returns the metric name with reserved chars removed.
GetLocalIPv4 will return this hosts IPv4 address.
IsCanceledError returns true if the provided value is a cancellation error.
LifecycleStart executes startup procedure.
LifecycleStop executes shutdown procedure.
NewSegmentHeap returns a new SegmentHeap instance.
NewUUID returns a randomly generated UUID.
SetDefaultBreaker sets the default value for provided location.
SetDefaultDuration sets the default value for provided location.
SetDefaultInt sets the default value for provided location.
SetDefaultRetrier sets the default value for provided location.
SetDefaultString sets the default value for provided location.
SetDefaultUint64 sets the default value for provided location.
Validate performs tag-based validation for the provided instance.

# Structs

FactoryType could have been avoided if Go had generics.

# Type aliases

DelayEvent is a helper Kafka event used during tests.
SegmentHeap is the heap of segments ordered by offset.