operator

type Config struct {
	OperatorDB        *sql.DB
	WorkerDB          *sql.DB
	ReplicationConfig *pgconn.Config
}

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

type ProjectionBootstrapResult struct {
	BootstrapID            string   `json:"bootstrap_id"`
	RegistryGeneration     int64    `json:"registry_generation"`
	SourceStreamGeneration string   `json:"source_stream_generation"`
	ActiveSlotName         string   `json:"active_slot_name"`
	CandidateSlotName      string   `json:"candidate_slot_name"`
	SchemaVersion          *int64   `json:"schema_version"`
	SchemaHash             *string  `json:"schema_hash"`
	ActivationBarrier      string   `json:"activation_barrier"`
	AffectedScopes         []string `json:"affected_scopes"`
}