pub unsafe fn filter_by_origin_cb_wrapper(
    arg_ctx: *mut LogicalDecodingContext,
    arg_origin_id: RepOriginId
) -> bool