cdc

type Config struct {
	DLQConfig       dlq.Config
	SequencerConfig sequencer.Config
	ScriptConfig    script.Config

	// Switch between BestEffort mode and Core if the applied resolved
	// timestamp is older than this threshold. A negative or zero value
	// will disable BestEffort switching.
	BestEffortWindow time.Duration

	// Force the use of BestEffort mode.
	BestEffortOnly bool

	// Discard all incoming HTTP payloads. This is useful for tuning
	// changefeed throughput without considering cdc-sink performance.
	Discard bool

	// If non-zero, wait half before and after consuming the payload.
	DiscardDelay time.Duration

	// Write directly to staging tables. May limit compatibility with
	// schemas that contain foreign keys.
	Immediate bool

	// The maximum amount of data to buffer when reading a single line
	// of ndjson input. This can be increased if the source cluster
	// has large blob values.
	NDJsonBuffer int

	// The maximum amount of time that we want to allow an HTTP handler
	// to run for.
	ResponseTimeout time.Duration
}

type Handler struct {
	Authenticator types.Authenticator // Access checks.
	Config        *Config             // Runtime options.
	TargetPool    *types.TargetPool   // Access to the target cluster.
	Targets       *Targets            // Access to target schemas.
}

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