puller

Documentation

Index

• type MultiplexingWrapper
  • func NewMultiplexingPullerWrapper(changefeed model.ChangeFeedID, client *kv.SharedClient, ...) *MultiplexingWrapper
• type Wrapper
  • func NewPullerWrapper(changefeed model.ChangeFeedID, span tablepb.Span, tableName string, ...) Wrapper
  • func NewPullerWrapperForTest(changefeed model.ChangeFeedID, span tablepb.Span, tableName string, ...) Wrapper
• type WrapperImpl
  • func (n *WrapperImpl) Close()
  • func (n *WrapperImpl) GetStats() puller.Stats
  • func (n *WrapperImpl) Start(ctx context.Context, up *upstream.Upstream, eventSortEngine engine.SortEngine, ...)

Types

type MultiplexingWrapper

type MultiplexingWrapper struct {
	*puller.MultiplexingPuller
	// contains filtered or unexported fields
}

MultiplexingWrapper wraps `puller.MultiplexingPuller`.

func NewMultiplexingPullerWrapper

func NewMultiplexingPullerWrapper(
	changefeed model.ChangeFeedID,
	client *kv.SharedClient,
	eventSortEngine engine.SortEngine,
	frontiers int,
) *MultiplexingWrapper

NewMultiplexingPullerWrapper creates a `MultiplexingWrapper`.

type Wrapper

type Wrapper interface {
	// Start the puller and send internal errors into `errChan`.
	Start(
		ctx context.Context,
		up *upstream.Upstream,
		eventSortEngine engine.SortEngine,
		errChan chan<- error,
	)
	GetStats() puller.Stats
	Close()
}

Wrapper is a wrapper of puller used by source manager.

func NewPullerWrapper

func NewPullerWrapper(
	changefeed model.ChangeFeedID,
	span tablepb.Span,
	tableName string,
	startTs model.Ts,
	bdrMode bool,
	shouldSplitKVEntry model.ShouldSplitKVEntry,
) Wrapper

NewPullerWrapper creates a new puller wrapper.

func NewPullerWrapperForTest

func NewPullerWrapperForTest(
	changefeed model.ChangeFeedID,
	span tablepb.Span,
	tableName string,
	startTs model.Ts,
	bdrMode bool,
	shouldSplitKVEntry model.ShouldSplitKVEntry,
) Wrapper

NewPullerWrapperForTest creates a new puller wrapper for test.

type WrapperImpl

type WrapperImpl struct {
	// contains filtered or unexported fields
}

WrapperImpl is a wrapper of puller used by source manager.

func (*WrapperImpl) Close

func (n *WrapperImpl) Close()

Close the puller wrapper.

func (*WrapperImpl) GetStats

func (n *WrapperImpl) GetStats() puller.Stats

GetStats returns the puller stats.

func (*WrapperImpl) Start

func (n *WrapperImpl) Start(
	ctx context.Context,
	up *upstream.Upstream,
	eventSortEngine engine.SortEngine,
	errChan chan<- error,
)

Start the puller wrapper. We use cdc context to put capture info and role into context.