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.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.