Struct JobContext 

pub struct JobContext {
    pub config: Config,
    pub source: ConnectionInfo,
    pub target: ConnectionInfo,
    pub metrics: Arc<Metrics>,
    pub cancel: CancellationToken,
    pub progress: ProgressHandle,
    pub source_version: Arc<Mutex<Option<String>>>,
}

Everything a command needs.

Fields

config: Config

source: ConnectionInfo

target: ConnectionInfo

metrics: Arc<Metrics>

cancel: CancellationToken

progress: ProgressHandle

source_version: Arc<Mutex<Option<String>>>

Source version() once known (preflight or stream open), for the heartbeat row.

Implementations

impl JobContext

pub fn new(config: Config, cancel: CancellationToken) -> Result<Self>

pub fn stream_factory(&self) -> PgStreamFactory