package
9.0.0-beta.1.pre+incompatible
Repository: https://github.com/pingcap/ticdc.git
Documentation: pkg.go.dev
# Functions
Cap is the option to configure the capacity of a creating buffer.
New returns a Chann that may represent a buffered, an unbuffered or an unbounded channel.
NewAutoDrainChann creates a new DrainableChann.
NewUnlimitedChannel creates a new UnlimitedChannel.
No description provided by the author
# Structs
Chann is a generic channel abstraction that can be either buffered, unbuffered, or unbounded.
DrainableChann is a channel that will be drained when it is closed.
UnlimitedChannel is a channel with unlimited buffer.