Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitMetrics ¶
func InitMetrics(registry *prometheus.Registry)
InitMetrics registers all metrics in this file
Types ¶
type Puller ¶
type Puller interface { // Run the puller, continually fetch event from TiKV and add event into buffer. Run(ctx context.Context) error GetResolvedTs() uint64 Output() <-chan *model.RawKVEntry IsInitialized() bool }
Puller pull data from tikv and push changes into a buffer.
func NewPuller ¶
func NewPuller( ctx context.Context, pdCli pd.Client, grpcPool kv.GrpcPool, regionCache *tikv.RegionCache, tikvStorage tikv.Storage, checkpointTs uint64, spans []regionspan.Span, enableOldValue bool, ) Puller
NewPuller create a new Puller fetch event start from checkpointTs and put into buf.
Click to show internal directories.
Click to hide internal directories.