agent

Documentation

Index

• func NewAgent(ctx context.Context, captureID model.CaptureID, liveness *model.Liveness, ...) (internal.Agent, error)

Functions

func NewAgent

func NewAgent(ctx context.Context,
	captureID model.CaptureID,
	liveness *model.Liveness,
	changeFeedID model.ChangeFeedID,
	messageServer *p2p.MessageServer,
	messageRouter p2p.MessageRouter,
	ownerInfoClient etcd.OwnerCaptureInfoClient,
	tableExecutor internal.TableExecutor,
	changefeedEpoch uint64,
	cfg *config.SchedulerConfig,
) (internal.Agent, error)

NewAgent returns a new agent.